k8s

Documentation

Index

• type Client
  • func New(ctx context.Context, opts Options) (*Client, error)
  • func (c *Client) Wait()
• type Options
• type PeerSetter

Types

type Client

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

func New

func New(ctx context.Context, opts Options) (*Client, error)

func (*Client) Wait

func (c *Client) Wait()

type Options

type Options struct {
	Namespace  string
	PortName   string
	PeerSetter PeerSetter

	OnError    func(err error)
	OnNewPeers func(peers ...string)
}

type PeerSetter

type PeerSetter interface {
	SetPeers(peers ...string)
}