proto

Documentation

Index

• type Client
  • func NewGrpcClient(managerStateCache proxycache.ManagerStateInterface) Client
• type SpecManager
  • func (sm *SpecManager) AcquireSpec() *ctrlmeshconv.InternalSpec
  • func (sm *SpecManager) GetStatus() *ctrlmeshproto.ProxyStatus
  • func (sm *SpecManager) ReleaseSpec()
  • func (sm *SpecManager) UpdateLeaderElection(le *ctrlmeshproto.LeaderElectionState)
  • func (sm *SpecManager) UpdateSpec(spec *ctrlmeshproto.ProxySpec)

Types

type Client

type Client interface {
	Start(ctx context.Context) error
	GetSpecManager() *SpecManager
}

func NewGrpcClient

func NewGrpcClient(managerStateCache proxycache.ManagerStateInterface) Client

type SpecManager

type SpecManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*SpecManager) AcquireSpec

func (sm *SpecManager) AcquireSpec() *ctrlmeshconv.InternalSpec

func (*SpecManager) GetStatus

func (sm *SpecManager) GetStatus() *ctrlmeshproto.ProxyStatus

func (*SpecManager) ReleaseSpec

func (sm *SpecManager) ReleaseSpec()

func (*SpecManager) UpdateLeaderElection

func (sm *SpecManager) UpdateLeaderElection(le *ctrlmeshproto.LeaderElectionState)

func (*SpecManager) UpdateSpec

func (sm *SpecManager) UpdateSpec(spec *ctrlmeshproto.ProxySpec)