grpc

Documentation

Index

• func RunServer(ctx context.Context, options ...Option) error
• type Option
  • func WithListen(listener net.Listener) Option
  • func WithListenAddress(listen string) Option
• type Options
  • func (o *Options) ApplyOptions(options []Option)
  • func (o *Options) InitWithDefaults()
• type Server
  • func (Server) Index(ctx context.Context, event *types.Event) (*types.IndexResonse, error)

Functions

func RunServer

func RunServer(ctx context.Context, options ...Option) error

RunServer runs the server and block the goroutine.

Types

type Option

type Option = func(option *Options)

And Option which can be applied to Options.

func WithListen

func WithListen(listener net.Listener) Option

WithListen allow to directly configure a net.Listen for the server.

func WithListenAddress

func WithListenAddress(listen string) Option

WithListenAddress the default listening address.

type Options

type Options struct {
	// Listen can be given to directly configure the port the grpc server is listening on.
	Listen net.Listener

	// ListenAddress can be used to configure a ListenAddress which is for the grpc server.
	// This will be ignored when Options.Listen is set.
	ListenAddress string
}

func (*Options) ApplyOptions

func (o *Options) ApplyOptions(options []Option)

ApplyOptions iterates over []Option and applies every single one of them.

func (*Options) InitWithDefaults

func (o *Options) InitWithDefaults()

InitDefaults initialises Options with default values for each setting.

type Server

type Server struct {
	types.UnimplementedStreamingServiceServer
}

func (Server) Index

func (Server) Index(ctx context.Context, event *types.Event) (*types.IndexResonse, error)