monitoringv1alpha1connect

Documentation

Index

• Constants
• func NewHealthcheckServiceHandler(svc HealthcheckServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
• func NewTokenServiceHandler(svc TokenServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
• func NewValidationServiceHandler(svc ValidationServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
• type HealthcheckServiceClient
  • func NewHealthcheckServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) HealthcheckServiceClient
• type HealthcheckServiceHandler
• type TokenServiceClient
  • func NewTokenServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) TokenServiceClient
• type TokenServiceHandler
• type UnimplementedHealthcheckServiceHandler
  • func (UnimplementedHealthcheckServiceHandler) Ping(context.Context, *connect.Request[v1alpha1.PingRequest]) (*connect.Response[v1alpha1.PingResponse], error)
• 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 (
	// HealthcheckServiceName is the fully-qualified name of the HealthcheckService service.
	HealthcheckServiceName = "commonfate.factory.monitoring.v1alpha1.HealthcheckService"
)

const (
	// HealthcheckServicePingProcedure is the fully-qualified name of the HealthcheckService's Ping RPC.
	HealthcheckServicePingProcedure = "/commonfate.factory.monitoring.v1alpha1.HealthcheckService/Ping"
)

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 (
	// 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 NewHealthcheckServiceHandler

func NewHealthcheckServiceHandler(svc HealthcheckServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewHealthcheckServiceHandler 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 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 HealthcheckServiceClient

type HealthcheckServiceClient interface {
	// Ping the healthcheck service.
	Ping(context.Context, *connect.Request[v1alpha1.PingRequest]) (*connect.Response[v1alpha1.PingResponse], error)
}

HealthcheckServiceClient is a client for the commonfate.factory.monitoring.v1alpha1.HealthcheckService service.

func NewHealthcheckServiceClient

func NewHealthcheckServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) HealthcheckServiceClient

NewHealthcheckServiceClient constructs a client for the commonfate.factory.monitoring.v1alpha1.HealthcheckService 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 HealthcheckServiceHandler

type HealthcheckServiceHandler interface {
	// Ping the healthcheck service.
	Ping(context.Context, *connect.Request[v1alpha1.PingRequest]) (*connect.Response[v1alpha1.PingResponse], error)
}

HealthcheckServiceHandler is an implementation of the commonfate.factory.monitoring.v1alpha1.HealthcheckService service.

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 UnimplementedHealthcheckServiceHandler

type UnimplementedHealthcheckServiceHandler struct{}

UnimplementedHealthcheckServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedHealthcheckServiceHandler) Ping

func (UnimplementedHealthcheckServiceHandler) Ping(context.Context, *connect.Request[v1alpha1.PingRequest]) (*connect.Response[v1alpha1.PingResponse], error)

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.