network

package

v0.1.65 Latest Latest Go to latest Published: Mar 29, 2024 License: MIT Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/codefly-dev/core

Links

Open Source Insights

Documentation ¶

Index ¶

func APIInt(api string) int
func Container(port uint16) *basev0.NetworkInstance
func GetPidUsingPort(port int) (string, error)
func HashInt(s string, low, high int) int
func IsPortAvailable(port int) bool
func KillProcess(pid string) error
func KillProcessUsingPort(port int) error
func KubernetesService(service *configurations.Service, port uint16) *basev0.NetworkInstance
func Namespace(service *configurations.Service) string
func Native(port uint16) *basev0.NetworkInstance
func Public(port uint16) *basev0.NetworkInstance
func ToNamedPort(_ context.Context, app string, svc string, name string, api string) uint16
type DeployManager
- func NewDeployManager(_ context.Context) (*DeployManager, error)
- func (m *DeployManager) GenerateNetworkMappings(_ context.Context, service *configurations.Service, ...) ([]*basev0.NetworkMapping, error)
type FixedStrategy
type Manager
type RuntimeManager
- func NewRuntimeManager(_ context.Context) (*RuntimeManager, error)
- func (m *RuntimeManager) GenerateNetworkMappings(ctx context.Context, service *configurations.Service, ...) ([]*basev0.NetworkMapping, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func APIInt ¶

func APIInt(api string) int

func Container ¶

func Container(port uint16) *basev0.NetworkInstance

func GetPidUsingPort ¶ added in v0.1.64

func GetPidUsingPort(port int) (string, error)

func HashInt ¶

func HashInt(s string, low, high int) int

func IsPortAvailable ¶

func IsPortAvailable(port int) bool

func KillProcess ¶ added in v0.1.64

func KillProcess(pid string) error

func KillProcessUsingPort ¶ added in v0.1.64

func KillProcessUsingPort(port int) error

func KubernetesService ¶ added in v0.1.65

func KubernetesService(service *configurations.Service, port uint16) *basev0.NetworkInstance

func Namespace ¶ added in v0.1.65

func Namespace(service *configurations.Service) string

func Native ¶

func Native(port uint16) *basev0.NetworkInstance

func Public ¶ added in v0.1.64

func Public(port uint16) *basev0.NetworkInstance

func ToNamedPort ¶

func ToNamedPort(_ context.Context, app string, svc string, name string, api string) uint16

ToNamedPort strategy: APP-SVC-API Between 1100(0) and 4999(9) First 11 -> 49: hash app Next 0 -> 9: hash svc Next 0 - 9: hash name Last Digit: API 0: TCP 1: HTTP/ REST 2: gRPC

Types ¶

type DeployManager ¶ added in v0.1.65

type DeployManager struct {
}

func NewDeployManager ¶ added in v0.1.65

func NewDeployManager(_ context.Context) (*DeployManager, error)

func (*DeployManager) GenerateNetworkMappings ¶ added in v0.1.65

func (m *DeployManager) GenerateNetworkMappings(_ context.Context, service *configurations.Service, endpoints []*basev0.Endpoint) ([]*basev0.NetworkMapping, error)

GenerateNetworkMappings generates network mappings for a service endpoints

type FixedStrategy ¶

type FixedStrategy struct {
}

type Manager ¶ added in v0.1.65

type Manager interface {
	GenerateNetworkMappings(ctx context.Context, service *configurations.Service, endpoints []*basev0.Endpoint) ([]*basev0.NetworkMapping, error)
}

type RuntimeManager ¶

type RuntimeManager struct {
	// contains filtered or unexported fields
}

func NewRuntimeManager ¶ added in v0.1.64

func NewRuntimeManager(_ context.Context) (*RuntimeManager, error)

func (*RuntimeManager) GenerateNetworkMappings ¶

func (m *RuntimeManager) GenerateNetworkMappings(ctx context.Context, service *configurations.Service, endpoints []*basev0.Endpoint) ([]*basev0.NetworkMapping, error)

GenerateNetworkMappings generates network mappings for a service endpoints

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL