mocks

package

v0.15.10-rc.1 Latest Latest Go to latest Published: Feb 23, 2024 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kubeshop/tracetest

Documentation ¶

Index ¶

type GrpcServerMock
- func NewGrpcServer() *GrpcServerMock
type Message

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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) GetLastDataStoreConnectionResponse ¶ added in v0.15.4

func (s *GrpcServerMock) GetLastDataStoreConnectionResponse() Message[*proto.DataStoreConnectionTestResponse]

func (*GrpcServerMock) GetLastOTLPConnectionResponse ¶ added in v0.15.4

func (s *GrpcServerMock) GetLastOTLPConnectionResponse() Message[*proto.OTLPConnectionTestResponse]

func (*GrpcServerMock) GetLastPollingResponse ¶

func (s *GrpcServerMock) GetLastPollingResponse() Message[*proto.PollingResponse]

func (*GrpcServerMock) GetLastTriggerResponse ¶

func (s *GrpcServerMock) GetLastTriggerResponse() Message[*proto.TriggerResponse]

func (*GrpcServerMock) RegisterDataStoreConnectionTestAgent ¶

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

func (*GrpcServerMock) RegisterOTLPConnectionTestListener ¶ added in v0.15.4

func (s *GrpcServerMock) RegisterOTLPConnectionTestListener(id *proto.AgentIdentification, stream proto.Orchestrator_RegisterOTLPConnectionTestListenerServer) 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) RegisterStopRequestAgent ¶ added in v0.15.4

func (s *GrpcServerMock) RegisterStopRequestAgent(id *proto.AgentIdentification, stream proto.Orchestrator_RegisterStopRequestAgentServer) error

func (*GrpcServerMock) RegisterTriggerAgent ¶

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

func (*GrpcServerMock) SendDataStoreConnectionTestRequest ¶ added in v0.15.4

func (s *GrpcServerMock) SendDataStoreConnectionTestRequest(ctx context.Context, request *proto.DataStoreConnectionTestRequest)

func (*GrpcServerMock) SendDataStoreConnectionTestResult ¶ added in v0.15.4

func (s *GrpcServerMock) SendDataStoreConnectionTestResult(ctx context.Context, result *proto.DataStoreConnectionTestResponse) (*proto.Empty, error)

func (*GrpcServerMock) SendOTLPConnectionTestRequest ¶ added in v0.15.4

func (s *GrpcServerMock) SendOTLPConnectionTestRequest(ctx context.Context, request *proto.OTLPConnectionTestRequest)

func (*GrpcServerMock) SendOTLPConnectionTestResult ¶ added in v0.15.4

func (s *GrpcServerMock) SendOTLPConnectionTestResult(ctx context.Context, result *proto.OTLPConnectionTestResponse) (*proto.Empty, error)

func (*GrpcServerMock) SendPolledSpans ¶

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

func (*GrpcServerMock) SendPollingRequest ¶

func (s *GrpcServerMock) SendPollingRequest(ctx context.Context, request *proto.PollingRequest)

func (*GrpcServerMock) SendTriggerRequest ¶

func (s *GrpcServerMock) SendTriggerRequest(ctx context.Context, request *proto.TriggerRequest)

func (*GrpcServerMock) SendTriggerResult ¶

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

func (*GrpcServerMock) Stop ¶ added in v0.14.7

func (s *GrpcServerMock) Stop()

func (*GrpcServerMock) TerminateConnection ¶

func (s *GrpcServerMock) TerminateConnection(ctx context.Context, reason string)

type Message ¶ added in v0.15.7

type Message[T any] struct {
	Context context.Context
	Data    T
}

Source Files ¶

View all Source files

grpc_server.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL