testing

package

v0.0.0-...-10905f8 Latest Latest Go to latest Published: Dec 3, 2016 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

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

Collects go-zookeeper events.

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

Create client connection to zk with timeout.

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

Create paths (without children) in zk.

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

Delete paths (without children) in zk.

func ZkUniqueNodeName() string

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

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

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

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 struct {
	Path string
	Data []byte
}

Custom gomega matcher: validates zk node data.

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 struct {
	Path string
}

Custom gomega matcher: validates zk node exists.

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)