service

package
v0.10.1 Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ErrorPrefix = "FlagdError:"
)

Variables

This section is empty.

Functions

func WithJSON 

func WithJSON(marshal protojson.MarshalOptions, unmarshal protojson.UnmarshalOptions) connect.Option

WithJSON customizes a connect-go Client or Handler's JSON by exposing MarshalOptions, and UnmarshalOptions See: https://github.com/connectrpc/connect-go/blob/main/codec.go Heavily inspired by https://github.com/akshayjshah/connectproto

Types

type ConnectService 

type ConnectService struct {
	// contains filtered or unexported fields
}

func NewConnectService 

func NewConnectService(
	logger *logger.Logger, evaluator evaluator.IEvaluator, mRecorder *telemetry.MetricsRecorder,
) *ConnectService

NewConnectService creates a ConnectService with provided parameters

func (*ConnectService) AddMiddleware 

func (s *ConnectService) AddMiddleware(mw middleware.IMiddleware)

func (*ConnectService) Notify 

func (s *ConnectService) Notify(n service.Notification)

Notify emits change event notifications for subscriptions

func (*ConnectService) Serve 

func (s *ConnectService) Serve(ctx context.Context, svcConf service.Configuration) error

Serve serves services with provided configuration options

func (*ConnectService) Shutdown 

func (s *ConnectService) Shutdown()

type FlagEvaluationService 

type FlagEvaluationService struct {
	// contains filtered or unexported fields
}

func NewFlagEvaluationService 

func NewFlagEvaluationService(log *logger.Logger,
	eval evaluator.IEvaluator,
	eventingCfg *eventingConfiguration,
	metricsRecorder *telemetry.MetricsRecorder,
) *FlagEvaluationService

NewFlagEvaluationService creates a FlagEvaluationService with provided parameters

func (*FlagEvaluationService) EventStream 

func (s *FlagEvaluationService) EventStream(
	ctx context.Context,
	req *connect.Request[evalV1.EventStreamRequest],
	stream *connect.ServerStream[evalV1.EventStreamResponse],
) error

func (*FlagEvaluationService) ResolveAll 

func (s *FlagEvaluationService) ResolveAll(
	ctx context.Context,
	req *connect.Request[evalV1.ResolveAllRequest],
) (*connect.Response[evalV1.ResolveAllResponse], error)

nolint:dupl,funlen

func (*FlagEvaluationService) ResolveBoolean 

func (s *FlagEvaluationService) ResolveBoolean(
	ctx context.Context,
	req *connect.Request[evalV1.ResolveBooleanRequest],
) (*connect.Response[evalV1.ResolveBooleanResponse], error)

func (*FlagEvaluationService) ResolveFloat 

func (s *FlagEvaluationService) ResolveFloat(
	ctx context.Context,
	req *connect.Request[evalV1.ResolveFloatRequest],
) (*connect.Response[evalV1.ResolveFloatResponse], error)

func (*FlagEvaluationService) ResolveInt 

func (s *FlagEvaluationService) ResolveInt(
	ctx context.Context,
	req *connect.Request[evalV1.ResolveIntRequest],
) (*connect.Response[evalV1.ResolveIntResponse], error)

func (*FlagEvaluationService) ResolveObject 

func (s *FlagEvaluationService) ResolveObject(
	ctx context.Context,
	req *connect.Request[evalV1.ResolveObjectRequest],
) (*connect.Response[evalV1.ResolveObjectResponse], error)

func (*FlagEvaluationService) ResolveString 

func (s *FlagEvaluationService) ResolveString(
	ctx context.Context,
	req *connect.Request[evalV1.ResolveStringRequest],
) (*connect.Response[evalV1.ResolveStringResponse], error)

type OldFlagEvaluationService 

type OldFlagEvaluationService struct {
	// contains filtered or unexported fields
}

OldFlagEvaluationService implements the methods required for the soon-to-be deprecated flag evaluation schema this can be removed as a part of https://github.com/open-feature/flagd/issues/1088

func NewOldFlagEvaluationService 

func NewOldFlagEvaluationService(log *logger.Logger,
	eval evaluator.IEvaluator, eventingCfg *eventingConfiguration, metricsRecorder *telemetry.MetricsRecorder,
) *OldFlagEvaluationService

NewOldFlagEvaluationService creates a OldFlagEvaluationService with provided parameters

func (*OldFlagEvaluationService) EventStream 

func (s *OldFlagEvaluationService) EventStream(
	ctx context.Context,
	req *connect.Request[schemaV1.EventStreamRequest],
	stream *connect.ServerStream[schemaV1.EventStreamResponse],
) error

func (*OldFlagEvaluationService) ResolveAll 

func (s *OldFlagEvaluationService) ResolveAll(
	ctx context.Context,
	req *connect.Request[schemaV1.ResolveAllRequest],
) (*connect.Response[schemaV1.ResolveAllResponse], error)

nolint:dupl

func (*OldFlagEvaluationService) ResolveBoolean 

func (s *OldFlagEvaluationService) ResolveBoolean(
	ctx context.Context,
	req *connect.Request[schemaV1.ResolveBooleanRequest],
) (*connect.Response[schemaV1.ResolveBooleanResponse], error)

func (*OldFlagEvaluationService) ResolveFloat 

func (s *OldFlagEvaluationService) ResolveFloat(
	ctx context.Context,
	req *connect.Request[schemaV1.ResolveFloatRequest],
) (*connect.Response[schemaV1.ResolveFloatResponse], error)

func (*OldFlagEvaluationService) ResolveInt 

func (s *OldFlagEvaluationService) ResolveInt(
	ctx context.Context,
	req *connect.Request[schemaV1.ResolveIntRequest],
) (*connect.Response[schemaV1.ResolveIntResponse], error)

func (*OldFlagEvaluationService) ResolveObject 

func (s *OldFlagEvaluationService) ResolveObject(
	ctx context.Context,
	req *connect.Request[schemaV1.ResolveObjectRequest],
) (*connect.Response[schemaV1.ResolveObjectResponse], error)

func (*OldFlagEvaluationService) ResolveString 

func (s *OldFlagEvaluationService) ResolveString(
	ctx context.Context,
	req *connect.Request[schemaV1.ResolveStringRequest],
) (*connect.Response[schemaV1.ResolveStringResponse], error)

Source Files

View all Source files

Directories

Path Synopsis

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.