monitoringv1alpha1connect

Documentation

Index

• Constants
• func NewTokenServiceHandler(svc TokenServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
• func NewValidationServiceHandler(svc ValidationServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
• type TokenServiceClient
  • func NewTokenServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) TokenServiceClient
• type TokenServiceHandler
• type UnimplementedTokenServiceHandler
  • func (UnimplementedTokenServiceHandler) CreateWriteToken(context.Context, *connect.Request[v1alpha1.CreateWriteTokenRequest]) (*connect.Response[v1alpha1.CreateWriteTokenResponse], error)
• type UnimplementedValidationServiceHandler
  • func (UnimplementedValidationServiceHandler) ValidateWriteToken(context.Context, *connect.Request[v1alpha1.ValidateWriteTokenRequest]) (*connect.Response[v1alpha1.ValidateWriteTokenResponse], error)
• type ValidationServiceClient
  • func NewValidationServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ValidationServiceClient
• type ValidationServiceHandler

Constants

const (
	// TokenServiceCreateWriteTokenProcedure is the fully-qualified name of the TokenService's
	// CreateWriteToken RPC.
	TokenServiceCreateWriteTokenProcedure = "/commonfate.factory.monitoring.v1alpha1.TokenService/CreateWriteToken"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

const (
	// TokenServiceName is the fully-qualified name of the TokenService service.
	TokenServiceName = "commonfate.factory.monitoring.v1alpha1.TokenService"
)

const (
	// ValidationServiceName is the fully-qualified name of the ValidationService service.
	ValidationServiceName = "commonfate.factory.monitoring.v1alpha1.ValidationService"
)

const (
	// ValidationServiceValidateWriteTokenProcedure is the fully-qualified name of the
	// ValidationService's ValidateWriteToken RPC.
	ValidationServiceValidateWriteTokenProcedure = "/commonfate.factory.monitoring.v1alpha1.ValidationService/ValidateWriteToken"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

Functions

func NewTokenServiceHandler

func NewTokenServiceHandler(svc TokenServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewTokenServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewValidationServiceHandler

func NewValidationServiceHandler(svc ValidationServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewValidationServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type TokenServiceClient

type TokenServiceClient interface {
	// Obtain a Write Token, used to authenticate to our OpenTelemetry collector.
	CreateWriteToken(context.Context, *connect.Request[v1alpha1.CreateWriteTokenRequest]) (*connect.Response[v1alpha1.CreateWriteTokenResponse], error)
}

TokenServiceClient is a client for the commonfate.factory.monitoring.v1alpha1.TokenService service.

func NewTokenServiceClient

func NewTokenServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) TokenServiceClient

NewTokenServiceClient constructs a client for the commonfate.factory.monitoring.v1alpha1.TokenService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type TokenServiceHandler

type TokenServiceHandler interface {
	// Obtain a Write Token, used to authenticate to our OpenTelemetry collector.
	CreateWriteToken(context.Context, *connect.Request[v1alpha1.CreateWriteTokenRequest]) (*connect.Response[v1alpha1.CreateWriteTokenResponse], error)
}

TokenServiceHandler is an implementation of the commonfate.factory.monitoring.v1alpha1.TokenService service.

type UnimplementedTokenServiceHandler

type UnimplementedTokenServiceHandler struct{}

UnimplementedTokenServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedTokenServiceHandler) CreateWriteToken

func (UnimplementedTokenServiceHandler) CreateWriteToken(context.Context, *connect.Request[v1alpha1.CreateWriteTokenRequest]) (*connect.Response[v1alpha1.CreateWriteTokenResponse], error)

type UnimplementedValidationServiceHandler

type UnimplementedValidationServiceHandler struct{}

UnimplementedValidationServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedValidationServiceHandler) ValidateWriteToken

func (UnimplementedValidationServiceHandler) ValidateWriteToken(context.Context, *connect.Request[v1alpha1.ValidateWriteTokenRequest]) (*connect.Response[v1alpha1.ValidateWriteTokenResponse], error)

type ValidationServiceClient

type ValidationServiceClient interface {
	// Check to see if an existing Write Token is valid.
	ValidateWriteToken(context.Context, *connect.Request[v1alpha1.ValidateWriteTokenRequest]) (*connect.Response[v1alpha1.ValidateWriteTokenResponse], error)
}

ValidationServiceClient is a client for the commonfate.factory.monitoring.v1alpha1.ValidationService service.

func NewValidationServiceClient

func NewValidationServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ValidationServiceClient

NewValidationServiceClient constructs a client for the commonfate.factory.monitoring.v1alpha1.ValidationService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type ValidationServiceHandler

type ValidationServiceHandler interface {
	// Check to see if an existing Write Token is valid.
	ValidateWriteToken(context.Context, *connect.Request[v1alpha1.ValidateWriteTokenRequest]) (*connect.Response[v1alpha1.ValidateWriteTokenResponse], error)
}

ValidationServiceHandler is an implementation of the commonfate.factory.monitoring.v1alpha1.ValidationService service.