service

Documentation

Index

• type GRPCService
  • func (s *GRPCService) HandleEvaluationError(err error, reason string) error
  • func (s *GRPCService) ResolveBoolean(ctx context.Context, req *gen.ResolveBooleanRequest) (*gen.ResolveBooleanResponse, error)
  • func (s *GRPCService) ResolveFloat(ctx context.Context, req *gen.ResolveFloatRequest) (*gen.ResolveFloatResponse, error)
  • func (s *GRPCService) ResolveInt(ctx context.Context, req *gen.ResolveIntRequest) (*gen.ResolveIntResponse, error)
  • func (s *GRPCService) ResolveObject(ctx context.Context, req *gen.ResolveObjectRequest) (*gen.ResolveObjectResponse, error)
  • func (s *GRPCService) ResolveString(ctx context.Context, req *gen.ResolveStringRequest) (*gen.ResolveStringResponse, error)
  • func (s *GRPCService) Serve(ctx context.Context, eval eval.IEvaluator) error
• type GRPCServiceConfiguration
• type HTTPService
  • func (s HTTPService) HTTPErrorHandler(ctx context.Context, m *runtime.ServeMux, ma runtime.Marshaler, ...)
  • func (s *HTTPService) Serve(ctx context.Context, eval eval.IEvaluator) error
  • func (s *HTTPService) ServeHTTP(mux *runtime.ServeMux) *http.Server
  • func (s *HTTPService) ServerGRPC(mux *runtime.ServeMux) *grpc.Server
• type HTTPServiceConfiguration
• type IService
• type IServiceConfiguration

Types

type GRPCService

type GRPCService struct {
	GRPCServiceConfiguration *GRPCServiceConfiguration
	Eval                     eval.IEvaluator
	gen.UnimplementedServiceServer
	Logger *log.Entry
}

func (*GRPCService) HandleEvaluationError

func (s *GRPCService) HandleEvaluationError(err error, reason string) error

func (*GRPCService) ResolveBoolean

func (s *GRPCService) ResolveBoolean(
	ctx context.Context,
	req *gen.ResolveBooleanRequest,
) (*gen.ResolveBooleanResponse, error)

TODO: might be able to simplify some of this with generics.

func (*GRPCService) ResolveFloat

func (s *GRPCService) ResolveFloat(
	ctx context.Context,
	req *gen.ResolveFloatRequest,
) (*gen.ResolveFloatResponse, error)

func (*GRPCService) ResolveInt

func (s *GRPCService) ResolveInt(
	ctx context.Context,
	req *gen.ResolveIntRequest,
) (*gen.ResolveIntResponse, error)

func (*GRPCService) ResolveObject

func (s *GRPCService) ResolveObject(
	ctx context.Context,
	req *gen.ResolveObjectRequest,
) (*gen.ResolveObjectResponse, error)

func (*GRPCService) ResolveString

func (s *GRPCService) ResolveString(
	ctx context.Context,
	req *gen.ResolveStringRequest,
) (*gen.ResolveStringResponse, error)

func (*GRPCService) Serve

func (s *GRPCService) Serve(ctx context.Context, eval eval.IEvaluator) error

Serve allows for the use of GRPC only without HTTP, where as HTTP service enables both GRPC and HTTP

type GRPCServiceConfiguration

type GRPCServiceConfiguration struct {
	Port           int32
	ServerKeyPath  string
	ServerCertPath string
}

type HTTPService

type HTTPService struct {
	HTTPServiceConfiguration *HTTPServiceConfiguration
	GRPCService              *GRPCService
	Logger                   *log.Entry
}

func (HTTPService) HTTPErrorHandler

func (s HTTPService) HTTPErrorHandler(
	ctx context.Context,
	m *runtime.ServeMux,
	ma runtime.Marshaler,
	w http.ResponseWriter,
	r *http.Request,
	err error,
)

func (*HTTPService) Serve

func (s *HTTPService) Serve(ctx context.Context, eval eval.IEvaluator) error

func (*HTTPService) ServeHTTP

func (s *HTTPService) ServeHTTP(mux *runtime.ServeMux) *http.Server

func (*HTTPService) ServerGRPC

func (s *HTTPService) ServerGRPC(mux *runtime.ServeMux) *grpc.Server

type HTTPServiceConfiguration

type HTTPServiceConfiguration struct {
	Port           int32
	ServerCertPath string
	ServerKeyPath  string
}

type IService

type IService interface {
	Serve(ctx context.Context, eval eval.IEvaluator) error
}

IService implementations define handlers for a particular transport, which call the IEvaluator implementation.

type IServiceConfiguration

type IServiceConfiguration interface{}