Documentation ¶
Index ¶
- Variables
- type BasicAuth
- type ClientTLSConfig
- func (*ClientTLSConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ClientTLSConfig) GetCertFile() string
- func (x *ClientTLSConfig) GetServerName() string
- func (*ClientTLSConfig) ProtoMessage()
- func (x *ClientTLSConfig) ProtoReflect() protoreflect.Message
- func (x *ClientTLSConfig) Reset()
- func (x *ClientTLSConfig) String() string
- type Etcd
- func (*Etcd) Descriptor() ([]byte, []int)deprecated
- func (x *Etcd) GetAuth() *BasicAuth
- func (x *Etcd) GetConnectTimeout() *durationpb.Duration
- func (x *Etcd) GetEndpoints() []string
- func (x *Etcd) GetLoggerRef() string
- func (x *Etcd) GetName() string
- func (x *Etcd) GetNamespace() string
- func (x *Etcd) GetTls() *ClientTLSConfig
- func (x *Etcd) GetTtl() *durationpb.Duration
- func (*Etcd) ProtoMessage()
- func (x *Etcd) ProtoReflect() protoreflect.Message
- func (x *Etcd) Reset()
- func (x *Etcd) String() string
- type GRPC
- type GRPCClient
- func (*GRPCClient) Descriptor() ([]byte, []int)deprecated
- func (x *GRPCClient) GetBalancerName() string
- func (x *GRPCClient) GetDiscoveryRef() string
- func (x *GRPCClient) GetEnableLogging() bool
- func (x *GRPCClient) GetEnableMetrics() bool
- func (x *GRPCClient) GetEnableTracing() bool
- func (x *GRPCClient) GetEnabledHealthCheck() bool
- func (x *GRPCClient) GetGrpcOpts() *GRPCClientOptions
- func (x *GRPCClient) GetLoggerRef() string
- func (x *GRPCClient) GetName() string
- func (x *GRPCClient) GetTarget() string
- func (x *GRPCClient) GetTimeout() *durationpb.Duration
- func (x *GRPCClient) GetTls() *ClientTLSConfig
- func (*GRPCClient) ProtoMessage()
- func (x *GRPCClient) ProtoReflect() protoreflect.Message
- func (x *GRPCClient) Reset()
- func (x *GRPCClient) String() string
- type GRPCClientConnectParams
- func (*GRPCClientConnectParams) Descriptor() ([]byte, []int)deprecated
- func (x *GRPCClientConnectParams) GetBaseDelay() *durationpb.Duration
- func (x *GRPCClientConnectParams) GetJitter() float32
- func (x *GRPCClientConnectParams) GetMaxDelay() *durationpb.Duration
- func (x *GRPCClientConnectParams) GetMinConnectTimeout() *durationpb.Duration
- func (x *GRPCClientConnectParams) GetMultiplier() float32
- func (*GRPCClientConnectParams) ProtoMessage()
- func (x *GRPCClientConnectParams) ProtoReflect() protoreflect.Message
- func (x *GRPCClientConnectParams) Reset()
- func (x *GRPCClientConnectParams) String() string
- type GRPCClientKeepaliveParams
- func (*GRPCClientKeepaliveParams) Descriptor() ([]byte, []int)deprecated
- func (x *GRPCClientKeepaliveParams) GetPermitWithoutStream() bool
- func (x *GRPCClientKeepaliveParams) GetTime() *durationpb.Duration
- func (x *GRPCClientKeepaliveParams) GetTimeout() *durationpb.Duration
- func (*GRPCClientKeepaliveParams) ProtoMessage()
- func (x *GRPCClientKeepaliveParams) ProtoReflect() protoreflect.Message
- func (x *GRPCClientKeepaliveParams) Reset()
- func (x *GRPCClientKeepaliveParams) String() string
- type GRPCClientOptions
- func (*GRPCClientOptions) Descriptor() ([]byte, []int)deprecated
- func (x *GRPCClientOptions) GetAuthority() string
- func (x *GRPCClientOptions) GetBlock() bool
- func (x *GRPCClientOptions) GetConnectParams() *GRPCClientConnectParams
- func (x *GRPCClientOptions) GetDisableRetry() bool
- func (x *GRPCClientOptions) GetInitialConnWindowSize() int32
- func (x *GRPCClientOptions) GetInitialWindowSize() int32
- func (x *GRPCClientOptions) GetKeepaliveParams() *GRPCClientKeepaliveParams
- func (x *GRPCClientOptions) GetMaxHeaderListSize() uint32
- func (x *GRPCClientOptions) GetReadBufferSize() int64
- func (x *GRPCClientOptions) GetUserAgent() string
- func (x *GRPCClientOptions) GetWriteBufferSize() int64
- func (*GRPCClientOptions) ProtoMessage()
- func (x *GRPCClientOptions) ProtoReflect() protoreflect.Message
- func (x *GRPCClientOptions) Reset()
- func (x *GRPCClientOptions) String() string
- type GRPCServer
- func (*GRPCServer) Descriptor() ([]byte, []int)deprecated
- func (x *GRPCServer) GetAddr() string
- func (x *GRPCServer) GetEnableLogging() bool
- func (x *GRPCServer) GetEnableMetrics() bool
- func (x *GRPCServer) GetEnableTracing() bool
- func (x *GRPCServer) GetGrpcOpts() *GRPCServerOptions
- func (x *GRPCServer) GetLoggerRef() string
- func (x *GRPCServer) GetMetadata() map[string]string
- func (x *GRPCServer) GetName() string
- func (x *GRPCServer) GetNetwork() string
- func (x *GRPCServer) GetRegistrarRef() string
- func (x *GRPCServer) GetTimeout() *durationpb.Duration
- func (x *GRPCServer) GetTls() *ServerTLSConfig
- func (*GRPCServer) ProtoMessage()
- func (x *GRPCServer) ProtoReflect() protoreflect.Message
- func (x *GRPCServer) Reset()
- func (x *GRPCServer) String() string
- type GRPCServerKeepaliveParams
- func (*GRPCServerKeepaliveParams) Descriptor() ([]byte, []int)deprecated
- func (x *GRPCServerKeepaliveParams) GetMaxConnectionAge() *durationpb.Duration
- func (x *GRPCServerKeepaliveParams) GetMaxConnectionAgeGrace() *durationpb.Duration
- func (x *GRPCServerKeepaliveParams) GetMaxConnectionIdle() *durationpb.Duration
- func (x *GRPCServerKeepaliveParams) GetTime() *durationpb.Duration
- func (x *GRPCServerKeepaliveParams) GetTimeout() *durationpb.Duration
- func (*GRPCServerKeepaliveParams) ProtoMessage()
- func (x *GRPCServerKeepaliveParams) ProtoReflect() protoreflect.Message
- func (x *GRPCServerKeepaliveParams) Reset()
- func (x *GRPCServerKeepaliveParams) String() string
- type GRPCServerKeepalivePolicy
- func (*GRPCServerKeepalivePolicy) Descriptor() ([]byte, []int)deprecated
- func (x *GRPCServerKeepalivePolicy) GetMinTime() *durationpb.Duration
- func (x *GRPCServerKeepalivePolicy) GetPermitWithoutStream() bool
- func (*GRPCServerKeepalivePolicy) ProtoMessage()
- func (x *GRPCServerKeepalivePolicy) ProtoReflect() protoreflect.Message
- func (x *GRPCServerKeepalivePolicy) Reset()
- func (x *GRPCServerKeepalivePolicy) String() string
- type GRPCServerOptions
- func (*GRPCServerOptions) Descriptor() ([]byte, []int)deprecated
- func (x *GRPCServerOptions) GetConnectionTimeout() *durationpb.Duration
- func (x *GRPCServerOptions) GetInitialConnWindowSize() int32
- func (x *GRPCServerOptions) GetInitialWindowSize() int32
- func (x *GRPCServerOptions) GetKeepaliveParams() *GRPCServerKeepaliveParams
- func (x *GRPCServerOptions) GetKeepalivePolicy() *GRPCServerKeepalivePolicy
- func (x *GRPCServerOptions) GetMaxConcurrentStreams() uint32
- func (x *GRPCServerOptions) GetMaxHeaderListSize() uint32
- func (x *GRPCServerOptions) GetMaxReceiveMessageSize() int64
- func (x *GRPCServerOptions) GetMaxSendMessageSize() int64
- func (x *GRPCServerOptions) GetReadBufferSize() int64
- func (x *GRPCServerOptions) GetWriteBufferSize() int64
- func (*GRPCServerOptions) ProtoMessage()
- func (x *GRPCServerOptions) ProtoReflect() protoreflect.Message
- func (x *GRPCServerOptions) Reset()
- func (x *GRPCServerOptions) String() string
- type HTTP
- type Microservices
- func (*Microservices) Descriptor() ([]byte, []int)deprecated
- func (x *Microservices) GetGrpc() *GRPC
- func (x *Microservices) GetHttp() *HTTP
- func (x *Microservices) GetSd() *ServiceDiscovery
- func (*Microservices) ProtoMessage()
- func (x *Microservices) ProtoReflect() protoreflect.Message
- func (x *Microservices) Reset()
- func (x *Microservices) String() string
- type ServerTLSConfig
- func (*ServerTLSConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ServerTLSConfig) GetCertFile() string
- func (x *ServerTLSConfig) GetKeyFile() string
- func (*ServerTLSConfig) ProtoMessage()
- func (x *ServerTLSConfig) ProtoReflect() protoreflect.Message
- func (x *ServerTLSConfig) Reset()
- func (x *ServerTLSConfig) String() string
- type ServiceDiscovery
Constants ¶
This section is empty.
Variables ¶
var File_config_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BasicAuth ¶
type BasicAuth struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` // contains filtered or unexported fields }
func (*BasicAuth) Descriptor
deprecated
func (*BasicAuth) GetPassword ¶
func (*BasicAuth) GetUsername ¶
func (*BasicAuth) ProtoMessage ¶
func (*BasicAuth) ProtoMessage()
func (*BasicAuth) ProtoReflect ¶
func (x *BasicAuth) ProtoReflect() protoreflect.Message
type ClientTLSConfig ¶
type ClientTLSConfig struct { CertFile string `protobuf:"bytes,1,opt,name=cert_file,json=certFile,proto3" json:"cert_file,omitempty"` ServerName string `protobuf:"bytes,2,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"` // contains filtered or unexported fields }
func (*ClientTLSConfig) Descriptor
deprecated
func (*ClientTLSConfig) Descriptor() ([]byte, []int)
Deprecated: Use ClientTLSConfig.ProtoReflect.Descriptor instead.
func (*ClientTLSConfig) GetCertFile ¶
func (x *ClientTLSConfig) GetCertFile() string
func (*ClientTLSConfig) GetServerName ¶
func (x *ClientTLSConfig) GetServerName() string
func (*ClientTLSConfig) ProtoMessage ¶
func (*ClientTLSConfig) ProtoMessage()
func (*ClientTLSConfig) ProtoReflect ¶
func (x *ClientTLSConfig) ProtoReflect() protoreflect.Message
func (*ClientTLSConfig) Reset ¶
func (x *ClientTLSConfig) Reset()
func (*ClientTLSConfig) String ¶
func (x *ClientTLSConfig) String() string
type Etcd ¶
type Etcd struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Endpoints []string `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"` ConnectTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=connect_timeout,json=connectTimeout,proto3" json:"connect_timeout,omitempty"` Auth *BasicAuth `protobuf:"bytes,4,opt,name=auth,proto3" json:"auth,omitempty"` Namespace string `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"` Ttl *durationpb.Duration `protobuf:"bytes,6,opt,name=ttl,proto3" json:"ttl,omitempty"` Tls *ClientTLSConfig `protobuf:"bytes,7,opt,name=tls,proto3" json:"tls,omitempty"` LoggerRef string `protobuf:"bytes,8,opt,name=logger_ref,json=loggerRef,proto3" json:"logger_ref,omitempty"` // contains filtered or unexported fields }
func (*Etcd) Descriptor
deprecated
func (*Etcd) GetConnectTimeout ¶
func (x *Etcd) GetConnectTimeout() *durationpb.Duration
func (*Etcd) GetEndpoints ¶
func (*Etcd) GetLoggerRef ¶
func (*Etcd) GetNamespace ¶
func (*Etcd) GetTls ¶
func (x *Etcd) GetTls() *ClientTLSConfig
func (*Etcd) GetTtl ¶
func (x *Etcd) GetTtl() *durationpb.Duration
func (*Etcd) ProtoMessage ¶
func (*Etcd) ProtoMessage()
func (*Etcd) ProtoReflect ¶
func (x *Etcd) ProtoReflect() protoreflect.Message
type GRPC ¶
type GRPC struct { Servers []*GRPCServer `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"` Clients []*GRPCClient `protobuf:"bytes,2,rep,name=clients,proto3" json:"clients,omitempty"` // contains filtered or unexported fields }
func (*GRPC) Descriptor
deprecated
func (*GRPC) GetClients ¶
func (x *GRPC) GetClients() []*GRPCClient
func (*GRPC) GetServers ¶
func (x *GRPC) GetServers() []*GRPCServer
func (*GRPC) ProtoMessage ¶
func (*GRPC) ProtoMessage()
func (*GRPC) ProtoReflect ¶
func (x *GRPC) ProtoReflect() protoreflect.Message
type GRPCClient ¶
type GRPCClient struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` Timeout *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"` DiscoveryRef string `protobuf:"bytes,4,opt,name=discovery_ref,json=discoveryRef,proto3" json:"discovery_ref,omitempty"` BalancerName string `protobuf:"bytes,5,opt,name=balancer_name,json=balancerName,proto3" json:"balancer_name,omitempty"` EnabledHealthCheck bool `protobuf:"varint,6,opt,name=enabled_health_check,json=enabledHealthCheck,proto3" json:"enabled_health_check,omitempty"` LoggerRef string `protobuf:"bytes,7,opt,name=logger_ref,json=loggerRef,proto3" json:"logger_ref,omitempty"` EnableMetrics bool `protobuf:"varint,8,opt,name=enable_metrics,json=enableMetrics,proto3" json:"enable_metrics,omitempty"` EnableTracing bool `protobuf:"varint,9,opt,name=enable_tracing,json=enableTracing,proto3" json:"enable_tracing,omitempty"` EnableLogging bool `protobuf:"varint,10,opt,name=enable_logging,json=enableLogging,proto3" json:"enable_logging,omitempty"` Tls *ClientTLSConfig `protobuf:"bytes,11,opt,name=tls,proto3" json:"tls,omitempty"` GrpcOpts *GRPCClientOptions `protobuf:"bytes,12,opt,name=grpc_opts,json=grpcOpts,proto3" json:"grpc_opts,omitempty"` // contains filtered or unexported fields }
func (*GRPCClient) Descriptor
deprecated
func (*GRPCClient) Descriptor() ([]byte, []int)
Deprecated: Use GRPCClient.ProtoReflect.Descriptor instead.
func (*GRPCClient) GetBalancerName ¶
func (x *GRPCClient) GetBalancerName() string
func (*GRPCClient) GetDiscoveryRef ¶
func (x *GRPCClient) GetDiscoveryRef() string
func (*GRPCClient) GetEnableLogging ¶
func (x *GRPCClient) GetEnableLogging() bool
func (*GRPCClient) GetEnableMetrics ¶
func (x *GRPCClient) GetEnableMetrics() bool
func (*GRPCClient) GetEnableTracing ¶
func (x *GRPCClient) GetEnableTracing() bool
func (*GRPCClient) GetEnabledHealthCheck ¶
func (x *GRPCClient) GetEnabledHealthCheck() bool
func (*GRPCClient) GetGrpcOpts ¶
func (x *GRPCClient) GetGrpcOpts() *GRPCClientOptions
func (*GRPCClient) GetLoggerRef ¶
func (x *GRPCClient) GetLoggerRef() string
func (*GRPCClient) GetName ¶
func (x *GRPCClient) GetName() string
func (*GRPCClient) GetTarget ¶
func (x *GRPCClient) GetTarget() string
func (*GRPCClient) GetTimeout ¶
func (x *GRPCClient) GetTimeout() *durationpb.Duration
func (*GRPCClient) GetTls ¶
func (x *GRPCClient) GetTls() *ClientTLSConfig
func (*GRPCClient) ProtoMessage ¶
func (*GRPCClient) ProtoMessage()
func (*GRPCClient) ProtoReflect ¶
func (x *GRPCClient) ProtoReflect() protoreflect.Message
func (*GRPCClient) Reset ¶
func (x *GRPCClient) Reset()
func (*GRPCClient) String ¶
func (x *GRPCClient) String() string
type GRPCClientConnectParams ¶
type GRPCClientConnectParams struct { BaseDelay *durationpb.Duration `protobuf:"bytes,1,opt,name=base_delay,json=baseDelay,proto3" json:"base_delay,omitempty"` Multiplier float32 `protobuf:"fixed32,2,opt,name=multiplier,proto3" json:"multiplier,omitempty"` Jitter float32 `protobuf:"fixed32,3,opt,name=jitter,proto3" json:"jitter,omitempty"` MaxDelay *durationpb.Duration `protobuf:"bytes,4,opt,name=max_delay,json=maxDelay,proto3" json:"max_delay,omitempty"` MinConnectTimeout *durationpb.Duration `protobuf:"bytes,5,opt,name=min_connect_timeout,json=minConnectTimeout,proto3" json:"min_connect_timeout,omitempty"` // contains filtered or unexported fields }
func (*GRPCClientConnectParams) Descriptor
deprecated
func (*GRPCClientConnectParams) Descriptor() ([]byte, []int)
Deprecated: Use GRPCClientConnectParams.ProtoReflect.Descriptor instead.
func (*GRPCClientConnectParams) GetBaseDelay ¶
func (x *GRPCClientConnectParams) GetBaseDelay() *durationpb.Duration
func (*GRPCClientConnectParams) GetJitter ¶
func (x *GRPCClientConnectParams) GetJitter() float32
func (*GRPCClientConnectParams) GetMaxDelay ¶
func (x *GRPCClientConnectParams) GetMaxDelay() *durationpb.Duration
func (*GRPCClientConnectParams) GetMinConnectTimeout ¶
func (x *GRPCClientConnectParams) GetMinConnectTimeout() *durationpb.Duration
func (*GRPCClientConnectParams) GetMultiplier ¶
func (x *GRPCClientConnectParams) GetMultiplier() float32
func (*GRPCClientConnectParams) ProtoMessage ¶
func (*GRPCClientConnectParams) ProtoMessage()
func (*GRPCClientConnectParams) ProtoReflect ¶
func (x *GRPCClientConnectParams) ProtoReflect() protoreflect.Message
func (*GRPCClientConnectParams) Reset ¶
func (x *GRPCClientConnectParams) Reset()
func (*GRPCClientConnectParams) String ¶
func (x *GRPCClientConnectParams) String() string
type GRPCClientKeepaliveParams ¶
type GRPCClientKeepaliveParams struct { Time *durationpb.Duration `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"` Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"` PermitWithoutStream bool `protobuf:"varint,3,opt,name=permit_without_stream,json=permitWithoutStream,proto3" json:"permit_without_stream,omitempty"` // contains filtered or unexported fields }
func (*GRPCClientKeepaliveParams) Descriptor
deprecated
func (*GRPCClientKeepaliveParams) Descriptor() ([]byte, []int)
Deprecated: Use GRPCClientKeepaliveParams.ProtoReflect.Descriptor instead.
func (*GRPCClientKeepaliveParams) GetPermitWithoutStream ¶
func (x *GRPCClientKeepaliveParams) GetPermitWithoutStream() bool
func (*GRPCClientKeepaliveParams) GetTime ¶
func (x *GRPCClientKeepaliveParams) GetTime() *durationpb.Duration
func (*GRPCClientKeepaliveParams) GetTimeout ¶
func (x *GRPCClientKeepaliveParams) GetTimeout() *durationpb.Duration
func (*GRPCClientKeepaliveParams) ProtoMessage ¶
func (*GRPCClientKeepaliveParams) ProtoMessage()
func (*GRPCClientKeepaliveParams) ProtoReflect ¶
func (x *GRPCClientKeepaliveParams) ProtoReflect() protoreflect.Message
func (*GRPCClientKeepaliveParams) Reset ¶
func (x *GRPCClientKeepaliveParams) Reset()
func (*GRPCClientKeepaliveParams) String ¶
func (x *GRPCClientKeepaliveParams) String() string
type GRPCClientOptions ¶
type GRPCClientOptions struct { Block bool `protobuf:"varint,1,opt,name=block,proto3" json:"block,omitempty"` Authority string `protobuf:"bytes,2,opt,name=authority,proto3" json:"authority,omitempty"` UserAgent string `protobuf:"bytes,3,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"` ConnectParams *GRPCClientConnectParams `protobuf:"bytes,4,opt,name=connect_params,json=connectParams,proto3" json:"connect_params,omitempty"` KeepaliveParams *GRPCClientKeepaliveParams `protobuf:"bytes,5,opt,name=keepalive_params,json=keepaliveParams,proto3" json:"keepalive_params,omitempty"` InitialWindowSize int32 `protobuf:"varint,6,opt,name=initial_window_size,json=initialWindowSize,proto3" json:"initial_window_size,omitempty"` InitialConnWindowSize int32 `` /* 129-byte string literal not displayed */ WriteBufferSize int64 `protobuf:"varint,8,opt,name=write_buffer_size,json=writeBufferSize,proto3" json:"write_buffer_size,omitempty"` ReadBufferSize int64 `protobuf:"varint,9,opt,name=read_buffer_size,json=readBufferSize,proto3" json:"read_buffer_size,omitempty"` MaxHeaderListSize uint32 `protobuf:"varint,10,opt,name=max_header_list_size,json=maxHeaderListSize,proto3" json:"max_header_list_size,omitempty"` DisableRetry bool `protobuf:"varint,11,opt,name=disable_retry,json=disableRetry,proto3" json:"disable_retry,omitempty"` // contains filtered or unexported fields }
func (*GRPCClientOptions) Descriptor
deprecated
func (*GRPCClientOptions) Descriptor() ([]byte, []int)
Deprecated: Use GRPCClientOptions.ProtoReflect.Descriptor instead.
func (*GRPCClientOptions) GetAuthority ¶
func (x *GRPCClientOptions) GetAuthority() string
func (*GRPCClientOptions) GetBlock ¶
func (x *GRPCClientOptions) GetBlock() bool
func (*GRPCClientOptions) GetConnectParams ¶
func (x *GRPCClientOptions) GetConnectParams() *GRPCClientConnectParams
func (*GRPCClientOptions) GetDisableRetry ¶
func (x *GRPCClientOptions) GetDisableRetry() bool
func (*GRPCClientOptions) GetInitialConnWindowSize ¶
func (x *GRPCClientOptions) GetInitialConnWindowSize() int32
func (*GRPCClientOptions) GetInitialWindowSize ¶
func (x *GRPCClientOptions) GetInitialWindowSize() int32
func (*GRPCClientOptions) GetKeepaliveParams ¶
func (x *GRPCClientOptions) GetKeepaliveParams() *GRPCClientKeepaliveParams
func (*GRPCClientOptions) GetMaxHeaderListSize ¶
func (x *GRPCClientOptions) GetMaxHeaderListSize() uint32
func (*GRPCClientOptions) GetReadBufferSize ¶
func (x *GRPCClientOptions) GetReadBufferSize() int64
func (*GRPCClientOptions) GetUserAgent ¶
func (x *GRPCClientOptions) GetUserAgent() string
func (*GRPCClientOptions) GetWriteBufferSize ¶
func (x *GRPCClientOptions) GetWriteBufferSize() int64
func (*GRPCClientOptions) ProtoMessage ¶
func (*GRPCClientOptions) ProtoMessage()
func (*GRPCClientOptions) ProtoReflect ¶
func (x *GRPCClientOptions) ProtoReflect() protoreflect.Message
func (*GRPCClientOptions) Reset ¶
func (x *GRPCClientOptions) Reset()
func (*GRPCClientOptions) String ¶
func (x *GRPCClientOptions) String() string
type GRPCServer ¶
type GRPCServer struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Network string `protobuf:"bytes,2,opt,name=network,proto3" json:"network,omitempty"` Addr string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"` Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"` RegistrarRef string `protobuf:"bytes,5,opt,name=registrar_ref,json=registrarRef,proto3" json:"registrar_ref,omitempty"` LoggerRef string `protobuf:"bytes,6,opt,name=logger_ref,json=loggerRef,proto3" json:"logger_ref,omitempty"` EnableMetrics bool `protobuf:"varint,7,opt,name=enable_metrics,json=enableMetrics,proto3" json:"enable_metrics,omitempty"` EnableTracing bool `protobuf:"varint,8,opt,name=enable_tracing,json=enableTracing,proto3" json:"enable_tracing,omitempty"` EnableLogging bool `protobuf:"varint,9,opt,name=enable_logging,json=enableLogging,proto3" json:"enable_logging,omitempty"` Tls *ServerTLSConfig `protobuf:"bytes,10,opt,name=tls,proto3" json:"tls,omitempty"` GrpcOpts *GRPCServerOptions `protobuf:"bytes,11,opt,name=grpc_opts,json=grpcOpts,proto3" json:"grpc_opts,omitempty"` Metadata map[string]string `` /* 158-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GRPCServer) Descriptor
deprecated
func (*GRPCServer) Descriptor() ([]byte, []int)
Deprecated: Use GRPCServer.ProtoReflect.Descriptor instead.
func (*GRPCServer) GetAddr ¶
func (x *GRPCServer) GetAddr() string
func (*GRPCServer) GetEnableLogging ¶
func (x *GRPCServer) GetEnableLogging() bool
func (*GRPCServer) GetEnableMetrics ¶
func (x *GRPCServer) GetEnableMetrics() bool
func (*GRPCServer) GetEnableTracing ¶
func (x *GRPCServer) GetEnableTracing() bool
func (*GRPCServer) GetGrpcOpts ¶
func (x *GRPCServer) GetGrpcOpts() *GRPCServerOptions
func (*GRPCServer) GetLoggerRef ¶
func (x *GRPCServer) GetLoggerRef() string
func (*GRPCServer) GetMetadata ¶
func (x *GRPCServer) GetMetadata() map[string]string
func (*GRPCServer) GetName ¶
func (x *GRPCServer) GetName() string
func (*GRPCServer) GetNetwork ¶
func (x *GRPCServer) GetNetwork() string
func (*GRPCServer) GetRegistrarRef ¶
func (x *GRPCServer) GetRegistrarRef() string
func (*GRPCServer) GetTimeout ¶
func (x *GRPCServer) GetTimeout() *durationpb.Duration
func (*GRPCServer) GetTls ¶
func (x *GRPCServer) GetTls() *ServerTLSConfig
func (*GRPCServer) ProtoMessage ¶
func (*GRPCServer) ProtoMessage()
func (*GRPCServer) ProtoReflect ¶
func (x *GRPCServer) ProtoReflect() protoreflect.Message
func (*GRPCServer) Reset ¶
func (x *GRPCServer) Reset()
func (*GRPCServer) String ¶
func (x *GRPCServer) String() string
type GRPCServerKeepaliveParams ¶
type GRPCServerKeepaliveParams struct { MaxConnectionIdle *durationpb.Duration `protobuf:"bytes,1,opt,name=max_connection_idle,json=maxConnectionIdle,proto3" json:"max_connection_idle,omitempty"` MaxConnectionAge *durationpb.Duration `protobuf:"bytes,2,opt,name=max_connection_age,json=maxConnectionAge,proto3" json:"max_connection_age,omitempty"` MaxConnectionAgeGrace *durationpb.Duration `` /* 128-byte string literal not displayed */ Time *durationpb.Duration `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"` Timeout *durationpb.Duration `protobuf:"bytes,5,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
func (*GRPCServerKeepaliveParams) Descriptor
deprecated
func (*GRPCServerKeepaliveParams) Descriptor() ([]byte, []int)
Deprecated: Use GRPCServerKeepaliveParams.ProtoReflect.Descriptor instead.
func (*GRPCServerKeepaliveParams) GetMaxConnectionAge ¶
func (x *GRPCServerKeepaliveParams) GetMaxConnectionAge() *durationpb.Duration
func (*GRPCServerKeepaliveParams) GetMaxConnectionAgeGrace ¶
func (x *GRPCServerKeepaliveParams) GetMaxConnectionAgeGrace() *durationpb.Duration
func (*GRPCServerKeepaliveParams) GetMaxConnectionIdle ¶
func (x *GRPCServerKeepaliveParams) GetMaxConnectionIdle() *durationpb.Duration
func (*GRPCServerKeepaliveParams) GetTime ¶
func (x *GRPCServerKeepaliveParams) GetTime() *durationpb.Duration
func (*GRPCServerKeepaliveParams) GetTimeout ¶
func (x *GRPCServerKeepaliveParams) GetTimeout() *durationpb.Duration
func (*GRPCServerKeepaliveParams) ProtoMessage ¶
func (*GRPCServerKeepaliveParams) ProtoMessage()
func (*GRPCServerKeepaliveParams) ProtoReflect ¶
func (x *GRPCServerKeepaliveParams) ProtoReflect() protoreflect.Message
func (*GRPCServerKeepaliveParams) Reset ¶
func (x *GRPCServerKeepaliveParams) Reset()
func (*GRPCServerKeepaliveParams) String ¶
func (x *GRPCServerKeepaliveParams) String() string
type GRPCServerKeepalivePolicy ¶
type GRPCServerKeepalivePolicy struct { MinTime *durationpb.Duration `protobuf:"bytes,1,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"` PermitWithoutStream bool `protobuf:"varint,2,opt,name=permit_without_stream,json=permitWithoutStream,proto3" json:"permit_without_stream,omitempty"` // contains filtered or unexported fields }
func (*GRPCServerKeepalivePolicy) Descriptor
deprecated
func (*GRPCServerKeepalivePolicy) Descriptor() ([]byte, []int)
Deprecated: Use GRPCServerKeepalivePolicy.ProtoReflect.Descriptor instead.
func (*GRPCServerKeepalivePolicy) GetMinTime ¶
func (x *GRPCServerKeepalivePolicy) GetMinTime() *durationpb.Duration
func (*GRPCServerKeepalivePolicy) GetPermitWithoutStream ¶
func (x *GRPCServerKeepalivePolicy) GetPermitWithoutStream() bool
func (*GRPCServerKeepalivePolicy) ProtoMessage ¶
func (*GRPCServerKeepalivePolicy) ProtoMessage()
func (*GRPCServerKeepalivePolicy) ProtoReflect ¶
func (x *GRPCServerKeepalivePolicy) ProtoReflect() protoreflect.Message
func (*GRPCServerKeepalivePolicy) Reset ¶
func (x *GRPCServerKeepalivePolicy) Reset()
func (*GRPCServerKeepalivePolicy) String ¶
func (x *GRPCServerKeepalivePolicy) String() string
type GRPCServerOptions ¶
type GRPCServerOptions struct { MaxConcurrentStreams uint32 `protobuf:"varint,1,opt,name=max_concurrent_streams,json=maxConcurrentStreams,proto3" json:"max_concurrent_streams,omitempty"` MaxReceiveMessageSize int64 `` /* 129-byte string literal not displayed */ MaxSendMessageSize int64 `protobuf:"varint,3,opt,name=max_send_message_size,json=maxSendMessageSize,proto3" json:"max_send_message_size,omitempty"` KeepaliveParams *GRPCServerKeepaliveParams `protobuf:"bytes,4,opt,name=keepalive_params,json=keepaliveParams,proto3" json:"keepalive_params,omitempty"` KeepalivePolicy *GRPCServerKeepalivePolicy `protobuf:"bytes,5,opt,name=keepalive_policy,json=keepalivePolicy,proto3" json:"keepalive_policy,omitempty"` InitialWindowSize int32 `protobuf:"varint,6,opt,name=initial_window_size,json=initialWindowSize,proto3" json:"initial_window_size,omitempty"` InitialConnWindowSize int32 `` /* 129-byte string literal not displayed */ WriteBufferSize int64 `protobuf:"varint,8,opt,name=write_buffer_size,json=writeBufferSize,proto3" json:"write_buffer_size,omitempty"` ReadBufferSize int64 `protobuf:"varint,9,opt,name=read_buffer_size,json=readBufferSize,proto3" json:"read_buffer_size,omitempty"` ConnectionTimeout *durationpb.Duration `protobuf:"bytes,10,opt,name=connection_timeout,json=connectionTimeout,proto3" json:"connection_timeout,omitempty"` MaxHeaderListSize uint32 `protobuf:"varint,11,opt,name=max_header_list_size,json=maxHeaderListSize,proto3" json:"max_header_list_size,omitempty"` // contains filtered or unexported fields }
func (*GRPCServerOptions) Descriptor
deprecated
func (*GRPCServerOptions) Descriptor() ([]byte, []int)
Deprecated: Use GRPCServerOptions.ProtoReflect.Descriptor instead.
func (*GRPCServerOptions) GetConnectionTimeout ¶
func (x *GRPCServerOptions) GetConnectionTimeout() *durationpb.Duration
func (*GRPCServerOptions) GetInitialConnWindowSize ¶
func (x *GRPCServerOptions) GetInitialConnWindowSize() int32
func (*GRPCServerOptions) GetInitialWindowSize ¶
func (x *GRPCServerOptions) GetInitialWindowSize() int32
func (*GRPCServerOptions) GetKeepaliveParams ¶
func (x *GRPCServerOptions) GetKeepaliveParams() *GRPCServerKeepaliveParams
func (*GRPCServerOptions) GetKeepalivePolicy ¶
func (x *GRPCServerOptions) GetKeepalivePolicy() *GRPCServerKeepalivePolicy
func (*GRPCServerOptions) GetMaxConcurrentStreams ¶
func (x *GRPCServerOptions) GetMaxConcurrentStreams() uint32
func (*GRPCServerOptions) GetMaxHeaderListSize ¶
func (x *GRPCServerOptions) GetMaxHeaderListSize() uint32
func (*GRPCServerOptions) GetMaxReceiveMessageSize ¶
func (x *GRPCServerOptions) GetMaxReceiveMessageSize() int64
func (*GRPCServerOptions) GetMaxSendMessageSize ¶
func (x *GRPCServerOptions) GetMaxSendMessageSize() int64
func (*GRPCServerOptions) GetReadBufferSize ¶
func (x *GRPCServerOptions) GetReadBufferSize() int64
func (*GRPCServerOptions) GetWriteBufferSize ¶
func (x *GRPCServerOptions) GetWriteBufferSize() int64
func (*GRPCServerOptions) ProtoMessage ¶
func (*GRPCServerOptions) ProtoMessage()
func (*GRPCServerOptions) ProtoReflect ¶
func (x *GRPCServerOptions) ProtoReflect() protoreflect.Message
func (*GRPCServerOptions) Reset ¶
func (x *GRPCServerOptions) Reset()
func (*GRPCServerOptions) String ¶
func (x *GRPCServerOptions) String() string
type HTTP ¶
type HTTP struct {
// contains filtered or unexported fields
}
func (*HTTP) Descriptor
deprecated
func (*HTTP) ProtoMessage ¶
func (*HTTP) ProtoMessage()
func (*HTTP) ProtoReflect ¶
func (x *HTTP) ProtoReflect() protoreflect.Message
type Microservices ¶
type Microservices struct { Http *HTTP `protobuf:"bytes,1,opt,name=http,proto3" json:"http,omitempty"` Grpc *GRPC `protobuf:"bytes,2,opt,name=grpc,proto3" json:"grpc,omitempty"` Sd *ServiceDiscovery `protobuf:"bytes,9,opt,name=sd,proto3" json:"sd,omitempty"` // contains filtered or unexported fields }
func (*Microservices) Descriptor
deprecated
func (*Microservices) Descriptor() ([]byte, []int)
Deprecated: Use Microservices.ProtoReflect.Descriptor instead.
func (*Microservices) GetGrpc ¶
func (x *Microservices) GetGrpc() *GRPC
func (*Microservices) GetHttp ¶
func (x *Microservices) GetHttp() *HTTP
func (*Microservices) GetSd ¶
func (x *Microservices) GetSd() *ServiceDiscovery
func (*Microservices) ProtoMessage ¶
func (*Microservices) ProtoMessage()
func (*Microservices) ProtoReflect ¶
func (x *Microservices) ProtoReflect() protoreflect.Message
func (*Microservices) Reset ¶
func (x *Microservices) Reset()
func (*Microservices) String ¶
func (x *Microservices) String() string
type ServerTLSConfig ¶
type ServerTLSConfig struct { CertFile string `protobuf:"bytes,1,opt,name=cert_file,json=certFile,proto3" json:"cert_file,omitempty"` KeyFile string `protobuf:"bytes,2,opt,name=key_file,json=keyFile,proto3" json:"key_file,omitempty"` // contains filtered or unexported fields }
func (*ServerTLSConfig) Descriptor
deprecated
func (*ServerTLSConfig) Descriptor() ([]byte, []int)
Deprecated: Use ServerTLSConfig.ProtoReflect.Descriptor instead.
func (*ServerTLSConfig) GetCertFile ¶
func (x *ServerTLSConfig) GetCertFile() string
func (*ServerTLSConfig) GetKeyFile ¶
func (x *ServerTLSConfig) GetKeyFile() string
func (*ServerTLSConfig) ProtoMessage ¶
func (*ServerTLSConfig) ProtoMessage()
func (*ServerTLSConfig) ProtoReflect ¶
func (x *ServerTLSConfig) ProtoReflect() protoreflect.Message
func (*ServerTLSConfig) Reset ¶
func (x *ServerTLSConfig) Reset()
func (*ServerTLSConfig) String ¶
func (x *ServerTLSConfig) String() string
type ServiceDiscovery ¶
type ServiceDiscovery struct { Etcds []*Etcd `protobuf:"bytes,1,rep,name=etcds,proto3" json:"etcds,omitempty"` // contains filtered or unexported fields }
func (*ServiceDiscovery) Descriptor
deprecated
func (*ServiceDiscovery) Descriptor() ([]byte, []int)
Deprecated: Use ServiceDiscovery.ProtoReflect.Descriptor instead.
func (*ServiceDiscovery) GetEtcds ¶
func (x *ServiceDiscovery) GetEtcds() []*Etcd
func (*ServiceDiscovery) ProtoMessage ¶
func (*ServiceDiscovery) ProtoMessage()
func (*ServiceDiscovery) ProtoReflect ¶
func (x *ServiceDiscovery) ProtoReflect() protoreflect.Message
func (*ServiceDiscovery) Reset ¶
func (x *ServiceDiscovery) Reset()
func (*ServiceDiscovery) String ¶
func (x *ServiceDiscovery) String() string