stackdriverplugin

package
v0.0.0-...-455dc84 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 4, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ExpectedBearer       = "kvass"
	ExpectedTokenRequest = "grant_type=urn:ietf:params:oauth:grant-type:token-exchange&" +
		"subject_token=kombucha&" +
		"subject_token_type=urn:ietf:params:oauth:token-type:jwt&" +
		"scope=https://www.googleapis.com/auth/cloud-platform"
)
View Source 
const ResponseLatencyMetricName = "istio.io/service/server/response_latencies"

Variables

View Source 
var ExpectedTokenResponse = fmt.Sprintf(`{
 "access_token": "%s",
 "issued_token_type": "urn:ietf:params:oauth:token-type:access_token",
 "token_type": "Bearer",
 "expires_in": 180
}`, ExpectedBearer)

Functions

func NewFakeStackdriver 

func NewFakeStackdriver(port uint16, delay time.Duration,
	enableTLS bool, bearer string,
) (*MetricServer, *LoggingServer, *TracesServer, *grpc.Server)

NewFakeStackdriver creates a new fake Stackdriver server.

func RunFakeStackdriver 

func RunFakeStackdriver(port uint16) error

Types

type LoggingServer 

type LoggingServer struct {
	RcvLoggingReq chan *loggingpb.WriteLogEntriesRequest
	// contains filtered or unexported fields
}

LoggingServer is a fake stackdriver server which implements all logging v2 service methods.

func (*LoggingServer) DeleteLog 

func (s *LoggingServer) DeleteLog(context.Context, *loggingpb.DeleteLogRequest) (*empty.Empty, error)

DeleteLog implements DeleteLog method.

func (*LoggingServer) GetLogEntries 

func (s *LoggingServer) GetLogEntries(w http.ResponseWriter, req *http.Request)

GetLogEntries returns all received log entries in a ListLogEntriesResponse as a marshaled json string.

func (*LoggingServer) ListLogEntries 

func (s *LoggingServer) ListLogEntries(context.Context, *loggingpb.ListLogEntriesRequest) (*loggingpb.ListLogEntriesResponse, error)

ListLogEntries implements ListLogEntries method.

func (*LoggingServer) ListLogs 

func (s *LoggingServer) ListLogs(context.Context, *loggingpb.ListLogsRequest) (*loggingpb.ListLogsResponse, error)

ListLogs implements ListLogs method.

func (*LoggingServer) ListMonitoredResourceDescriptors 

func (s *LoggingServer) ListMonitoredResourceDescriptors(
	context.Context, *loggingpb.ListMonitoredResourceDescriptorsRequest) (
	*loggingpb.ListMonitoredResourceDescriptorsResponse, error,
)

ListMonitoredResourceDescriptors immplements ListMonitoredResourceDescriptors method.

func (*LoggingServer) TailLogEntries 

func (s *LoggingServer) TailLogEntries(server loggingpb.LoggingServiceV2_TailLogEntriesServer) error

func (*LoggingServer) WriteLogEntries 

func (s *LoggingServer) WriteLogEntries(ctx context.Context, req *loggingpb.WriteLogEntriesRequest) (*loggingpb.WriteLogEntriesResponse, error)

WriteLogEntries implements WriteLogEntries method.

type MetricServer 

type MetricServer struct {
	RcvMetricReq chan *monitoringpb.CreateTimeSeriesRequest
	// contains filtered or unexported fields
}

MetricServer is a fake stackdriver server which implements all monitoring v3 service methods.

func (*MetricServer) CreateMetricDescriptor 

func (s *MetricServer) CreateMetricDescriptor(_ context.Context, req *monitoringpb.CreateMetricDescriptorRequest) (*metric.MetricDescriptor, error)

CreateMetricDescriptor implements CreateMetricDescriptor method.

func (*MetricServer) CreateServiceTimeSeries 

func (s *MetricServer) CreateServiceTimeSeries(ctx context.Context, request *monitoringpb.CreateTimeSeriesRequest) (*emptypb.Empty, error)

func (*MetricServer) CreateTimeSeries 

func (s *MetricServer) CreateTimeSeries(ctx context.Context, req *monitoringpb.CreateTimeSeriesRequest) (*empty.Empty, error)

CreateTimeSeries implements CreateTimeSeries method.

func (*MetricServer) DeleteMetricDescriptor 

func (s *MetricServer) DeleteMetricDescriptor(context.Context, *monitoringpb.DeleteMetricDescriptorRequest) (*empty.Empty, error)

DeleteMetricDescriptor implements DeleteMetricDescriptor method.

func (*MetricServer) GetMetricDescriptor 

func (s *MetricServer) GetMetricDescriptor(
	context.Context, *monitoringpb.GetMetricDescriptorRequest) (
	*metric.MetricDescriptor, error,
)

