server

package

v0.8.0 Latest Latest Go to latest Published: Jan 23, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var (
	DefaultAddress = ":0"
	DefaultName    = "go.ebrick.server"
	DefaultVersion = "latest"
)

This section is empty.

type Config struct {
	Grpc GrpcServerConfig `yaml:"grpc"`
}

func GetConfig() (*Config, error)

GetConfig loads and returns the configuration

type GRPCOptions struct {
	MaxConcurrentStreams uint32
	Interceptor          grpc.UnaryServerInterceptor
}

GRPCOptions holds gRPC-specific configuration options.

type GRPCServer interface {
	Server
	// RegisterServices allows registration of gRPC services
	RegisterServices(registerFunc func(s *grpc.Server))
}

GRPCServer defines the interface for a gRPC server.

func NewGRPCServer(opts ...Option) GRPCServer

NewGRPCServer creates a new gRPC server with the given options.

type GrpcServerConfig struct {
	Address string `yaml:"address"`
}

type Option func(*Options)

func WithAddress(address string) Option

func WithInterceptor(interceptor grpc.UnaryServerInterceptor) Option

func WithMaxConcurrentStreams(maxStreams uint32) Option

func WithName(name string) Option

func WithVersion(version string) Option

type Options struct {
	Address     string
	Name        string
	Version     string
	GRPCOptions GRPCOptions
}

type Server interface {
	// Retrieve the options
	Options() Options
	// Start the server
	Start() error
	// Stop the server
	Stop() error
}

Server defines the interface for a server with methods to initialize, start, and stop the server, as well as retrieve its options.