k8s

Documentation

Index

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

Types

type Client

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

func New

func New(opts Options) (*Client, error)

func (*Client) RefreshPeers

func (c *Client) RefreshPeers(ctx context.Context) error

func (*Client) Watch

func (c *Client) Watch(ctx context.Context) error

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)
}