kubernetes

Documentation

Index

• func NewHaMembership(_ *config.Dcp, bus helpers.Bus) membership.Membership
• func NewLeaderElector(client Client, config *config.Dcp, myIdentity *models.Identity, ...) leaderelector.LeaderElector
• func NewStatefulSetMembership(config *config.Dcp) membership.Membership
• type Client
  • func NewClient(myIdentity *models.Identity) Client

Functions

func NewHaMembership

func NewHaMembership(_ *config.Dcp, bus helpers.Bus) membership.Membership

func NewLeaderElector

func NewLeaderElector(
	client Client,
	config *config.Dcp,
	myIdentity *models.Identity,
	handler leaderelector.Handler,
	bus helpers.Bus,
) leaderelector.LeaderElector

func NewStatefulSetMembership

func NewStatefulSetMembership(config *config.Dcp) membership.Membership

Types

type Client

type Client interface {
	CoordinationV1() v1.CoordinationV1Interface
	AddLabel(namespace string, key string, value string)
	RemoveLabel(namespace string, key string)
}

func NewClient

func NewClient(myIdentity *models.Identity) Client