package mock

import "github.com/mesos/mesos-go/api/v0/detector/zoo/mock"

Index ¶

• type AllMastersListener
• func (a *AllMastersListener) OnMasterChanged(mi *mesos.MasterInfo)
• func (a *AllMastersListener) UpdatedMasters(mi []*mesos.MasterInfo)
• type Client
• func NewClient(testZkPath string, initialChildren ...string) (mocked *Client, snaps chan []string, errs chan error)
• func (m *Client) Data(path string) (a []byte, b error)
• func (m *Client) Stop()
• func (m *Client) Stopped() (a <-chan struct{})
• func (m *Client) WatchChildren(path string) (a string, b <-chan []string, c <-chan error)
• type Connector
• func NewConnector() *Connector
• func (conn *Connector) Children(path string) ([]string, *zk.Stat, error)
• func (conn *Connector) ChildrenW(path string) ([]string, *zk.Stat, <-chan zk.Event, error)
• func (conn *Connector) Close()
• func (conn *Connector) Get(path string) ([]byte, *zk.Stat, error)

Types ¶

type AllMastersListener ¶

type AllMastersListener struct {
	mock.Mock
}

implements MasterChanged and AllMasters extension

func (*AllMastersListener) OnMasterChanged ¶

func (a *AllMastersListener) OnMasterChanged(mi *mesos.MasterInfo)

func (*AllMastersListener) UpdatedMasters ¶

func (a *AllMastersListener) UpdatedMasters(mi []*mesos.MasterInfo)

type Client ¶

type Client struct {
	mock.Mock
}

func NewClient ¶

func NewClient(testZkPath string, initialChildren ...string) (mocked *Client, snaps chan []string, errs chan error)

newMockZkClient returns a mocked implementation of ZKInterface that implements expectations for Stop() and Stopped(); multiple calls to Stop() are safe.

func (*Client) Data ¶

func (m *Client) Data(path string) (a []byte, b error)

func (*Client) Stop ¶

func (m *Client) Stop()

func (*Client) Stopped ¶

func (m *Client) Stopped() (a <-chan struct{})

func (*Client) WatchChildren ¶

func (m *Client) WatchChildren(path string) (a string, b <-chan []string, c <-chan error)

type Connector ¶

type Connector struct {
	mock.Mock
}

Impersontates a zk.Connection It implements interface Connector

func NewConnector ¶

func NewConnector() *Connector

func (*Connector) Children ¶

func (conn *Connector) Children(path string) ([]string, *zk.Stat, error)

func (*Connector) ChildrenW ¶

func (conn *Connector) ChildrenW(path string) ([]string, *zk.Stat, <-chan zk.Event, error)

func (*Connector) Close ¶

func (conn *Connector) Close()

func (*Connector) Get ¶

func (conn *Connector) Get(path string) ([]byte, *zk.Stat, error)

Source Files ¶

conn.go mock.go