zookeeper

Documentation

Index

• func Path(path string) string
• type Connection
  • func NewConnection(kafkaArgs *args.ParsedArguments) (Connection, error)
• type MockConnection
  • func (m *MockConnection) Children(s string) ([]string, *zk.Stat, error)
  • func (m *MockConnection) Close()
  • func (m *MockConnection) Get(s string) ([]byte, *zk.Stat, error)

Functions

func Path

func Path(path string) string

Path takes a zookeeper path and prepends it with argument args.GlobalArgs

Types

type Connection

type Connection interface {
	Get(string) ([]byte, *zk.Stat, error)
	Children(string) ([]string, *zk.Stat, error)
	Close()
}

Connection interface to allow easy mocking of a Zookeeper connection

func NewConnection

func NewConnection(kafkaArgs *args.ParsedArguments) (Connection, error)

NewConnection creates a new Connection with the given arguments. If not hosts are specified then a nil Connection and error will be returned

Waiting on issue https://github.com/samuel/go-zookeeper/issues/108 so we can change this function and allow us to mock out the zk.Connect function

type MockConnection

type MockConnection struct {
	mock.Mock
}

MockConnection implements Connection to facilitate testing.

func (*MockConnection) Children

func (m *MockConnection) Children(s string) ([]string, *zk.Stat, error)

Children mocks the Children method

func (*MockConnection) Close

func (m *MockConnection) Close()

Close does nothing

func (*MockConnection) Get

func (m *MockConnection) Get(s string) ([]byte, *zk.Stat, error)

Get mocks the Get method