core

Documentation

Index

• func LoadConfig(configOptions *coreContracts.ConfigOptions) error
• func NewUnaryServerInterceptorBuilder() coreContracts.IUnaryServerInterceptorBuilder
• func ValidateConfigPath(configPath string) error
• 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 *coreContracts.ConfigOptions) error

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 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 coreContracts.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