peer

package
v0.0.0-...-21e40fe Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ServerStatus_StatusCode_name = map[int32]string{
	0: "UNDEFINED",
	1: "STARTED",
	2: "STOPPED",
	3: "PAUSED",
	4: "ERROR",
	5: "UNKNOWN",
}
View Source 
var ServerStatus_StatusCode_value = map[string]int32{
	"UNDEFINED": 0,
	"STARTED":   1,
	"STOPPED":   2,
	"PAUSED":    3,
	"ERROR":     4,
	"UNKNOWN":   5,
}

Functions

func RegisterAdminServer 

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

Types

type AdminClient 

type AdminClient interface {
	GetStatus(ctx context.Context, in *common.Envelope, opts ...grpc.CallOption) (*ServerStatus, error)
	StartServer(ctx context.Context, in *common.Envelope, opts ...grpc.CallOption) (*ServerStatus, error)
	GetModuleLogLevel(ctx context.Context, in *common.Envelope, opts ...grpc.CallOption) (*LogLevelResponse, error)
	SetModuleLogLevel(ctx context.Context, in *common.Envelope, opts ...grpc.CallOption) (*LogLevelResponse, error)
	RevertLogLevels(ctx context.Context, in *common.Envelope, opts ...grpc.CallOption) (*empty.Empty, error)
}

func NewAdminClient 

func NewAdminClient(cc *grpc.ClientConn) AdminClient

type AdminOperation 

