mocks

Documentation

Index

• type GrpcServerMock
  • func NewGrpcServer() *GrpcServerMock
  • func (s *GrpcServerMock) Addr() string
  • func (s *GrpcServerMock) Connect(ctx context.Context, req *proto.ConnectRequest) (*proto.AgentConfiguration, error)
  • func (s *GrpcServerMock) GetLastPollingResponse() *proto.PollingResponse
  • func (s *GrpcServerMock) GetLastTriggerResponse() *proto.TriggerResponse
  • func (s *GrpcServerMock) RegisterDataStoreConnectionTestAgent(id *proto.AgentIdentification, ...) error
  • func (s *GrpcServerMock) RegisterPollerAgent(id *proto.AgentIdentification, ...) error
  • func (s *GrpcServerMock) RegisterShutdownListener(_ *proto.AgentIdentification, ...) error
  • func (s *GrpcServerMock) RegisterTriggerAgent(id *proto.AgentIdentification, ...) error
  • func (s *GrpcServerMock) SendPolledSpans(ctx context.Context, result *proto.PollingResponse) (*proto.Empty, error)
  • func (s *GrpcServerMock) SendPollingRequest(request *proto.PollingRequest)
  • func (s *GrpcServerMock) SendTriggerRequest(request *proto.TriggerRequest)
  • func (s *GrpcServerMock) SendTriggerResult(ctx context.Context, result *proto.TriggerResponse) (*proto.Empty, error)
  • func (s *GrpcServerMock) TerminateConnection(reason string)

Types

type GrpcServerMock

type GrpcServerMock struct {
	proto.UnimplementedOrchestratorServer
	// contains filtered or unexported fields
}

func NewGrpcServer

func NewGrpcServer() *GrpcServerMock

func (*GrpcServerMock) Addr

func (s *GrpcServerMock) Addr() string

func (*GrpcServerMock) Connect

func (s *GrpcServerMock) Connect(ctx context.Context, req *proto.ConnectRequest) (*proto.AgentConfiguration, error)

func (*GrpcServerMock) GetLastPollingResponse

func (s *GrpcServerMock) GetLastPollingResponse() *proto.PollingResponse

func (*GrpcServerMock) GetLastTriggerResponse

func (s *GrpcServerMock) GetLastTriggerResponse() *proto.TriggerResponse

func (*GrpcServerMock) RegisterDataStoreConnectionTestAgent

func (s *GrpcServerMock) RegisterDataStoreConnectionTestAgent(id *proto.AgentIdentification, stream proto.Orchestrator_RegisterDataStoreConnectionTestAgentServer) error

func (*GrpcServerMock) RegisterPollerAgent

func (s *GrpcServerMock) RegisterPollerAgent(id *proto.AgentIdentification, stream proto.Orchestrator_RegisterPollerAgentServer) error

func (*GrpcServerMock) RegisterShutdownListener

func (s *GrpcServerMock) RegisterShutdownListener(_ *proto.AgentIdentification, stream proto.Orchestrator_RegisterShutdownListenerServer) error

func (*GrpcServerMock) RegisterTriggerAgent

func (s *GrpcServerMock) RegisterTriggerAgent(id *proto.AgentIdentification, stream proto.Orchestrator_RegisterTriggerAgentServer) error

func (*GrpcServerMock) SendPolledSpans

func (s *GrpcServerMock) SendPolledSpans(ctx context.Context, result *proto.PollingResponse) (*proto.Empty, error)

func (*GrpcServerMock) SendPollingRequest

func (s *GrpcServerMock) SendPollingRequest(request *proto.PollingRequest)

func (*GrpcServerMock) SendTriggerRequest

func (s *GrpcServerMock) SendTriggerRequest(request *proto.TriggerRequest)

func (*GrpcServerMock) SendTriggerResult

func (s *GrpcServerMock) SendTriggerResult(ctx context.Context, result *proto.TriggerResponse) (*proto.Empty, error)

func (*GrpcServerMock) TerminateConnection

func (s *GrpcServerMock) TerminateConnection(reason string)