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 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

Jump to

Keyboard shortcuts

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