backendv1beta1connect

package
v0.2.9 Latest Latest
Warning

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

 Go to latest Published: Mar 22, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ConfigurationServiceName is the fully-qualified name of the ConfigurationService service.
	ConfigurationServiceName = "lekko.backend.v1beta1.ConfigurationService"
)
View Source 
const (
	// DistributionServiceName is the fully-qualified name of the DistributionService service.
	DistributionServiceName = "lekko.backend.v1beta1.DistributionService"
)

Variables

This section is empty.

Functions

func NewConfigurationServiceHandler 

func NewConfigurationServiceHandler(svc ConfigurationServiceHandler, opts ...connect_go.HandlerOption) (string, http.Handler)

NewConfigurationServiceHandler 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 NewDistributionServiceHandler 

func NewDistributionServiceHandler(svc DistributionServiceHandler, opts ...connect_go.HandlerOption) (string, http.Handler)

NewDistributionServiceHandler 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 ConfigurationServiceClient 

type ConfigurationServiceClient interface {
	GetBoolValue(context.Context, *connect_go.Request[v1beta1.GetBoolValueRequest]) (*connect_go.Response[v1beta1.GetBoolValueResponse], error)
	GetIntValue(context.Context, *connect_go.Request[v1beta1.GetIntValueRequest]) (*connect_go.Response[v1beta1.GetIntValueResponse], error)
	GetFloatValue(context.Context, *connect_go.Request[v1beta1.GetFloatValueRequest]) (*connect_go.Response[v1beta1.GetFloatValueResponse], error)
	GetStringValue(context.Context, *connect_go.Request[v1beta1.GetStringValueRequest]) (*connect_go.Response[v1beta1.GetStringValueResponse], error)
	GetProtoValue(context.Context, *connect_go.Request[v1beta1.GetProtoValueRequest]) (*connect_go.Response[v1beta1.GetProtoValueResponse], error)
	GetJSONValue(context.Context, *connect_go.Request[v1beta1.GetJSONValueRequest]) (*connect_go.Response[v1beta1.GetJSONValueResponse], error)
	// Register is used to denote a RepositoryKey and namespaces within it
	// that a client is interested in so the server can cache and keep up to date.
	Register(context.Context, *connect_go.Request[v1beta1.RegisterRequest]) (*connect_go.Response[v1beta1.RegisterResponse], error)
	// Deregister is used to tell the server that a client is shutting down. It is not
	// required but preferable to have implementations call this once their lifecycle
	// has completed.
	Deregister(context.Context, *connect_go.Request[v1beta1.DeregisterRequest]) (*connect_go.Response[v1beta1.DeregisterResponse], error)
}

ConfigurationServiceClient is a client for the lekko.backend.v1beta1.ConfigurationService service.

func NewConfigurationServiceClient 

func NewConfigurationServiceClient(httpClient connect_go.HTTPClient, baseURL string, opts ...connect_go.ClientOption) ConfigurationServiceClient

NewConfigurationServiceClient constructs a client for the lekko.backend.v1beta1.ConfigurationService 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 ConfigurationServiceHandler 

type ConfigurationServiceHandler interface {
	GetBoolValue(context.Context, *connect_go.Request[v1beta1.GetBoolValueRequest]) (*connect_go.Response[v1beta1.GetBoolValueResponse], error)
	GetIntValue(context.Context, *connect_go.Request[v1beta1.GetIntValueRequest]) (*connect_go.Response[v1beta1.GetIntValueResponse], error)
	GetFloatValue(context.Context, *connect_go.Request[v1beta1.GetFloatValueRequest]) (*connect_go.Response[v1beta1.GetFloatValueResponse], error)
	GetStringValue(context.Context, *connect_go.Request[v1beta1.GetStringValueRequest]) (*connect_go.Response[v1beta1.GetStringValueResponse], error)
	GetProtoValue(context.Context, *connect_go.Request[v1beta1.GetProtoValueRequest]) (*connect_go.Response[v1beta1.GetProtoValueResponse], error)
	GetJSONValue(context.Context, *connect_go.Request[v1beta1.GetJSONValueRequest]) (*connect_go.Response[v1beta1.GetJSONValueResponse], error)
	// Register is used to denote a RepositoryKey and namespaces within it
	// that a client is interested in so the server can cache and keep up to date.
	Register(context.Context, *connect_go.Request[v1beta1.RegisterRequest]) (*connect_go.Response[v1beta1.RegisterResponse], error)
	// Deregister is used to tell the server that a client is shutting down. It is not
	// required but preferable to have implementations call this once their lifecycle
	// has completed.
	Deregister(context.Context, *connect_go.Request[v1beta1.DeregisterRequest]) (*connect_go.Response[v1beta1.DeregisterResponse], error)
}

