grpc

Documentation

Index

• Constants
• func NewGrpcServer(cfg *Config) (*grpc.Server, error)
• func ParseCAFile(caFile string) (*x509.CertPool, error)
• func SetupTLSConfig(cfg *Config) (*tls.Config, error)
• type Config
• type ConfigurationStream
• type StatemachineStream

Constants

const (
	DefaultTimeout = 200 * time.Millisecond
)

Functions

func NewGrpcServer

func NewGrpcServer(cfg *Config) (*grpc.Server, error)

NewGrpcServer creates a new gRPC cmd to handle incoming events and other API calls. The `Config` can be used to configure the backing store, a timeout and the logger.

func ParseCAFile

func ParseCAFile(caFile string) (*x509.CertPool, error)

func SetupTLSConfig

func SetupTLSConfig(cfg *Config) (*tls.Config, error)

TODO: move to its own grpc_tls.go file in this package.

Types

type Config

type Config struct {
	EventsChannel chan<- protos.EventRequest
	Store         storage.StoreManager
	Logger        *logging.Log
	Timeout       time.Duration
	ServerAddress string
	TlsEnabled    bool
	TlsCerts      string
	TlsMutual     bool
}

type ConfigurationStream

type ConfigurationStream = protos.StatemachineService_StreamAllConfigurationsServer

type StatemachineStream

type StatemachineStream = protos.StatemachineService_StreamAllInstateServer