testing

Documentation

Index

• func HaveZnode(path string) OmegaMatcher
• func HaveZnodeData(path string, data []byte) OmegaMatcher
• func MatchEvent(eventType zk.EventType, eventState zk.State) OmegaMatcher
• func ZkCollectEvents(count int, evntChn <-chan zk.Event) []zk.Event
• func ZkConnect(zkHosts []string, zkSessionTimeout time.Duration, ...) (client *Client)
• func ZkCreatePaths(client *Client, paths ...string)
• func ZkDeletePaths(client *Client, paths ...string)
• func ZkUniqueNodeName() string
• type EventMatcher
  • func (matcher *EventMatcher) FailureMessage(actual interface{}) (message string)
  • func (matcher *EventMatcher) Match(actual interface{}) (success bool, err error)
  • func (matcher *EventMatcher) NegatedFailureMessage(actual interface{}) (message string)
• type HaveZnodeDataMatcher
  • func (matcher *HaveZnodeDataMatcher) FailureMessage(actual interface{}) (message string)
  • func (matcher *HaveZnodeDataMatcher) Match(actual interface{}) (success bool, err error)
  • func (matcher *HaveZnodeDataMatcher) NegatedFailureMessage(actual interface{}) (message string)
• type HaveZnodeMatcher
  • func (matcher *HaveZnodeMatcher) FailureMessage(actual interface{}) (message string)
  • func (matcher *HaveZnodeMatcher) Match(actual interface{}) (success bool, err error)
  • func (matcher *HaveZnodeMatcher) NegatedFailureMessage(actual interface{}) (message string)

Functions

func HaveZnode

func HaveZnode(path string) OmegaMatcher

func HaveZnodeData

func HaveZnodeData(path string, data []byte) OmegaMatcher

func MatchEvent

func MatchEvent(eventType zk.EventType, eventState zk.State) OmegaMatcher

func ZkCollectEvents

func ZkCollectEvents(count int, evntChn <-chan zk.Event) []zk.Event

Collects go-zookeeper events.

func ZkConnect

func ZkConnect(zkHosts []string, zkSessionTimeout time.Duration, zkWaitForSessionTimeout time.Duration) (client *Client)

Create client connection to zk with timeout.

func ZkCreatePaths

func ZkCreatePaths(client *Client, paths ...string)

Create paths (without children) in zk.

func ZkDeletePaths

func ZkDeletePaths(client *Client, paths ...string)

Delete paths (without children) in zk.

func ZkUniqueNodeName

func ZkUniqueNodeName() string

Generates a unique string suitable for using as a node name.

Types

type EventMatcher

type EventMatcher struct {
	Type  zk.EventType
	State zk.State
}

Custom gomega matcher: zk event is the expected type with the expected state.

func (*EventMatcher) FailureMessage

func (matcher *EventMatcher) FailureMessage(actual interface{}) (message string)

func (*EventMatcher) Match

func (matcher *EventMatcher) Match(actual interface{}) (success bool, err error)

func (*EventMatcher) NegatedFailureMessage

func (matcher *EventMatcher) NegatedFailureMessage(actual interface{}) (message string)

type HaveZnodeDataMatcher

type HaveZnodeDataMatcher struct {
	Path string
	Data []byte
}

Custom gomega matcher: validates zk node data.

func (*HaveZnodeDataMatcher) FailureMessage

func (matcher *HaveZnodeDataMatcher) FailureMessage(actual interface{}) (message string)

func (*HaveZnodeDataMatcher) Match

func (matcher *HaveZnodeDataMatcher) Match(actual interface{}) (success bool, err error)

func (*HaveZnodeDataMatcher) NegatedFailureMessage

func (matcher *HaveZnodeDataMatcher) NegatedFailureMessage(actual interface{}) (message string)

type HaveZnodeMatcher

type HaveZnodeMatcher struct {
	Path string
}

Custom gomega matcher: validates zk node exists.

func (*HaveZnodeMatcher) FailureMessage

func (matcher *HaveZnodeMatcher) FailureMessage(actual interface{}) (message string)

func (*HaveZnodeMatcher) Match

func (matcher *HaveZnodeMatcher) Match(actual interface{}) (success bool, err error)

func (*HaveZnodeMatcher) NegatedFailureMessage

func (matcher *HaveZnodeMatcher) NegatedFailureMessage(actual interface{}) (message string)