Documentation
¶
Overview ¶
Package server is a generated protocol buffer package.
It is generated from these files:
fake_server.proto
It has these top-level messages:
FailWithHTTPErrorRequest
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterFakeServerServer ¶
func RegisterFakeServerServer(s *grpc.Server, srv FakeServerServer)
func RegisterInstrumentation ¶
RegisterInstrumentation on the given router.
Types ¶
type Config ¶
type Config struct {
MetricsNamespace string `yaml:"-"`
HTTPListenAddress string `yaml:"http_listen_address"`
HTTPListenPort int `yaml:"http_listen_port"`
HTTPConnLimit int `yaml:"http_listen_conn_limit"`
GRPCListenAddress string `yaml:"grpc_listen_address"`
GRPCListenPort int `yaml:"grpc_listen_port"`
GRPCConnLimit int `yaml:"grpc_listen_conn_limit"`
RegisterInstrumentation bool `yaml:"register_instrumentation"`
ExcludeRequestInLog bool `yaml:"-"`
ServerGracefulShutdownTimeout time.Duration `yaml:"graceful_shutdown_timeout"`
HTTPServerReadTimeout time.Duration `yaml:"http_server_read_timeout"`
HTTPServerWriteTimeout time.Duration `yaml:"http_server_write_timeout"`
HTTPServerIdleTimeout time.Duration `yaml:"http_server_idle_timeout"`
GRPCOptions []grpc.ServerOption `yaml:"-"`
GRPCMiddleware []grpc.UnaryServerInterceptor `yaml:"-"`
GRPCStreamMiddleware []grpc.StreamServerInterceptor `yaml:"-"`
HTTPMiddleware []middleware.Interface `yaml:"-"`
GPRCServerMaxRecvMsgSize int `yaml:"grpc_server_max_recv_msg_size"`
GRPCServerMaxSendMsgSize int `yaml:"grpc_server_max_send_msg_size"`
GPRCServerMaxConcurrentStreams uint `yaml:"grpc_server_max_concurrent_streams"`
GRPCServerMaxConnectionIdle time.Duration `yaml:"grpc_server_max_connection_idle"`
GRPCServerMaxConnectionAge time.Duration `yaml:"grpc_server_max_connection_age"`
GRPCServerMaxConnectionAgeGrace time.Duration `yaml:"grpc_server_max_connection_age_grace"`
GRPCServerTime time.Duration `yaml:"grpc_server_keepalive_time"`
GRPCServerTimeout time.Duration `yaml:"grpc_server_keepalive_timeout"`
LogLevel logging.Level `yaml:"log_level"`
Log logging.Interface `yaml:"-"`
PathPrefix string `yaml:"http_path_prefix"`
}
Config for a Server
func (*Config) RegisterFlags ¶
RegisterFlags adds the flags required to config this to the given FlagSet
type FailWithHTTPErrorRequest ¶
type FailWithHTTPErrorRequest struct {
Code int32 `protobuf:"varint,1,opt,name=Code" json:"Code,omitempty"`
}
func (*FailWithHTTPErrorRequest) Descriptor ¶
func (*FailWithHTTPErrorRequest) Descriptor() ([]byte, []int)
func (*FailWithHTTPErrorRequest) GetCode ¶
func (m *FailWithHTTPErrorRequest) GetCode() int32
func (*FailWithHTTPErrorRequest) ProtoMessage ¶
func (*FailWithHTTPErrorRequest) ProtoMessage()
func (*FailWithHTTPErrorRequest) Reset ¶
func (m *FailWithHTTPErrorRequest) Reset()
func (*FailWithHTTPErrorRequest) String ¶
func (m *FailWithHTTPErrorRequest) String() string
type FakeServerClient ¶
type FakeServerClient interface {
Succeed(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
FailWithError(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
FailWithHTTPError(ctx context.Context, in *FailWithHTTPErrorRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
}
func NewFakeServerClient ¶
func NewFakeServerClient(cc *grpc.ClientConn) FakeServerClient
type FakeServerServer ¶
type FakeServerServer interface {
Succeed(context.Context, *google_protobuf.Empty) (*google_protobuf.Empty, error)
FailWithError(context.Context, *google_protobuf.Empty) (*google_protobuf.Empty, error)
FailWithHTTPError(context.Context, *FailWithHTTPErrorRequest) (*google_protobuf.Empty, error)
}
type Server ¶
type Server struct {
HTTP *mux.Router
HTTPServer *http.Server
GRPC *grpc.Server
Log logging.Interface
// contains filtered or unexported fields
}
Server wraps a HTTP and gRPC server, and some common initialization.
Servers will be automatically instrumented for Prometheus metrics.
Click to show internal directories.
Click to hide internal directories.