service

Documentation

Index

• Constants
• func WithJSON(marshal protojson.MarshalOptions, unmarshal protojson.UnmarshalOptions) connect.Option
• type ConnectService
  • func NewConnectService(logger *logger.Logger, evaluator eval.IEvaluator, ...) *ConnectService
  • func (s *ConnectService) AddMiddleware(mw middleware.IMiddleware)
  • func (s *ConnectService) Notify(n service.Notification)
  • func (s *ConnectService) Serve(ctx context.Context, svcConf service.Configuration) error
  • func (s *ConnectService) Shutdown()
• type FlagEvaluationService
  • func NewFlagEvaluationService(log *logger.Logger, eval eval.IEvaluator, eventingCfg *eventingConfiguration, ...) *FlagEvaluationService
  • func (s *FlagEvaluationService) EventStream(ctx context.Context, req *connect.Request[schemaV1.EventStreamRequest], ...) error
  • func (s *FlagEvaluationService) ResolveAll(ctx context.Context, req *connect.Request[schemaV1.ResolveAllRequest]) (*connect.Response[schemaV1.ResolveAllResponse], error)
  • func (s *FlagEvaluationService) ResolveBoolean(ctx context.Context, req *connect.Request[schemaV1.ResolveBooleanRequest]) (*connect.Response[schemaV1.ResolveBooleanResponse], error)
  • func (s *FlagEvaluationService) ResolveFloat(ctx context.Context, req *connect.Request[schemaV1.ResolveFloatRequest]) (*connect.Response[schemaV1.ResolveFloatResponse], error)
  • func (s *FlagEvaluationService) ResolveInt(ctx context.Context, req *connect.Request[schemaV1.ResolveIntRequest]) (*connect.Response[schemaV1.ResolveIntResponse], error)
  • func (s *FlagEvaluationService) ResolveObject(ctx context.Context, req *connect.Request[schemaV1.ResolveObjectRequest]) (*connect.Response[schemaV1.ResolveObjectResponse], error)
  • func (s *FlagEvaluationService) ResolveString(ctx context.Context, req *connect.Request[schemaV1.ResolveStringRequest]) (*connect.Response[schemaV1.ResolveStringResponse], error)

Constants

const ErrorPrefix = "FlagdError:"

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 eval.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 eval.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[schemaV1.EventStreamRequest],
	stream *connect.ServerStream[schemaV1.EventStreamResponse],
) error

func (*FlagEvaluationService) ResolveAll

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

func (*FlagEvaluationService) ResolveBoolean

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

func (*FlagEvaluationService) ResolveFloat

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

func (*FlagEvaluationService) ResolveInt

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

func (*FlagEvaluationService) ResolveObject

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

func (*FlagEvaluationService) ResolveString

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