service

Documentation

Index

• Constants
• func AddressHandle(param resourcemanage.ExtendParams) (interface{}, error)
• func ExternalHandle(param resourcemanage.ExtendParams) (interface{}, error)
• func Handle(param resourcemanage.ExtendParams) (interface{}, error)
• type ExternalAccess
  • func NewExternalAccess(client client.Client, namespace string, name string, filter filter.Filter, ...) ExternalAccess
  • func (s *ExternalAccess) DeleteExternalAccess() error
  • func (s *ExternalAccess) GetExternalAccess() ([]ExternalAccessInfo, error)
  • func (s *ExternalAccess) GetExternalAccessConfigMap() (tcpResultMap map[int]*ExternalAccessInfo, ...)
  • func (s *ExternalAccess) GetExternalIP() ([]string, error)
  • func (s *ExternalAccess) SetExternalAccess(externalServices []ExternalAccessInfo) error
• type ExternalAccessInfo
• type Service
  • func NewService(client mgrclient.Client, namespace string, filter filter.Filter) Service
  • func (s *Service) GetExtendServices() (filter.K8sJson, error)

Constants

const (
	TCP = "TCP"
	UDP = "UDP"
)

Functions

func AddressHandle

func AddressHandle(param resourcemanage.ExtendParams) (interface{}, error)

func ExternalHandle

func ExternalHandle(param resourcemanage.ExtendParams) (interface{}, error)

func Handle

func Handle(param resourcemanage.ExtendParams) (interface{}, error)

Types

type ExternalAccess

type ExternalAccess struct {
	NginxNamespace           string
	NginxTcpServiceConfigMap string
	NginxUdpServiceConfigMap string
	// contains filtered or unexported fields
}

func NewExternalAccess

func NewExternalAccess(client client.Client, namespace string, name string, filter filter.Filter, nginxNs string, tcpCm string, udpCm string) ExternalAccess

func (*ExternalAccess) DeleteExternalAccess

func (s *ExternalAccess) DeleteExternalAccess() error

DeleteExternalAccess delete external service

func (*ExternalAccess) GetExternalAccess

func (s *ExternalAccess) GetExternalAccess() ([]ExternalAccessInfo, error)

GetExternalAccess get external info

func (*ExternalAccess) GetExternalAccessConfigMap

func (s *ExternalAccess) GetExternalAccessConfigMap() (tcpResultMap map[int]*ExternalAccessInfo, udpResultMap map[int]*ExternalAccessInfo, err error)

func (*ExternalAccess) GetExternalIP

func (s *ExternalAccess) GetExternalIP() ([]string, error)

GetExternalIP ingress-nginx pod status host IPs

func (*ExternalAccess) SetExternalAccess

func (s *ExternalAccess) SetExternalAccess(externalServices []ExternalAccessInfo) error

type ExternalAccessInfo

type ExternalAccessInfo struct {
	ServicePort     int    `json:"servicePort,omitempty"`
	Protocol        string `json:"protocol,omitempty"`
	ExternalPort    *int   `json:"externalPort,omitempty"`
	ServicePortName string `json:"servicePortName,omitempty"`
}

type Service

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

func NewService

func NewService(client mgrclient.Client, namespace string, filter filter.Filter) Service

func (*Service) GetExtendServices

func (s *Service) GetExtendServices() (filter.K8sJson, error)