core

Documentation

Index

• func LoadConfig(configOptions *contracts_core.ConfigOptions) error
• func NewGRPCLogger() grpclog.DepthLoggerV2
• func NewUnaryServerInterceptorBuilder() coreContracts.IUnaryServerInterceptorBuilder
• func ValidateConfigPath(configPath string) error
• type Control
  • func NewControl(runtime *Runtime, port int) *Control
  • func (s *Control) Start()
  • func (s *Control) Stop()
• type Runtime
  • func NewRuntime() *Runtime
  • func (s *Runtime) GetServerInstances() []*ServerInstance
  • func (s *Runtime) Start()
  • func (s *Runtime) StartWithListenterAndPlugins(lis net.Listener, plugins []pluginContracts.IGRPCDotNetGoPlugin)
  • func (s *Runtime) Stop()
  • func (s *Runtime) Wait()
• type ServerInstance
• type UnaryServerInterceptorBuilder
  • func (s *UnaryServerInterceptorBuilder) GetUnaryServerInterceptors() []grpc.UnaryServerInterceptor
  • func (s *UnaryServerInterceptorBuilder) Use(interceptor grpc.UnaryServerInterceptor)

Functions

func LoadConfig

func LoadConfig(configOptions *contracts_core.ConfigOptions) error

func NewGRPCLogger

func NewGRPCLogger() grpclog.DepthLoggerV2

NewGRPCLogger Creates a new instance of a gRPC Logger interface that redirects to zerolog

func NewUnaryServerInterceptorBuilder

func NewUnaryServerInterceptorBuilder() coreContracts.IUnaryServerInterceptorBuilder

NewUnaryServerInterceptorBuilder helper

func ValidateConfigPath

func ValidateConfigPath(configPath string) error

ValidateConfigPath just makes sure, that the path provided is a file, that can be read

Types

type Control

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

Control is the control object that manages an echo web server

func NewControl

func NewControl(runtime *Runtime, port int) *Control

NewControl creates a new control object

func (*Control) Start

func (s *Control) Start()

Start starts the echo web server using async and futures

func (*Control) Stop

func (s *Control) Stop()

Stop ...

type Runtime

type Runtime struct {
	ServerInstances []*ServerInstance
	// contains filtered or unexported fields
}

Runtime type

func NewRuntime

func NewRuntime() *Runtime

NewRuntime returns an instance of a new Runtime

func (*Runtime) GetServerInstances

func (s *Runtime) GetServerInstances() []*ServerInstance

GetServerInstances gets the array or service instances

func (*Runtime) Start

func (s *Runtime) Start()

Start to be used in production

func (*Runtime) StartWithListenterAndPlugins

func (s *Runtime) StartWithListenterAndPlugins(lis net.Listener, plugins []pluginContracts.IGRPCDotNetGoPlugin)

StartWithListenterAndPlugins starts up the server

func (*Runtime) Stop

func (s *Runtime) Stop()

Stop ...

func (*Runtime) Wait

func (s *Runtime) Wait()

Wait for someone to call stop

type ServerInstance

type ServerInstance struct {
	StartupManifest contracts_core.StartupManifest
	Server          *grpc.Server
	Future          async.Future[interface{}]
	DotNetGoBuilder *grpcdotnetgo.DotNetGoBuilder
	Endpoints       []interface{}
}

ServerInstance represents an instance of a plugin

type UnaryServerInterceptorBuilder

type UnaryServerInterceptorBuilder struct {
	UnaryServerInterceptors []grpc.UnaryServerInterceptor
}

UnaryServerInterceptorBuilder struct

func (*UnaryServerInterceptorBuilder) GetUnaryServerInterceptors

func (s *UnaryServerInterceptorBuilder) GetUnaryServerInterceptors() []grpc.UnaryServerInterceptor

GetUnaryServerInterceptors helper

func (*UnaryServerInterceptorBuilder) Use

func (s *UnaryServerInterceptorBuilder) Use(interceptor grpc.UnaryServerInterceptor)

Use helper