ConfigurationServiceHandler is an implementation of the lekko.backend.v1beta1.ConfigurationService service.

type DistributionServiceClient 

type DistributionServiceClient interface {
	// Returns the latest commit sha of the repository. The client is expected to poll this
	// rpc to become aware of updates.
	GetRepositoryVersion(context.Context, *connect_go.Request[v1beta1.GetRepositoryVersionRequest]) (*connect_go.Response[v1beta1.GetRepositoryVersionResponse], error)
	// Returns the entire state of the repository, including all feature flags.
	GetRepositoryContents(context.Context, *connect_go.Request[v1beta1.GetRepositoryContentsRequest]) (*connect_go.Response[v1beta1.GetRepositoryContentsResponse], error)
	// Sends metrics to the backend related to flag evaluation. This rpc can be used
	// to batch metrics to lekko servers.
	SendFlagEvaluationMetrics(context.Context, *connect_go.Request[v1beta1.SendFlagEvaluationMetricsRequest]) (*connect_go.Response[v1beta1.SendFlagEvaluationMetricsResponse], error)
	// Registers a client and returns a session key.
	RegisterClient(context.Context, *connect_go.Request[v1beta1.RegisterClientRequest]) (*connect_go.Response[v1beta1.RegisterClientResponse], error)
	// Deregisters a client using a session key.
	DeregisterClient(context.Context, *connect_go.Request[v1beta1.DeregisterClientRequest]) (*connect_go.Response[v1beta1.DeregisterClientResponse], error)
}

DistributionServiceClient is a client for the lekko.backend.v1beta1.DistributionService service.

func NewDistributionServiceClient 

func NewDistributionServiceClient(httpClient connect_go.HTTPClient, baseURL string, opts ...connect_go.ClientOption) DistributionServiceClient

NewDistributionServiceClient constructs a client for the lekko.backend.v1beta1.DistributionService 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 DistributionServiceHandler 

type DistributionServiceHandler interface {
	// Returns the latest commit sha of the repository. The client is expected to poll this
	// rpc to become aware of updates.
	GetRepositoryVersion(context.Context, *connect_go.Request[v1beta1.GetRepositoryVersionRequest]) (*connect_go.Response[v1beta1.GetRepositoryVersionResponse], error)
	// Returns the entire state of the repository, including all feature flags.
	GetRepositoryContents(context.Context, *connect_go.Request[v1beta1.GetRepositoryContentsRequest]) (*connect_go.Response[v1beta1.GetRepositoryContentsResponse], error)
	// Sends metrics to the backend related to flag evaluation. This rpc can be used
	// to batch metrics to lekko servers.
	SendFlagEvaluationMetrics(context.Context, *connect_go.Request[v1beta1.SendFlagEvaluationMetricsRequest]) (*connect_go.Response[v1beta1.SendFlagEvaluationMetricsResponse], error)
	// Registers a client and returns a session key.
	RegisterClient(context.Context, *connect_go.Request[v1beta1.RegisterClientRequest]) (*connect_go.Response[v1beta1.RegisterClientResponse], error)
	// Deregisters a client using a session key.
	DeregisterClient(context.Context, *connect_go.Request[v1beta1.DeregisterClientRequest]) (*connect_go.Response[v1beta1.DeregisterClientResponse], error)
}

DistributionServiceHandler is an implementation of the lekko.backend.v1beta1.DistributionService service.

type UnimplementedConfigurationServiceHandler 

type UnimplementedConfigurationServiceHandler struct{}

UnimplementedConfigurationServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedConfigurationServiceHandler) Deregister added in v0.2.6 

func (UnimplementedConfigurationServiceHandler) Deregister(context.Context, *connect_go.Request[v1beta1.DeregisterRequest]) (*connect_go.Response[v1beta1.DeregisterResponse], error)

func (UnimplementedConfigurationServiceHandler) GetBoolValue 

func (UnimplementedConfigurationServiceHandler) GetBoolValue(context.Context, *connect_go.Request[v1beta1.GetBoolValueRequest]) (*connect_go.Response[v1beta1.GetBoolValueResponse], error)

func (UnimplementedConfigurationServiceHandler) GetFloatValue added in v0.2.6 

func (UnimplementedConfigurationServiceHandler) GetFloatValue(context.Context, *connect_go.Request[v1beta1.GetFloatValueRequest]) (*connect_go.Response[v1beta1.GetFloatValueResponse], error)

func (UnimplementedConfigurationServiceHandler) GetIntValue added in v0.2.6 

func (UnimplementedConfigurationServiceHandler) GetIntValue(context.Context, *connect_go.Request[v1beta1.GetIntValueRequest]) (*connect_go.Response[v1beta1.GetIntValueResponse], error)

func (UnimplementedConfigurationServiceHandler) GetJSONValue 

func (UnimplementedConfigurationServiceHandler) GetJSONValue(context.Context, *connect_go.Request[v1beta1.GetJSONValueRequest]) (*connect_go.Response[v1beta1.GetJSONValueResponse], error)

func (UnimplementedConfigurationServiceHandler) GetProtoValue 

func (UnimplementedConfigurationServiceHandler) GetProtoValue(context.Context, *connect_go.Request[v1beta1.GetProtoValueRequest]) (*connect_go.Response[v1beta1.GetProtoValueResponse], error)

func (UnimplementedConfigurationServiceHandler) GetStringValue added in v0.2.6 

func (UnimplementedConfigurationServiceHandler) GetStringValue(context.Context, *connect_go.Request[v1beta1.GetStringValueRequest]) (*connect_go.Response[v1beta1.GetStringValueResponse], error)

func (UnimplementedConfigurationServiceHandler) Register 

func (UnimplementedConfigurationServiceHandler) Register(context.Context, *connect_go.Request[v1beta1.RegisterRequest]) (*connect_go.Response[v1beta1.RegisterResponse], error)

type UnimplementedDistributionServiceHandler 

type UnimplementedDistributionServiceHandler struct{}

UnimplementedDistributionServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedDistributionServiceHandler) DeregisterClient added in v0.2.6 

func (UnimplementedDistributionServiceHandler) DeregisterClient(context.Context, *connect_go.Request[v1beta1.DeregisterClientRequest]) (*connect_go.Response[v1beta1.DeregisterClientResponse], error)

func (UnimplementedDistributionServiceHandler) GetRepositoryContents 

func (UnimplementedDistributionServiceHandler) GetRepositoryContents(context.Context, *connect_go.Request[v1beta1.GetRepositoryContentsRequest]) (*connect_go.Response[v1beta1.GetRepositoryContentsResponse], error)

func (UnimplementedDistributionServiceHandler) GetRepositoryVersion 

func (UnimplementedDistributionServiceHandler) GetRepositoryVersion(context.Context, *connect_go.Request[v1beta1.GetRepositoryVersionRequest]) (*connect_go.Response[v1beta1.GetRepositoryVersionResponse], error)

func (UnimplementedDistributionServiceHandler) RegisterClient 

func (UnimplementedDistributionServiceHandler) RegisterClient(context.Context, *connect_go.Request[v1beta1.RegisterClientRequest]) (*connect_go.Response[v1beta1.RegisterClientResponse], error)

func (UnimplementedDistributionServiceHandler) SendFlagEvaluationMetrics 

func (UnimplementedDistributionServiceHandler) SendFlagEvaluationMetrics(context.Context, *connect_go.Request[v1beta1.SendFlagEvaluationMetricsRequest]) (*connect_go.Response[v1beta1.SendFlagEvaluationMetricsResponse], error)

Source Files

View all Source files

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.