type AdminOperation struct {
	// Types that are valid to be assigned to Content:
	//	*AdminOperation_LogReq
	Content              isAdminOperation_Content `protobuf_oneof:"content"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*AdminOperation) Descriptor 

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

func (*AdminOperation) GetContent 

func (m *AdminOperation) GetContent() isAdminOperation_Content

func (*AdminOperation) GetLogReq 

func (m *AdminOperation) GetLogReq() *LogLevelRequest

func (*AdminOperation) ProtoMessage 

func (*AdminOperation) ProtoMessage()

func (*AdminOperation) Reset 

func (m *AdminOperation) Reset()

func (*AdminOperation) String 

func (m *AdminOperation) String() string

func (*AdminOperation) XXX_DiscardUnknown 

func (m *AdminOperation) XXX_DiscardUnknown()

func (*AdminOperation) XXX_Marshal 

func (m *AdminOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AdminOperation) XXX_Merge 

func (dst *AdminOperation) XXX_Merge(src proto.Message)

func (*AdminOperation) XXX_OneofFuncs 

func (*AdminOperation) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*AdminOperation) XXX_Size 

func (m *AdminOperation) XXX_Size() int

func (*AdminOperation) XXX_Unmarshal 

func (m *AdminOperation) XXX_Unmarshal(b []byte) error

type AdminOperation_LogReq 

type AdminOperation_LogReq struct {
	LogReq *LogLevelRequest `protobuf:"bytes,1,opt,name=logReq,oneof"`
}

type AdminServer 

type AdminServer interface {
	GetStatus(context.Context, *common.Envelope) (*ServerStatus, error)
	StartServer(context.Context, *common.Envelope) (*ServerStatus, error)
	GetModuleLogLevel(context.Context, *common.Envelope) (*LogLevelResponse, error)
	SetModuleLogLevel(context.Context, *common.Envelope) (*LogLevelResponse, error)
	RevertLogLevels(context.Context, *common.Envelope) (*empty.Empty, error)
}

type LogLevelRequest 

type LogLevelRequest struct {
	LogModule            string   `protobuf:"bytes,1,opt,name=log_module,json=logModule" json:"log_module,omitempty"`
	LogLevel             string   `protobuf:"bytes,2,opt,name=log_level,json=logLevel" json:"log_level,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogLevelRequest) Descriptor 

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

func (*LogLevelRequest) GetLogLevel 

func (m *LogLevelRequest) GetLogLevel() string

func (*LogLevelRequest) GetLogModule 

func (m *LogLevelRequest) GetLogModule() string

func (*LogLevelRequest) ProtoMessage 

func (*LogLevelRequest) ProtoMessage()

func (*LogLevelRequest) Reset 

func (m *LogLevelRequest) Reset()

func (*LogLevelRequest) String 

func (m *LogLevelRequest) String() string

func (*LogLevelRequest) XXX_DiscardUnknown 

func (m *LogLevelRequest) XXX_DiscardUnknown()

func (*LogLevelRequest) XXX_Marshal 

func (m *LogLevelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogLevelRequest) XXX_Merge 

func (dst *LogLevelRequest) XXX_Merge(src proto.Message)

func (*LogLevelRequest) XXX_Size 

func (m *LogLevelRequest) XXX_Size() int

func (*LogLevelRequest) XXX_Unmarshal 

func (m *LogLevelRequest) XXX_Unmarshal(b []byte) error

type LogLevelResponse 

type LogLevelResponse struct {
	LogModule            string   `protobuf:"bytes,1,opt,name=log_module,json=logModule" json:"log_module,omitempty"`
	LogLevel             string   `protobuf:"bytes,2,opt,name=log_level,json=logLevel" json:"log_level,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogLevelResponse) Descriptor 

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

func (*LogLevelResponse) GetLogLevel 

func (m *LogLevelResponse) GetLogLevel() string

func (*LogLevelResponse) GetLogModule 

func (m *LogLevelResponse) GetLogModule() string

func (*LogLevelResponse) ProtoMessage 

func (*LogLevelResponse) ProtoMessage()

func (*LogLevelResponse) Reset 

func (m *LogLevelResponse) Reset()

func (*LogLevelResponse) String 

func (m *LogLevelResponse) String() string

func (*LogLevelResponse) XXX_DiscardUnknown 

func (m *LogLevelResponse) XXX_DiscardUnknown()

func (*LogLevelResponse) XXX_Marshal 

func (m *LogLevelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogLevelResponse) XXX_Merge 

func (dst *LogLevelResponse) XXX_Merge(src proto.Message)

func (*LogLevelResponse) XXX_Size 

func (m *LogLevelResponse) XXX_Size() int

func (*LogLevelResponse) XXX_Unmarshal 

func (m *LogLevelResponse) XXX_Unmarshal(b []byte) error

type ServerStatus 

type ServerStatus struct {
	Status               ServerStatus_StatusCode `protobuf:"varint,1,opt,name=status,enum=protos.ServerStatus_StatusCode" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ServerStatus) Descriptor 

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

func (*ServerStatus) GetStatus 

func (m *ServerStatus) GetStatus() ServerStatus_StatusCode

func (*ServerStatus) ProtoMessage 

func (*ServerStatus) ProtoMessage()

func (*ServerStatus) Reset 

func (m *ServerStatus) Reset()

func (*ServerStatus) String 

func (m *ServerStatus) String() string

func (*ServerStatus) XXX_DiscardUnknown 

func (m *ServerStatus) XXX_DiscardUnknown()

func (*ServerStatus) XXX_Marshal 

func (m *ServerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerStatus) XXX_Merge 

func (dst *ServerStatus) XXX_Merge(src proto.Message)

func (*ServerStatus) XXX_Size 

func (m *ServerStatus) XXX_Size() int

func (*ServerStatus) XXX_Unmarshal 

func (m *ServerStatus) XXX_Unmarshal(b []byte) error

type ServerStatus_StatusCode 

type ServerStatus_StatusCode int32
const (
	ServerStatus_UNDEFINED ServerStatus_StatusCode = 0
	ServerStatus_STARTED   ServerStatus_StatusCode = 1
	ServerStatus_STOPPED   ServerStatus_StatusCode = 2
	ServerStatus_PAUSED    ServerStatus_StatusCode = 3
	ServerStatus_ERROR     ServerStatus_StatusCode = 4
	ServerStatus_UNKNOWN   ServerStatus_StatusCode = 5
)

func (ServerStatus_StatusCode) EnumDescriptor 

func (ServerStatus_StatusCode) EnumDescriptor() ([]byte, []int)

func (ServerStatus_StatusCode) String 

func (x ServerStatus_StatusCode) 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.