kubernetes

Documentation

Index

• Constants
• func NewHaMembership(_ *config.Dcp, bus EventBus.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() Client

Constants

const DefaultNamespace = "default"

Functions

func NewHaMembership

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

func NewLeaderElector

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

func NewStatefulSetMembership

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

Types

type Client

type Client interface {
	CoordinationV1() v1.CoordinationV1Interface
	AddLabel(key string, value string)
	RemoveLabel(key string)
	GetIdentity() *models.Identity
}

func NewClient

func NewClient() Client