GetMetricDescriptor implements GetMetricDescriptor method.

func (*MetricServer) GetMonitoredResourceDescriptor 

func (s *MetricServer) GetMonitoredResourceDescriptor(
	context.Context, *monitoringpb.GetMonitoredResourceDescriptorRequest) (
	*monitoredres.MonitoredResourceDescriptor, error,
)

GetMonitoredResourceDescriptor implements GetMonitoredResourceDescriptor method.

func (*MetricServer) GetTimeSeries 

func (s *MetricServer) GetTimeSeries(w http.ResponseWriter, req *http.Request)

GetTimeSeries returns all received time series in a ListTimeSeriesResponse as a marshaled json string

func (*MetricServer) ListMetricDescriptors 

func (s *MetricServer) ListMetricDescriptors(
	context.Context, *monitoringpb.ListMetricDescriptorsRequest) (
	*monitoringpb.ListMetricDescriptorsResponse, error,
)

ListMetricDescriptors implements ListMetricDescriptors method.

func (*MetricServer) ListMonitoredResourceDescriptors 

func (s *MetricServer) ListMonitoredResourceDescriptors(
	context.Context, *monitoringpb.ListMonitoredResourceDescriptorsRequest) (
	*monitoringpb.ListMonitoredResourceDescriptorsResponse, error,
)

ListMonitoredResourceDescriptors implements ListMonitoredResourceDescriptors method.

func (*MetricServer) ListTimeSeries 

func (s *MetricServer) ListTimeSeries(context.Context, *monitoringpb.ListTimeSeriesRequest) (*monitoringpb.ListTimeSeriesResponse, error)

ListTimeSeries implements ListTimeSeries method.

type SDLogEntry 

type SDLogEntry struct {
	LogBaseFile   string
	LogEntryFile  []string
	LogEntryCount int
}

type SecureTokenService 

type SecureTokenService struct {
	Port uint16
	// contains filtered or unexported fields
}

func (*SecureTokenService) Cleanup 

func (sts *SecureTokenService) Cleanup()

func (*SecureTokenService) Run 

func (sts *SecureTokenService) Run(_ *driver.Params) error

func (*SecureTokenService) ServeHTTP 

func (sts *SecureTokenService) ServeHTTP(resp http.ResponseWriter, req *http.Request)

type Stackdriver 

type Stackdriver struct {
	sync.Mutex

	Port  uint16
	Delay time.Duration
	// contains filtered or unexported fields
}

func (*Stackdriver) Check 

func (sd *Stackdriver) Check(p *driver.Params, tsFiles []string, lsFiles []SDLogEntry, verifyLatency bool) driver.Step

func (*Stackdriver) Cleanup 

func (sd *Stackdriver) Cleanup()

func (*Stackdriver) Reset 

func (sd *Stackdriver) Reset() driver.Step

func (*Stackdriver) Run 

func (sd *Stackdriver) Run(p *driver.Params) error

type TracesServer 

type TracesServer struct {
	RcvTracesReq chan *cloudtracev2.BatchWriteSpansRequest
	// contains filtered or unexported fields
}

TracesServer is a fake stackdriver server which implements all cloudtrace v1 service methods.

func (*TracesServer) BatchWriteSpans 

func (s *TracesServer) BatchWriteSpans(ctx context.Context, req *cloudtracev2.BatchWriteSpansRequest) (*empty.Empty, error)

BatchWriteSpans implements BatchWriteSpans method.

func (*TracesServer) CreateSpan 

func (s *TracesServer) CreateSpan(ctx context.Context, req *cloudtracev2.Span) (*cloudtracev2.Span, error)

CreateSpan implements CreateSpan method.

func (*TracesServer) GetTrace 

func (s *TracesServer) GetTrace(context.Context, *cloudtracev1.GetTraceRequest) (*cloudtracev1.Trace, error)

GetTrace implements GetTrace method.

func (*TracesServer) ListTraces 

func (s *TracesServer) ListTraces(ctx context.Context, req *cloudtracev1.ListTracesRequest) (*cloudtracev1.ListTracesResponse, error)

ListTraces implements ListTraces method.

func (*TracesServer) PatchTraces 

func (s *TracesServer) PatchTraces(context.Context, *cloudtracev1.PatchTracesRequest) (*empty.Empty, error)

GetTrace implements GetTrace method.

func (*TracesServer) Traces 

func (s *TracesServer) Traces(w http.ResponseWriter, r *http.Request)

Traces returns the batch of Tracess reported to the server in the form of a JSON-serialized string of a ListTracesResponse proto.

Source Files

View all Source files

Directories

Path Synopsis
edges module

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.