grpcserver

Documentation

Index

• Constants
• Variables
• func ErrorLog(ctx context.Context, code codes.Code, err error) (grpcerr error)
• type Adapter
  • func New() *Adapter
  • func (a *Adapter) Attach()
  • func (a *Adapter) Detach()
  • func (a *Adapter) GetServer() *grpc.Server
  • func (a *Adapter) Initialize()
  • func (a *Adapter) Register() (string, interface{})
  • func (a *Adapter) ServerContext(ctx context.Context) (context.Context, error)
  • func (a *Adapter) Start()
• type Configuration
  • func (*Configuration) Descriptor() ([]byte, []int)
  • func (x *Configuration) GetCertificateFilePath() string
  • func (x *Configuration) GetEnableReflection() bool
  • func (x *Configuration) GetEnableTls() bool
  • func (x *Configuration) GetKeepaliveMaxConnectionIdleSeconds() int64
  • func (x *Configuration) GetKeepalivePingDelaySeconds() int64
  • func (x *Configuration) GetKeepalivePingTimeoutSeconds() int64
  • func (x *Configuration) GetListenAddress() string
  • func (x *Configuration) GetMaxConcurrentStreams() uint32
  • func (x *Configuration) GetMaxRecvMsgSize() int64
  • func (x *Configuration) GetPrivateKeyFilePath() string
  • func (*Configuration) ProtoMessage()
  • func (x *Configuration) ProtoReflect() protoreflect.Message
  • func (x *Configuration) Reset()
  • func (x *Configuration) String() string

Constants

const Key = "grpcServer"

const (
	StackTraceSize = 1 << 16
)

Variables

var (
	ErrGlitch = grpc.Errorf(codes.Internal, "internal glitch")
)

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

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