test

Documentation

Index

• Variables
• func NewFakeAddressProvider(adminport string, httpport string) common.ServiceAddressProvider
• func NewFakeProjector(port string) *fakeProjector
• type TestDefaultClientEnv
  • func (p *TestDefaultClientEnv) FilterTimestampsForNode(timestamps []*protobuf.TsVbuuid, node string) ([]*protobuf.TsVbuuid, error)
  • func (p *TestDefaultClientEnv) GetNodeListForBuckets(buckets []string) (map[string]string, error)
  • func (p *TestDefaultClientEnv) GetNodeListForTimestamps(timestamps []*common.TsVbuuid) (map[string][]*protobuf.TsVbuuid, error)
• type TestDefaultClientFactory
  • func (p *TestDefaultClientFactory) GetClientForNode(server string) manager.ProjectorStreamClient

Variables

var TT *testing.T

Functions

func NewFakeAddressProvider

func NewFakeAddressProvider(adminport string, httpport string) common.ServiceAddressProvider

func NewFakeProjector

func NewFakeProjector(port string) *fakeProjector

Types

type TestDefaultClientEnv

type TestDefaultClientEnv struct {
}

func (*TestDefaultClientEnv) FilterTimestampsForNode

func (p *TestDefaultClientEnv) FilterTimestampsForNode(timestamps []*protobuf.TsVbuuid, node string) ([]*protobuf.TsVbuuid, error)

func (*TestDefaultClientEnv) GetNodeListForBuckets

func (p *TestDefaultClientEnv) GetNodeListForBuckets(buckets []string) (map[string]string, error)

func (*TestDefaultClientEnv) GetNodeListForTimestamps

func (p *TestDefaultClientEnv) GetNodeListForTimestamps(timestamps []*common.TsVbuuid) (map[string][]*protobuf.TsVbuuid, error)

type TestDefaultClientFactory

type TestDefaultClientFactory struct {
}

func (*TestDefaultClientFactory) GetClientForNode

func (p *TestDefaultClientFactory) GetClientForNode(server string) manager.ProjectorStreamClient