testutils

Documentation

Index

• func ACLAnonymous(t *testing.T) resolver.Result
• func ACLNoPermissions(t *testing.T) resolver.Result
• func ACLServiceRead(t *testing.T, serviceName string) resolver.Result
• func ACLServiceWriteAny(t *testing.T) resolver.Result
• func ACLsDisabled(t *testing.T) resolver.Result
• func RunTestServer(t *testing.T, services ...GRPCService) net.Addr
• func TestStateStore(t *testing.T, publisher state.EventPublisher) *state.Store
• type FakeFSM
  • func SetupFSMAndPublisher(t *testing.T, config FakeFSMConfig) (*FakeFSM, state.EventPublisher)
  • func (f *FakeFSM) GetStore() *state.Store
  • func (f *FakeFSM) ReplaceStore(store *state.Store)
• type FakeFSMConfig
• type GRPCService
• type Registrar

Functions

func ACLAnonymous

func ACLAnonymous(t *testing.T) resolver.Result

func ACLNoPermissions

func ACLNoPermissions(t *testing.T) resolver.Result

func ACLServiceRead

func ACLServiceRead(t *testing.T, serviceName string) resolver.Result

func ACLServiceWriteAny

func ACLServiceWriteAny(t *testing.T) resolver.Result

func ACLsDisabled

func ACLsDisabled(t *testing.T) resolver.Result

func RunTestServer

func RunTestServer(t *testing.T, services ...GRPCService) net.Addr

func TestStateStore

func TestStateStore(t *testing.T, publisher state.EventPublisher) *state.Store

Types

type FakeFSM

type FakeFSM struct {
	// contains filtered or unexported fields
}

func SetupFSMAndPublisher

func SetupFSMAndPublisher(t *testing.T, config FakeFSMConfig) (*FakeFSM, state.EventPublisher)

func (*FakeFSM) GetStore

func (f *FakeFSM) GetStore() *state.Store

func (*FakeFSM) ReplaceStore

func (f *FakeFSM) ReplaceStore(store *state.Store)

type FakeFSMConfig

type FakeFSMConfig struct {
	Register Registrar
	Refresh  []stream.Topic
	// contains filtered or unexported fields
}

type GRPCService

type GRPCService interface {
	Register(*grpc.Server)
}

type Registrar

type Registrar func(*FakeFSM, *stream.EventPublisher)