cloudmock

Documentation

Index

• type LogsTestServer
  • func NewLoggingTestServer() (*LogsTestServer, error)
  • func (l *LogsTestServer) CreateWriteLogEntriesRequests() []*logpb.WriteLogEntriesRequest
  • func (l *LogsTestServer) Serve()
  • func (l *LogsTestServer) Shutdown()
  • func (l *LogsTestServer) UserAgent() string
• type MetricsTestServer
  • func NewMetricTestServer() (*MetricsTestServer, error)
  • func (m *MetricsTestServer) CreateMetricDescriptorRequests() []*monitoringpb.CreateMetricDescriptorRequest
  • func (m *MetricsTestServer) CreateServiceTimeSeriesRequests() []*monitoringpb.CreateTimeSeriesRequest
  • func (m *MetricsTestServer) CreateTimeSeriesRequests() []*monitoringpb.CreateTimeSeriesRequest
  • func (m *MetricsTestServer) Serve() error
  • func (m *MetricsTestServer) Shutdown()
  • func (m *MetricsTestServer) UserAgent() string
• type TraceServerOption
  • func WithDelay(t time.Duration) TraceServerOption
  • func WithErrorResponse(err error) TraceServerOption
• type TracesTestServer
  • func NewTracesTestServer(opts ...TraceServerOption) (*TracesTestServer, error)
  • func (t *TracesTestServer) CreateBatchWriteSpansRequests() []*tracepb.BatchWriteSpansRequest
  • func (t *TracesTestServer) Serve()
  • func (t *TracesTestServer) Shutdown()
  • func (t *TracesTestServer) UserAgent() string

Types

type LogsTestServer

type LogsTestServer struct {

	// Endpoint where the gRPC server is listening
	Endpoint string
	// contains filtered or unexported fields
}

func NewLoggingTestServer

func NewLoggingTestServer() (*LogsTestServer, error)

func (*LogsTestServer) CreateWriteLogEntriesRequests

func (l *LogsTestServer) CreateWriteLogEntriesRequests() []*logpb.WriteLogEntriesRequest

func (*LogsTestServer) Serve

func (l *LogsTestServer) Serve()

func (*LogsTestServer) Shutdown

func (l *LogsTestServer) Shutdown()

func (*LogsTestServer) UserAgent

func (l *LogsTestServer) UserAgent() string

Pops out the UserAgent from the most recent CreateWriteLogEntries.

type MetricsTestServer

type MetricsTestServer struct {
	Endpoint string

	RetryCount int
	// contains filtered or unexported fields
}

func NewMetricTestServer

func NewMetricTestServer() (*MetricsTestServer, error)

func (*MetricsTestServer) CreateMetricDescriptorRequests

func (m *MetricsTestServer) CreateMetricDescriptorRequests() []*monitoringpb.CreateMetricDescriptorRequest

Pops out the CreateMetricDescriptorRequests which the test server has received so far.

func (*MetricsTestServer) CreateServiceTimeSeriesRequests

func (m *MetricsTestServer) CreateServiceTimeSeriesRequests() []*monitoringpb.CreateTimeSeriesRequest

Pops out the CreateServiceTimeSeriesRequests which the test server has received so far.

func (*MetricsTestServer) CreateTimeSeriesRequests

func (m *MetricsTestServer) CreateTimeSeriesRequests() []*monitoringpb.CreateTimeSeriesRequest

Pops out the CreateTimeSeriesRequests which the test server has received so far.

func (*MetricsTestServer) Serve

func (m *MetricsTestServer) Serve() error

func (*MetricsTestServer) Shutdown

func (m *MetricsTestServer) Shutdown()

func (*MetricsTestServer) UserAgent

func (m *MetricsTestServer) UserAgent() string

Pops out the UserAgent from the most recent CreateTimeSeriesRequests or CreateServiceTimeSeriesRequests.

type TraceServerOption

type TraceServerOption interface {
	// contains filtered or unexported methods
}

func WithDelay

func WithDelay(t time.Duration) TraceServerOption

WithDelay sets a delay on the test server before it responds.

func WithErrorResponse

func WithErrorResponse(err error) TraceServerOption

type TracesTestServer

type TracesTestServer struct {

	// Endpoint where the gRPC server is listening
	Endpoint string

	Retries int
	// contains filtered or unexported fields
}

func NewTracesTestServer

func NewTracesTestServer(opts ...TraceServerOption) (*TracesTestServer, error)

func (*TracesTestServer) CreateBatchWriteSpansRequests

func (t *TracesTestServer) CreateBatchWriteSpansRequests() []*tracepb.BatchWriteSpansRequest

func (*TracesTestServer) Serve

func (t *TracesTestServer) Serve()

func (*TracesTestServer) Shutdown

func (t *TracesTestServer) Shutdown()

func (*TracesTestServer) UserAgent

func (t *TracesTestServer) UserAgent() string

Pops out the UserAgent from the most recent BatchWriteSpans.