poller

Documentation

Index

• type PollClient
  • func (pc *PollClient) Start()
  • func (pc *PollClient) Stop()
• type PollConnection
  • func NewPollConnection(index int, client *http.Client, ...) *PollConnection
  • func (conn *PollConnection) Start(ctx context.Context)
  • func (conn *PollConnection) Stop()
• type PollManager
  • func NewPollManager(isMaster bool, selfNamespace, gatewayName string, ...) (*PollManager, error)
  • func (pm *PollManager) Run(workers int, stopCh <-chan struct{})
• type PollState

Types

type PollClient

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

func (*PollClient) Start

func (pc *PollClient) Start()

func (*PollClient) Stop

func (pc *PollClient) Stop()

type PollConnection

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

func NewPollConnection

func NewPollConnection(index int, client *http.Client, receiverDomain, pollerDomain, serviceName string) *PollConnection

func (*PollConnection) Start

func (conn *PollConnection) Start(ctx context.Context)

func (*PollConnection) Stop

func (conn *PollConnection) Stop()

type PollManager

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

func NewPollManager

func NewPollManager(isMaster bool, selfNamespace, gatewayName string, serviceInformer corev1informers.ServiceInformer,
	domainRouteInformer kusciaextv1alpha1.DomainRouteInformer, gatewayInformer kusciaextv1alpha1.GatewayInformer) (*PollManager, error)

func (*PollManager) Run

func (pm *PollManager) Run(workers int, stopCh <-chan struct{})

type PollState

type PollState int