testutils

Documentation

Index

• func RunTestServer(t *testing.T, services ...GRPCService) net.Addr
• func TestAuthorizerServiceRead(t *testing.T, serviceName string) acl.Authorizer
• func TestAuthorizerServiceWriteAny(t *testing.T) acl.Authorizer
• 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 RunTestServer

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

func TestAuthorizerServiceRead

func TestAuthorizerServiceRead(t *testing.T, serviceName string) acl.Authorizer

func TestAuthorizerServiceWriteAny

func TestAuthorizerServiceWriteAny(t *testing.T) acl.Authorizer

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)