grpcserver

package
v0.0.0-...-367b6cc Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 24, 2020 License: MPL-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const Key = "grpcServer"
View Source
const (
	StackTraceSize = 1 << 16
)

Variables

View Source
var (
	ErrGlitch = grpc.Errorf(codes.Internal, "internal glitch")
)
View Source
var File_adapters_grpc_server_grpc_server_proto protoreflect.FileDescriptor

Functions

func ErrorLog

func ErrorLog(ctx context.Context, code codes.Code, err error) (grpcerr error)

Types

type Adapter

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

func New

func New() *Adapter

func (*Adapter) Attach

func (a *Adapter) Attach()

func (*Adapter) Detach

func (a *Adapter) Detach()

func (*Adapter) GetServer

func (a *Adapter) GetServer() *grpc.Server

func (*Adapter) Initialize

func (a *Adapter) Initialize()

func (*Adapter) Register

func (a *Adapter) Register() (string, interface{})

func (*Adapter) ServerContext

func (a *Adapter) ServerContext(ctx context.Context) (context.Context, error)

func (*Adapter) Start

func (a *Adapter) Start()

type Configuration

type Configuration struct {
	CertificateFilePath               string `protobuf:"bytes,1,opt,name=certificate_file_path,json=certificateFilePath,proto3" json:"certificate_file_path,omitempty"`
	PrivateKeyFilePath                string `protobuf:"bytes,2,opt,name=private_key_file_path,json=privateKeyFilePath,proto3" json:"private_key_file_path,omitempty"`
	MaxRecvMsgSize                    int64  `protobuf:"varint,3,opt,name=max_recv_msg_size,json=maxRecvMsgSize,proto3" json:"max_recv_msg_size,omitempty"`
	MaxConcurrentStreams              uint32 `protobuf:"varint,4,opt,name=max_concurrent_streams,json=maxConcurrentStreams,proto3" json:"max_concurrent_streams,omitempty"`
	KeepaliveMaxConnectionIdleSeconds int64  `` /* 167-byte string literal not displayed */
	KeepalivePingDelaySeconds         int64  `` /* 141-byte string literal not displayed */
	KeepalivePingTimeoutSeconds       int64  `` /* 147-byte string literal not displayed */
	ListenAddress                     string `protobuf:"bytes,8,opt,name=listen_address,json=listenAddress,proto3" json:"listen_address,omitempty"`
	EnableTls                         bool   `protobuf:"varint,9,opt,name=enable_tls,json=enableTls,proto3" json:"enable_tls,omitempty"`
	EnableReflection                  bool   `protobuf:"varint,10,opt,name=enable_reflection,json=enableReflection,proto3" json:"enable_reflection,omitempty"`
	// contains filtered or unexported fields
}

func (*Configuration) Descriptor deprecated

func (*Configuration) Descriptor() ([]byte, []int)

Deprecated: Use Configuration.ProtoReflect.Descriptor instead.

func (*Configuration) GetCertificateFilePath

func (x *Configuration) GetCertificateFilePath() string

func (*Configuration) GetEnableReflection

func (x *Configuration) GetEnableReflection() bool

func (*Configuration) GetEnableTls

func (x *Configuration) GetEnableTls() bool

func (*Configuration) GetKeepaliveMaxConnectionIdleSeconds

func (x *Configuration) GetKeepaliveMaxConnectionIdleSeconds() int64

func (*Configuration) GetKeepalivePingDelaySeconds

func (x *Configuration) GetKeepalivePingDelaySeconds() int64

func (*Configuration) GetKeepalivePingTimeoutSeconds

func (x *Configuration) GetKeepalivePingTimeoutSeconds() int64

func (*Configuration) GetListenAddress

func (x *Configuration) GetListenAddress() string

func (*Configuration) GetMaxConcurrentStreams

func (x *Configuration) GetMaxConcurrentStreams() uint32

func (*Configuration) GetMaxRecvMsgSize

func (x *Configuration) GetMaxRecvMsgSize() int64

func (*Configuration) GetPrivateKeyFilePath

func (x *Configuration) GetPrivateKeyFilePath() string

func (*Configuration) ProtoMessage

func (*Configuration) ProtoMessage()

func (*Configuration) ProtoReflect

func (x *Configuration) ProtoReflect() protoreflect.Message

func (*Configuration) Reset

func (x *Configuration) Reset()

func (*Configuration) String

func (x *Configuration) String() string

Jump to

Keyboard shortcuts

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