proxyservice

type CacheHealthFn func(ctx context.Context) error

type Config struct {
	Logger           log.ContextualLogger
	FeatureRepo      repository.FeatureFlagRepo
	TargetRepo       repository.TargetRepo
	SegmentRepo      repository.SegmentRepo
	AuthRepo         repository.AuthRepo
	CacheHealthFn    CacheHealthFn
	EnvHealthFn      EnvHealthFn
	AuthFn           authTokenFn
	ClientService    clientService
	MetricService    metricService
	Offline          bool
	Hasher           hash.Hasher
	StreamingEnabled bool
	SDKClients       SDKClients
}

type EnvHealthFn func() []domain.EnvironmentHealth

type ProxyService interface {
	// Authenticate performs authentication
	Authenticate(ctx context.Context, req domain.AuthRequest) (domain.AuthResponse, error)

	// FeatureConfig gets all FeatureConfig for an environment
	FeatureConfig(ctx context.Context, req domain.FeatureConfigRequest) ([]domain.FeatureConfig, error)

	// FeatureConfigByIdentifier gets the feature config for a feature
	FeatureConfigByIdentifier(ctx context.Context, req domain.FeatureConfigByIdentifierRequest) (domain.FeatureConfig, error)

	// TargetSegments gets all of the TargetSegments in an environment
	TargetSegments(ctx context.Context, req domain.TargetSegmentsRequest) ([]domain.Segment, error)

	// TargetSegmentsByIdentifier get a TargetSegments from an environment by its identifier
	TargetSegmentsByIdentifier(ctx context.Context, req domain.TargetSegmentsByIdentifierRequest) (domain.Segment, error)

	// Evaluations gets all of the evaluations in an environment for a target
	Evaluations(ctx context.Context, req domain.EvaluationsRequest) ([]clientgen.Evaluation, error)

	// Evaluations gets all of the evaluations in an environment for a target for a particular feature
	EvaluationsByFeature(ctx context.Context, req domain.EvaluationsByFeatureRequest) (clientgen.Evaluation, error)

	// Stream returns the name of the GripChannel that the client should subscribe to
	Stream(ctx context.Context, req domain.StreamRequest) (domain.StreamResponse, error)

	// Metrics forwards metrics to the analytics service
	Metrics(ctx context.Context, req domain.MetricsRequest) error

	// Health checks the health of the system
	Health(ctx context.Context) (domain.HealthResponse, error)
}

type QueryStore struct {
	F func(identifier string) (rest.FeatureConfig, error)
	S func(identifier string) (rest.Segment, error)
	L func() ([]rest.FeatureConfig, error)
}

type SDKClients interface {
	StreamConnected(key string) bool
}

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