serverpb

package
v0.0.0-...-64e9426 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package serverpb is a generated protocol buffer package.

It is generated from these files: 

admin.proto

It has these top-level messages: 

NodeRequest
NodeResponse
PoolRequest
PoolResponse
HealthRequest
HealthResponse
StatisticsRequest
StatisticsResponse
ShutdownRequest
ShutdownResponse
VersionRequest
VersionResponse

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterAdminServer 

func RegisterAdminServer(s *grpc.Server, srv AdminServer)

Types

type AdminClient 

type AdminClient interface {
	Nodes(ctx context.Context, in *NodeRequest, opts ...grpc.CallOption) (*NodeResponse, error)
	Pools(ctx context.Context, in *PoolRequest, opts ...grpc.CallOption) (*PoolResponse, error)
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
	Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (Admin_ShutdownClient, error)
	Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
}

func NewAdminClient 

func NewAdminClient(cc *grpc.ClientConn) AdminClient

type AdminServer 

type AdminServer interface {
	Nodes(context.Context, *NodeRequest) (*NodeResponse, error)
	Pools(context.Context, *PoolRequest) (*PoolResponse, error)
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error)
	Shutdown(*ShutdownRequest, Admin_ShutdownServer) error
	Version(context.Context, *VersionRequest) (*VersionResponse, error)
}

type Admin_ShutdownClient 

type Admin_ShutdownClient interface {
	Recv() (*ShutdownResponse, error)
	grpc.ClientStream
}

type Admin_ShutdownServer 

type Admin_ShutdownServer interface {
	Send(*ShutdownResponse) error
	grpc.ServerStream
}

type HealthRequest 

type HealthRequest struct {
}

func (*HealthRequest) Descriptor 

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

func (*HealthRequest) ProtoMessage 

func (*HealthRequest) ProtoMessage()

func (*HealthRequest) Reset 

func (m *HealthRequest) Reset()

func (*HealthRequest) String 

func (m *HealthRequest) String() string

type HealthResponse 

type HealthResponse struct {
	Health map[string]bool `` /* 133-byte string literal not displayed */
}

func (*HealthResponse) Descriptor 

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

func (*HealthResponse) GetHealth 

func (m *HealthResponse) GetHealth() map[string]bool

func (*HealthResponse) ProtoMessage 

func (*HealthResponse) ProtoMessage()

func (*HealthResponse) Reset 

func (m *HealthResponse) Reset()

func (*HealthResponse) String 

func (m *HealthResponse) String() string

type NodeRequest 

type NodeRequest struct {
}

NodeRequest requests a list of nodes.

func (*NodeRequest) Descriptor 

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

func (*NodeRequest) ProtoMessage 

func (*NodeRequest) ProtoMessage()

func (*NodeRequest) Reset 

func (m *NodeRequest) Reset()

func (*NodeRequest) String 

func (m *NodeRequest) String() string

type NodeResponse 

type NodeResponse struct {
	Nodes map[string]string `` /* 130-byte string literal not displayed */
}

NodeResponse contains a list of nodes.

func (*NodeResponse) Descriptor 

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

func (*NodeResponse) GetNodes 

func (m *NodeResponse) GetNodes() map[string]string

func (*NodeResponse) ProtoMessage 

func (*NodeResponse) ProtoMessage()

func (*NodeResponse) Reset 

func (m *NodeResponse) Reset()

func (*NodeResponse) String 

func (m *NodeResponse) String() string

type PoolRequest 

type PoolRequest struct {
}

PoolRequest requests a list of pools.

func (*PoolRequest) Descriptor 

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

func (*PoolRequest) ProtoMessage 

func (*PoolRequest) ProtoMessage()

func (*PoolRequest) Reset 

func (m *PoolRequest) Reset()

func (*PoolRequest) String 

func (m *PoolRequest) String() string

type PoolResponse 

type PoolResponse struct {
	Pools []string `protobuf:"bytes,1,rep,name=pools" json:"pools,omitempty"`
}

PoolResponse contains a list of pools.

func (*PoolResponse) Descriptor 

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

func (*PoolResponse) GetPools 

func (m *PoolResponse) GetPools() []string

func (*PoolResponse) ProtoMessage 

func (*PoolResponse) ProtoMessage()

func (*PoolResponse) Reset 

func (m *PoolResponse) Reset()

func (*PoolResponse) String 

func (m *PoolResponse) String() string

type ShutdownRequest 

type ShutdownRequest struct {
}

ShutdownRequest requests the server to shutdown.

func (*ShutdownRequest) Descriptor 

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

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) Reset 

func (m *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (m *ShutdownRequest) String() string

type ShutdownResponse 

type ShutdownResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
}

ShutdownResponse contains the the state of the proxy.

func (*ShutdownResponse) Descriptor 

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

func (*ShutdownResponse) GetSuccess 

func (m *ShutdownResponse) GetSuccess() bool

func (*ShutdownResponse) ProtoMessage 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) Reset 

func (m *ShutdownResponse) Reset()

func (*ShutdownResponse) String 

func (m *ShutdownResponse) String() string

type StatisticsRequest 

type StatisticsRequest struct {
}

func (*StatisticsRequest) Descriptor 

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

func (*StatisticsRequest) ProtoMessage 

func (*StatisticsRequest) ProtoMessage()

func (*StatisticsRequest) Reset 

func (m *StatisticsRequest) Reset()

func (*StatisticsRequest) String 

func (m *StatisticsRequest) String() string

type StatisticsResponse 

type StatisticsResponse struct {
	Queries map[string]int32 `` /* 135-byte string literal not displayed */
}

func (*StatisticsResponse) Descriptor 

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

func (*StatisticsResponse) GetQueries 

func (m *StatisticsResponse) GetQueries() map[string]int32

func (*StatisticsResponse) ProtoMessage 

func (*StatisticsResponse) ProtoMessage()

func (*StatisticsResponse) Reset 

func (m *StatisticsResponse) Reset()

func (*StatisticsResponse) String 

func (m *StatisticsResponse) String() string

type VersionRequest 

type VersionRequest struct {
}

func (*VersionRequest) Descriptor 

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

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) Reset 

func (m *VersionRequest) Reset()

func (*VersionRequest) String 

func (m *VersionRequest) String() string

type VersionResponse 

type VersionResponse struct {
	Version string `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
}

func (*VersionResponse) Descriptor 

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

func (*VersionResponse) GetVersion 

func (m *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) Reset 

func (m *VersionResponse) Reset()

func (*VersionResponse) String 

func (m *VersionResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.