sidecar

Documentation

Index

• type MemberController
  • func New(name, namespace string, kubeClient kubernetes.Interface, ...) (*MemberController, error)
  • func (m *MemberController) Run(threadiness int, stopCh <-chan struct{}) error
  • func (m *MemberController) Sync(memberService *v1.Service) error

Types

type MemberController

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

MemberController encapsulates all the tools the sidecar needs to talk to the Kubernetes API

func New

func New(
	name, namespace string,
	kubeClient kubernetes.Interface,
	rookClient rookClientset.Interface,
	serviceInformer coreinformers.ServiceInformer,
) (*MemberController, error)

New return a new MemberController

func (*MemberController) Run

func (m *MemberController) Run(threadiness int, stopCh <-chan struct{}) error

Run starts executing the sync loop for the sidecar

func (*MemberController) Sync

func (m *MemberController) Sync(memberService *v1.Service) error