service

Documentation

Index

• func GetEndpointFromKubeObjects(c client.Client, obj types.NamespacedName) (endpoint.Endpoint, error)
• func NewEndpoint(namespacedName types.NamespacedName, labels map[string]string, hostname string, ...) endpoint.Endpoint
• type ServiceEndpoint
  • func (s *ServiceEndpoint) Create(c client.Client) error
  • func (s *ServiceEndpoint) ExposedPort() int32
  • func (s *ServiceEndpoint) Hostname() string
  • func (s *ServiceEndpoint) IsHealthy(c client.Client) (bool, error)
  • func (s *ServiceEndpoint) Labels() map[string]string
  • func (s *ServiceEndpoint) NamespacedName() types.NamespacedName
  • func (s *ServiceEndpoint) Port() int32

Functions

func GetEndpointFromKubeObjects

func GetEndpointFromKubeObjects(c client.Client, obj types.NamespacedName) (endpoint.Endpoint, error)

GetEndpointFromKubeObjects check if the required svc is created and healthy. It populates the fields for the Endpoint needed for transfer and transport objects.

func NewEndpoint

func NewEndpoint(namespacedName types.NamespacedName, labels map[string]string, hostname string, svcType corev1.ServiceType) endpoint.Endpoint

Types

type ServiceEndpoint

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

func (*ServiceEndpoint) Create

func (s *ServiceEndpoint) Create(c client.Client) error

func (*ServiceEndpoint) ExposedPort

func (s *ServiceEndpoint) ExposedPort() int32

func (*ServiceEndpoint) Hostname

func (s *ServiceEndpoint) Hostname() string

func (*ServiceEndpoint) IsHealthy

func (s *ServiceEndpoint) IsHealthy(c client.Client) (bool, error)

func (*ServiceEndpoint) Labels

func (s *ServiceEndpoint) Labels() map[string]string

func (*ServiceEndpoint) NamespacedName

func (s *ServiceEndpoint) NamespacedName() types.NamespacedName

func (*ServiceEndpoint) Port

func (s *ServiceEndpoint) Port() int32