grpc

package

v0.0.0-...-ad801e6 Latest Latest Go to latest Published: Apr 24, 2019 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/xichen2020/eventdb

Links

Open Source Insights

Documentation ¶

Index ¶

func NewServer(address string, svc servicepb.EventdbServer, opts *Options) xserver.Server
func NewService(db storage.Database, opts *ServiceOptions) servicepb.EventdbServer
type Options
- func NewOptions() *Options
type ServiceOptions
- func NewServiceOptions() *ServiceOptions

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewServer ¶

func NewServer(
	address string,
	svc servicepb.EventdbServer,
	opts *Options,
) xserver.Server

NewServer creates a new GRPC server.

func NewService ¶

func NewService(db storage.Database, opts *ServiceOptions) servicepb.EventdbServer

NewService creates a new service.

Types ¶

type Options ¶

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

Options provide a set of server options.

func NewOptions ¶

func NewOptions() *Options

NewOptions creates a new set of options.

func (*Options) InstrumentOptions ¶

func (o *Options) InstrumentOptions() instrument.Options

InstrumentOptions returns the instrument options.

func (*Options) KeepAlivePeriod ¶

func (o *Options) KeepAlivePeriod() time.Duration

KeepAlivePeriod returns the keep alive period.

func (*Options) MaxRecvMsgSize ¶

func (o *Options) MaxRecvMsgSize() int

MaxRecvMsgSize returns the max message size in bytes the server can receive.

func (*Options) ReadBufferSize ¶

func (o *Options) ReadBufferSize() int

ReadBufferSize returns the read buffer size. This determines how much data can be read at most for one read syscall.

func (*Options) SetInstrumentOptions ¶

func (o *Options) SetInstrumentOptions(v instrument.Options) *Options

SetInstrumentOptions sets the instrument options.

func (*Options) SetKeepAlivePeriod ¶

func (o *Options) SetKeepAlivePeriod(v time.Duration) *Options

SetKeepAlivePeriod sets the keep alive period.

func (*Options) SetMaxRecvMsgSize ¶

func (o *Options) SetMaxRecvMsgSize(v int) *Options

SetMaxRecvMsgSize sets the max message size in bytes the server can receive.

func (*Options) SetReadBufferSize ¶

func (o *Options) SetReadBufferSize(v int) *Options

SetReadBufferSize sets the read buffer size. This determines how much data can be read at most for one read syscall.

type ServiceOptions ¶

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

ServiceOptions provide a set of service options.

func NewServiceOptions ¶

func NewServiceOptions() *ServiceOptions

NewServiceOptions create a new set of service options.

func (*ServiceOptions) ClockOptions ¶

func (o *ServiceOptions) ClockOptions() clock.Options

ClockOptions returns the clock options.

func (*ServiceOptions) DocumentArrayPool ¶

func (o *ServiceOptions) DocumentArrayPool() *document.BucketizedDocumentArrayPool

DocumentArrayPool returns the document array pool.

func (*ServiceOptions) FieldArrayPool ¶

func (o *ServiceOptions) FieldArrayPool() *field.BucketizedFieldArrayPool

FieldArrayPool returns the field array pool.

func (*ServiceOptions) InstrumentOptions ¶

func (o *ServiceOptions) InstrumentOptions() instrument.Options

InstrumentOptions returns the instrument options.

func (*ServiceOptions) ReadTimeout ¶

func (o *ServiceOptions) ReadTimeout() time.Duration

ReadTimeout returns the read timeout.

func (*ServiceOptions) SetClockOptions ¶

func (o *ServiceOptions) SetClockOptions(v clock.Options) *ServiceOptions

SetClockOptions sets the clock options.

func (*ServiceOptions) SetDocumentArrayPool ¶

func (o *ServiceOptions) SetDocumentArrayPool(v *document.BucketizedDocumentArrayPool) *ServiceOptions

SetDocumentArrayPool sets the document array pool.

func (*ServiceOptions) SetFieldArrayPool ¶

func (o *ServiceOptions) SetFieldArrayPool(v *field.BucketizedFieldArrayPool) *ServiceOptions

SetFieldArrayPool sets the field array pool.

func (*ServiceOptions) SetInstrumentOptions ¶

func (o *ServiceOptions) SetInstrumentOptions(v instrument.Options) *ServiceOptions

SetInstrumentOptions sets the instrument options.

func (*ServiceOptions) SetReadTimeout ¶

func (o *ServiceOptions) SetReadTimeout(v time.Duration) *ServiceOptions

SetReadTimeout sets the read timeout.

func (*ServiceOptions) SetWriteTimeout ¶

func (o *ServiceOptions) SetWriteTimeout(v time.Duration) *ServiceOptions

SetWriteTimeout sets the write timeout.

func (*ServiceOptions) WriteTimeout ¶

func (o *ServiceOptions) WriteTimeout() time.Duration

WriteTimeout returns the write timeout.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL