admin

package
v0.11.0-alpha.30 Latest Latest
Warning

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

 Go to latest Published: Oct 4, 2023 License: Apache-2.0 Imports: 10 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DebugOperation_name = map[int32]string{
	0: "DEBUGSERVER",
	1: "STACKTRACE",
}
View Source 
var DebugOperation_value = map[string]int32{
	"DEBUGSERVER": 0,
	"STACKTRACE":  1,
}
View Source 
var Operation_name = map[int32]string{
	0: "BACKUP",
	1: "RESTORE",
}
View Source 
var Operation_value = map[string]int32{
	"BACKUP":  0,
	"RESTORE": 1,
}
View Source 
var ValidationOperation_name = map[int32]string{
	0: "VALIDATE",
}
View Source 
var ValidationOperation_value = map[string]int32{
	"VALIDATE": 0,
}
View Source 
var VerboseLevel_name = map[int32]string{
	0: "Min_Level",
	9: "Max_Level",
}
View Source 
var VerboseLevel_value = map[string]int32{
	"Min_Level": 0,
	"Max_Level": 9,
}

Functions

func RegisterDebugAgentServer added in v0.10.13 

func RegisterDebugAgentServer(s *grpc.Server, srv DebugAgentServer)

func RegisterHealthAgentServer 

func RegisterHealthAgentServer(s *grpc.Server, srv HealthAgentServer)

func RegisterLogAgentServer 

func RegisterLogAgentServer(s *grpc.Server, srv LogAgentServer)

func RegisterRecoveryAgentServer 

func RegisterRecoveryAgentServer(s *grpc.Server, srv RecoveryAgentServer)

func RegisterValidationAgentServer added in v0.10.27 

func RegisterValidationAgentServer(s *grpc.Server, srv ValidationAgentServer)

func RegisterVersionAgentServer added in v0.10.21 

func RegisterVersionAgentServer(s *grpc.Server, srv VersionAgentServer)

Types

type AgentInfoResponse 

type AgentInfoResponse struct {
	Node                 *common.NodeInfo    `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	DeploymentId         string              `protobuf:"bytes,4,opt,name=deploymentId,proto3" json:"deploymentId,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*AgentInfoResponse) Descriptor 

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

func (*AgentInfoResponse) GetDeploymentId added in v0.10.30 

func (m *AgentInfoResponse) GetDeploymentId() string

func (*AgentInfoResponse) GetError 

func (m *AgentInfoResponse) GetError() string

func (*AgentInfoResponse) GetNode 

func (m *AgentInfoResponse) GetNode() *common.NodeInfo

func (*AgentInfoResponse) GetResult 

func (m *AgentInfoResponse) GetResult() *wrappers.BoolValue

func (*AgentInfoResponse) ProtoMessage 

func (*AgentInfoResponse) ProtoMessage()

func (*AgentInfoResponse) Reset 

func (m *AgentInfoResponse) Reset()

func (*AgentInfoResponse) String 

func (m *AgentInfoResponse) String() string

func (*AgentInfoResponse) XXX_DiscardUnknown 

func (m *AgentInfoResponse) XXX_DiscardUnknown()

func (*AgentInfoResponse) XXX_Marshal 

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

func (*AgentInfoResponse) XXX_Merge 

func (m *AgentInfoResponse) XXX_Merge(src proto.Message)

func (*AgentInfoResponse) XXX_Size 

func (m *AgentInfoResponse) XXX_Size() int

func (*AgentInfoResponse) XXX_Unmarshal 

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

type DebugAgentClient added in v0.10.13 

type DebugAgentClient interface {
	Invoke(ctx context.Context, in *DebugRequest, opts ...grpc.CallOption) (*DebugResponse, error)
}

DebugAgentClient is the client API for DebugAgent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDebugAgentClient added in v0.10.13 

func NewDebugAgentClient(cc *grpc.ClientConn) DebugAgentClient

type DebugAgentServer added in v0.10.13 

type DebugAgentServer interface {
	Invoke(context.Context, *DebugRequest) (*DebugResponse, error)
}

DebugAgentServer is the server API for DebugAgent service.

type DebugOperation added in v0.10.13 

type DebugOperation int32
const (
	DebugOperation_DEBUGSERVER DebugOperation = 0
	DebugOperation_STACKTRACE  DebugOperation = 1
)

func (DebugOperation) EnumDescriptor added in v0.10.13 

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

func (DebugOperation) String added in v0.10.13 

func (x DebugOperation) String() string

type DebugRequest added in v0.10.13 

type DebugRequest struct {
	// Operation Type
	OBSOLETE_OperationType DebugOperation `` // Deprecated: Do not use.
	/* 162-byte string literal not displayed */
	// Artibraty data
	Data                 string                         `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"`
	OperationType        common.ProviderAccessOperation `protobuf:"varint,3,opt,name=OperationType,proto3,enum=moc.ProviderAccessOperation" json:"OperationType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*DebugRequest) Descriptor added in v0.10.13 

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

func (*DebugRequest) GetData added in v0.10.13 

func (m *DebugRequest) GetData() string

func (*DebugRequest) GetOBSOLETE_OperationType deprecated added in v0.10.27 

func (m *DebugRequest) GetOBSOLETE_OperationType() DebugOperation

Deprecated: Do not use.

func (*DebugRequest) GetOperationType added in v0.10.13 

func (m *DebugRequest) GetOperationType() common.ProviderAccessOperation

func (*DebugRequest) ProtoMessage added in v0.10.13 

func (*DebugRequest) ProtoMessage()

func (*DebugRequest) Reset added in v0.10.13 

func (m *DebugRequest) Reset()

func (*DebugRequest) String added in v0.10.13 

func (m *DebugRequest) String() string

func (*DebugRequest) XXX_DiscardUnknown added in v0.10.13 

func (m *DebugRequest) XXX_DiscardUnknown()

func (*DebugRequest) XXX_Marshal added in v0.10.13 

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

func (*DebugRequest) XXX_Merge added in v0.10.13 

func (m *DebugRequest) XXX_Merge(src proto.Message)

func (*DebugRequest) XXX_Size added in v0.10.13 

func (m *DebugRequest) XXX_Size() int

func (*DebugRequest) XXX_Unmarshal added in v0.10.13 

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

type DebugResponse added in v0.10.13 

type DebugResponse struct {
	Result               string   `protobuf:"bytes,1,opt,name=Result,proto3" json:"Result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DebugResponse) Descriptor added in v0.10.13 

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

func (*DebugResponse) GetResult added in v0.10.13 

func (m *DebugResponse) GetResult() string

func (*DebugResponse) ProtoMessage added in v0.10.13 

func (*DebugResponse) ProtoMessage()

func (*DebugResponse) Reset added in v0.10.13 

func (m *DebugResponse) Reset()

func (*DebugResponse) String added in v0.10.13 

func (m *DebugResponse) String() string

func (*DebugResponse) XXX_DiscardUnknown added in v0.10.13 

func (m *DebugResponse) XXX_DiscardUnknown()

func (*DebugResponse) XXX_Marshal added in v0.10.13 

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

func (*DebugResponse) XXX_Merge added in v0.10.13 

func (m *DebugResponse) XXX_Merge(src proto.Message)

func (*DebugResponse) XXX_Size added in v0.10.13 

func (m *DebugResponse) XXX_Size() int

func (*DebugResponse) XXX_Unmarshal added in v0.10.13 

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

type GetRequest added in v0.10.29 

type GetRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRequest) Descriptor added in v0.10.29 

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

func (*GetRequest) ProtoMessage added in v0.10.29 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset added in v0.10.29 

func (m *GetRequest) Reset()

func (*GetRequest) String added in v0.10.29 

func (m *GetRequest) String() string

func (*GetRequest) XXX_DiscardUnknown added in v0.10.29 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal added in v0.10.29 

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

func (*GetRequest) XXX_Merge added in v0.10.29 

func (m *GetRequest) XXX_Merge(src proto.Message)

func (*GetRequest) XXX_Size added in v0.10.29 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal added in v0.10.29 

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

type GetResponse added in v0.10.29 

type GetResponse struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Level                string   `protobuf:"bytes,2,opt,name=level,proto3" json:"level,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetResponse) Descriptor added in v0.10.29 

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

func (*GetResponse) GetError added in v0.10.29 

func (m *GetResponse) GetError() string

func (*GetResponse) GetLevel added in v0.10.29 

func (m *GetResponse) GetLevel() string

func (*GetResponse) ProtoMessage added in v0.10.29 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset added in v0.10.29 

func (m *GetResponse) Reset()

func (*GetResponse) String added in v0.10.29 

func (m *GetResponse) String() string

func (*GetResponse) XXX_DiscardUnknown added in v0.10.29 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal added in v0.10.29 

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

func (*GetResponse) XXX_Merge added in v0.10.29 

func (m *GetResponse) XXX_Merge(src proto.Message)

func (*GetResponse) XXX_Size added in v0.10.29 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal added in v0.10.29 

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

type HealthAgentClient 

type HealthAgentClient interface {
	CheckHealth(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
	GetAgentInfo(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*AgentInfoResponse, error)
}

HealthAgentClient is the client API for HealthAgent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewHealthAgentClient 

func NewHealthAgentClient(cc *grpc.ClientConn) HealthAgentClient

type HealthAgentServer 

type HealthAgentServer interface {
	CheckHealth(context.Context, *HealthRequest) (*HealthResponse, error)
	GetAgentInfo(context.Context, *empty.Empty) (*AgentInfoResponse, error)
}

HealthAgentServer is the server API for HealthAgent service.

type HealthRequest 

type HealthRequest struct {
	TimeoutSeconds       uint32   `protobuf:"varint,1,opt,name=timeoutSeconds,proto3" json:"timeoutSeconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HealthRequest) Descriptor 

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

func (*HealthRequest) GetTimeoutSeconds 

func (m *HealthRequest) GetTimeoutSeconds() uint32

func (*HealthRequest) ProtoMessage 

func (*HealthRequest) ProtoMessage()

func (*HealthRequest) Reset 

func (m *HealthRequest) Reset()

func (*HealthRequest) String 

func (m *HealthRequest) String() string

func (*HealthRequest) XXX_DiscardUnknown 

func (m *HealthRequest) XXX_DiscardUnknown()

func (*HealthRequest) XXX_Marshal 

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

func (*HealthRequest) XXX_Merge 

func (m *HealthRequest) XXX_Merge(src proto.Message)

func (*HealthRequest) XXX_Size 

func (m *HealthRequest) XXX_Size() int

func (*HealthRequest) XXX_Unmarshal 

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

type HealthResponse 

type HealthResponse struct {
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	State                common.HealthState  `protobuf:"varint,4,opt,name=State,proto3,enum=moc.HealthState" json:"State,omitempty"`
	Rebooted             bool                `protobuf:"varint,5,opt,name=Rebooted,proto3" json:"Rebooted,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*HealthResponse) Descriptor 

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

func (*HealthResponse) GetError 

func (m *HealthResponse) GetError() string

func (*HealthResponse) GetRebooted 

func (m *HealthResponse) GetRebooted() bool

func (*HealthResponse) GetResult 

func (m *HealthResponse) GetResult() *wrappers.BoolValue

func (*HealthResponse) GetState 

func (m *HealthResponse) GetState() common.HealthState

func (*HealthResponse) ProtoMessage 

func (*HealthResponse) ProtoMessage()

func (*HealthResponse) Reset 

func (m *HealthResponse) Reset()

func (*HealthResponse) String 

func (m *HealthResponse) String() string

func (*HealthResponse) XXX_DiscardUnknown 

func (m *HealthResponse) XXX_DiscardUnknown()

func (*HealthResponse) XXX_Marshal 

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

func (*HealthResponse) XXX_Merge 

func (m *HealthResponse) XXX_Merge(src proto.Message)

func (*HealthResponse) XXX_Size 

func (m *HealthResponse) XXX_Size() int

func (*HealthResponse) XXX_Unmarshal 

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

type LogAgentClient 

type LogAgentClient interface {
	Get(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (LogAgent_GetClient, error)
	Rotate(ctx context.Context, in *LogRotateRequest, opts ...grpc.CallOption) (*LogRotateResponse, error)
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	GetLevel(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
}

LogAgentClient is the client API for LogAgent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLogAgentClient 

func NewLogAgentClient(cc *grpc.ClientConn) LogAgentClient

type LogAgentServer 

type LogAgentServer interface {
	Get(*LogRequest, LogAgent_GetServer) error
	Rotate(context.Context, *LogRotateRequest) (*LogRotateResponse, error)
	Set(context.Context, *SetRequest) (*SetResponse, error)
	GetLevel(context.Context, *GetRequest) (*GetResponse, error)
}

LogAgentServer is the server API for LogAgent service.

type LogAgent_GetClient 

type LogAgent_GetClient interface {
	Recv() (*LogFileResponse, error)
	grpc.ClientStream
}

type LogAgent_GetServer 

type LogAgent_GetServer interface {
	Send(*LogFileResponse) error
	grpc.ServerStream
}

type LogFileResponse 

type LogFileResponse struct {
	File                 []byte              `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	Done                 *wrappers.BoolValue `protobuf:"bytes,2,opt,name=done,proto3" json:"done,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*LogFileResponse) Descriptor 

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

func (*LogFileResponse) GetDone 

func (m *LogFileResponse) GetDone() *wrappers.BoolValue

func (*LogFileResponse) GetError 

func (m *LogFileResponse) GetError() string

func (*LogFileResponse) GetFile 

func (m *LogFileResponse) GetFile() []byte

func (*LogFileResponse) ProtoMessage 

func (*LogFileResponse) ProtoMessage()

func (*LogFileResponse) Reset 

func (m *LogFileResponse) Reset()

func (*LogFileResponse) String 

func (m *LogFileResponse) String() string

func (*LogFileResponse) XXX_DiscardUnknown 

func (m *LogFileResponse) XXX_DiscardUnknown()

func (*LogFileResponse) XXX_Marshal 

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

func (*LogFileResponse) XXX_Merge 

func (m *LogFileResponse) XXX_Merge(src proto.Message)

func (*LogFileResponse) XXX_Size 

func (m *LogFileResponse) XXX_Size() int

func (*LogFileResponse) XXX_Unmarshal 

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

type LogRequest 

type LogRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogRequest) Descriptor 

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

func (*LogRequest) ProtoMessage 

func (*LogRequest) ProtoMessage()

func (*LogRequest) Reset 

func (m *LogRequest) Reset()

func (*LogRequest) String 

func (m *LogRequest) String() string

func (*LogRequest) XXX_DiscardUnknown 

func (m *LogRequest) XXX_DiscardUnknown()

func (*LogRequest) XXX_Marshal 

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

func (*LogRequest) XXX_Merge 

func (m *LogRequest) XXX_Merge(src proto.Message)

func (*LogRequest) XXX_Size 

func (m *LogRequest) XXX_Size() int

func (*LogRequest) XXX_Unmarshal 

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

type LogRotateRequest 

type LogRotateRequest struct {
	LogRotation          *LogRotation `protobuf:"bytes,1,opt,name=logRotation,proto3" json:"logRotation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*LogRotateRequest) Descriptor 

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

func (*LogRotateRequest) GetLogRotation 

func (m *LogRotateRequest) GetLogRotation() *LogRotation

func (*LogRotateRequest) ProtoMessage 

func (*LogRotateRequest) ProtoMessage()

func (*LogRotateRequest) Reset 

func (m *LogRotateRequest) Reset()

func (*LogRotateRequest) String 

func (m *LogRotateRequest) String() string

func (*LogRotateRequest) XXX_DiscardUnknown 

func (m *LogRotateRequest) XXX_DiscardUnknown()

func (*LogRotateRequest) XXX_Marshal 

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

func (*LogRotateRequest) XXX_Merge 

func (m *LogRotateRequest) XXX_Merge(src proto.Message)

func (*LogRotateRequest) XXX_Size 

func (m *LogRotateRequest) XXX_Size() int

func (*LogRotateRequest) XXX_Unmarshal 

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

type LogRotateResponse 

type LogRotateResponse struct {
	Result               bool     `protobuf:"varint,1,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogRotateResponse) Descriptor 

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

func (*LogRotateResponse) GetError 

func (m *LogRotateResponse) GetError() string

func (*LogRotateResponse) GetResult 

func (m *LogRotateResponse) GetResult() bool

func (*LogRotateResponse) ProtoMessage 

func (*LogRotateResponse) ProtoMessage()

func (*LogRotateResponse) Reset 

func (m *LogRotateResponse) Reset()

func (*LogRotateResponse) String 

func (m *LogRotateResponse) String() string

func (*LogRotateResponse) XXX_DiscardUnknown 

func (m *LogRotateResponse) XXX_DiscardUnknown()

func (*LogRotateResponse) XXX_Marshal 

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

func (*LogRotateResponse) XXX_Merge 

func (m *LogRotateResponse) XXX_Merge(src proto.Message)

func (*LogRotateResponse) XXX_Size 

func (m *LogRotateResponse) XXX_Size() int

func (*LogRotateResponse) XXX_Unmarshal 

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

type LogRotation 

type LogRotation struct {
	Minutes              int32    `protobuf:"varint,1,opt,name=minutes,proto3" json:"minutes,omitempty"`
	Size                 int32    `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	EnableTime           bool     `protobuf:"varint,3,opt,name=enableTime,proto3" json:"enableTime,omitempty"`
	EnableSize           bool     `protobuf:"varint,4,opt,name=enableSize,proto3" json:"enableSize,omitempty"`
	DisableTime          bool     `protobuf:"varint,5,opt,name=disableTime,proto3" json:"disableTime,omitempty"`
	DisableSize          bool     `protobuf:"varint,6,opt,name=disableSize,proto3" json:"disableSize,omitempty"`
	Limit                int32    `protobuf:"varint,7,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogRotation) Descriptor 

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

func (*LogRotation) GetDisableSize 

func (m *LogRotation) GetDisableSize() bool

func (*LogRotation) GetDisableTime 

func (m *LogRotation) GetDisableTime() bool

func (*LogRotation) GetEnableSize 

func (m *LogRotation) GetEnableSize() bool

func (*LogRotation) GetEnableTime 

func (m *LogRotation) GetEnableTime() bool

func (*LogRotation) GetLimit 

func (m *LogRotation) GetLimit() int32

func (*LogRotation) GetMinutes 

func (m *LogRotation) GetMinutes() int32

func (*LogRotation) GetSize 

func (m *LogRotation) GetSize() int32

func (*LogRotation) ProtoMessage 

func (*LogRotation) ProtoMessage()

func (*LogRotation) Reset 

func (m *LogRotation) Reset()

func (*LogRotation) String 

func (m *LogRotation) String() string

func (*LogRotation) XXX_DiscardUnknown 

func (m *LogRotation) XXX_DiscardUnknown()

func (*LogRotation) XXX_Marshal 

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

func (*LogRotation) XXX_Merge 

func (m *LogRotation) XXX_Merge(src proto.Message)

func (*LogRotation) XXX_Size 

func (m *LogRotation) XXX_Size() int

func (*LogRotation) XXX_Unmarshal 

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

type Operation 

type Operation int32
const (
	Operation_BACKUP  Operation = 0
	Operation_RESTORE Operation = 1
)

func (Operation) EnumDescriptor 

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

func (Operation) String 

func (x Operation) String() string

type RecoveryAgentClient 

type RecoveryAgentClient interface {
	Invoke(ctx context.Context, in *RecoveryRequest, opts ...grpc.CallOption) (*RecoveryResponse, error)
}

RecoveryAgentClient is the client API for RecoveryAgent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRecoveryAgentClient 

func NewRecoveryAgentClient(cc *grpc.ClientConn) RecoveryAgentClient

type RecoveryAgentServer 

type RecoveryAgentServer interface {
	Invoke(context.Context, *RecoveryRequest) (*RecoveryResponse, error)
}

RecoveryAgentServer is the server API for RecoveryAgent service.

type RecoveryRequest 

type RecoveryRequest struct {
	OperationType Operation `protobuf:"varint,1,opt,name=OperationType,proto3,enum=moc.common.admin.Operation" json:"OperationType,omitempty"`
	// Path to back to or restore from. Can be a relative path for registry
	Path string `protobuf:"bytes,2,opt,name=Path,proto3" json:"Path,omitempty"`
	// Config file path. Must be on hard disk.
	ConfigFilePath string `protobuf:"bytes,3,opt,name=ConfigFilePath,proto3" json:"ConfigFilePath,omitempty"`
	// Type of data store
	StoreType            string   `protobuf:"bytes,4,opt,name=StoreType,proto3" json:"StoreType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RecoveryRequest) Descriptor 

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

func (*RecoveryRequest) GetConfigFilePath 

func (m *RecoveryRequest) GetConfigFilePath() string

func (*RecoveryRequest) GetOperationType 

func (m *RecoveryRequest) GetOperationType() Operation

func (*RecoveryRequest) GetPath 

func (m *RecoveryRequest) GetPath() string

func (*RecoveryRequest) GetStoreType 

func (m *RecoveryRequest) GetStoreType() string

func (*RecoveryRequest) ProtoMessage 

func (*RecoveryRequest) ProtoMessage()

func (*RecoveryRequest) Reset 

func (m *RecoveryRequest) Reset()

func (*RecoveryRequest) String 

func (m *RecoveryRequest) String() string

func (*RecoveryRequest) XXX_DiscardUnknown 

func (m *RecoveryRequest) XXX_DiscardUnknown()

func (*RecoveryRequest) XXX_Marshal 

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

func (*RecoveryRequest) XXX_Merge 

func (m *RecoveryRequest) XXX_Merge(src proto.Message)

func (*RecoveryRequest) XXX_Size 

func (m *RecoveryRequest) XXX_Size() int

func (*RecoveryRequest) XXX_Unmarshal 

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

type RecoveryResponse 

type RecoveryResponse struct {
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*RecoveryResponse) Descriptor 

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

func (*RecoveryResponse) GetError 

func (m *RecoveryResponse) GetError() string

func (*RecoveryResponse) GetResult 

func (m *RecoveryResponse) GetResult() *wrappers.BoolValue

func (*RecoveryResponse) ProtoMessage 

func (*RecoveryResponse) ProtoMessage()

func (*RecoveryResponse) Reset 

func (m *RecoveryResponse) Reset()

func (*RecoveryResponse) String 

func (m *RecoveryResponse) String() string

func (*RecoveryResponse) XXX_DiscardUnknown 

func (m *RecoveryResponse) XXX_DiscardUnknown()

func (*RecoveryResponse) XXX_Marshal 

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

func (*RecoveryResponse) XXX_Merge 

func (m *RecoveryResponse) XXX_Merge(src proto.Message)

func (*RecoveryResponse) XXX_Size 

func (m *RecoveryResponse) XXX_Size() int

func (*RecoveryResponse) XXX_Unmarshal 

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

type SetRequest added in v0.10.29 

type SetRequest struct {
	Verbositylevel       int32    `protobuf:"varint,1,opt,name=verbositylevel,proto3" json:"verbositylevel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetRequest) Descriptor added in v0.10.29 

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

func (*SetRequest) GetVerbositylevel added in v0.10.29 

func (m *SetRequest) GetVerbositylevel() int32

func (*SetRequest) ProtoMessage added in v0.10.29 

func (*SetRequest) ProtoMessage()

func (*SetRequest) Reset added in v0.10.29 

func (m *SetRequest) Reset()

func (*SetRequest) String added in v0.10.29 

func (m *SetRequest) String() string

func (*SetRequest) XXX_DiscardUnknown added in v0.10.29 

func (m *SetRequest) XXX_DiscardUnknown()

func (*SetRequest) XXX_Marshal added in v0.10.29 

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

func (*SetRequest) XXX_Merge added in v0.10.29 

func (m *SetRequest) XXX_Merge(src proto.Message)

func (*SetRequest) XXX_Size added in v0.10.29 

func (m *SetRequest) XXX_Size() int

func (*SetRequest) XXX_Unmarshal added in v0.10.29 

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

type SetResponse added in v0.10.29 

type SetResponse struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetResponse) Descriptor added in v0.10.29 

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

func (*SetResponse) GetError added in v0.10.29 

func (m *SetResponse) GetError() string

func (*SetResponse) ProtoMessage added in v0.10.29 

func (*SetResponse) ProtoMessage()

func (*SetResponse) Reset added in v0.10.29 

func (m *SetResponse) Reset()

func (*SetResponse) String added in v0.10.29 

func (m *SetResponse) String() string

func (*SetResponse) XXX_DiscardUnknown added in v0.10.29 

func (m *SetResponse) XXX_DiscardUnknown()

func (*SetResponse) XXX_Marshal added in v0.10.29 

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

func (*SetResponse) XXX_Merge added in v0.10.29 

func (m *SetResponse) XXX_Merge(src proto.Message)

func (*SetResponse) XXX_Size added in v0.10.29 

func (m *SetResponse) XXX_Size() int

func (*SetResponse) XXX_Unmarshal added in v0.10.29 

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

type UnimplementedDebugAgentServer added in v0.10.13 

type UnimplementedDebugAgentServer struct {
}

UnimplementedDebugAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedDebugAgentServer) Invoke added in v0.10.13 

func (*UnimplementedDebugAgentServer) Invoke(ctx context.Context, req *DebugRequest) (*DebugResponse, error)

type UnimplementedHealthAgentServer 

type UnimplementedHealthAgentServer struct {
}

UnimplementedHealthAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedHealthAgentServer) CheckHealth 

func (*UnimplementedHealthAgentServer) CheckHealth(ctx context.Context, req *HealthRequest) (*HealthResponse, error)

func (*UnimplementedHealthAgentServer) GetAgentInfo 

func (*UnimplementedHealthAgentServer) GetAgentInfo(ctx context.Context, req *empty.Empty) (*AgentInfoResponse, error)

type UnimplementedLogAgentServer 

type UnimplementedLogAgentServer struct {
}

UnimplementedLogAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedLogAgentServer) Get 

func (*UnimplementedLogAgentServer) Get(req *LogRequest, srv LogAgent_GetServer) error

func (*UnimplementedLogAgentServer) GetLevel added in v0.10.29 

func (*UnimplementedLogAgentServer) GetLevel(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedLogAgentServer) Rotate 

func (*UnimplementedLogAgentServer) Rotate(ctx context.Context, req *LogRotateRequest) (*LogRotateResponse, error)

func (*UnimplementedLogAgentServer) Set added in v0.10.29 

func (*UnimplementedLogAgentServer) Set(ctx context.Context, req *SetRequest) (*SetResponse, error)

type UnimplementedRecoveryAgentServer 

type UnimplementedRecoveryAgentServer struct {
}

UnimplementedRecoveryAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedRecoveryAgentServer) Invoke 

func (*UnimplementedRecoveryAgentServer) Invoke(ctx context.Context, req *RecoveryRequest) (*RecoveryResponse, error)

type UnimplementedValidationAgentServer added in v0.10.27 

type UnimplementedValidationAgentServer struct {
}

UnimplementedValidationAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedValidationAgentServer) Invoke added in v0.10.27 

func (*UnimplementedValidationAgentServer) Invoke(ctx context.Context, req *ValidationRequest) (*ValidationResponse, error)

type UnimplementedVersionAgentServer added in v0.10.21 

type UnimplementedVersionAgentServer struct {
}

UnimplementedVersionAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedVersionAgentServer) Get added in v0.10.21 

func (*UnimplementedVersionAgentServer) Get(ctx context.Context, req *VersionRequest) (*VersionResponse, error)

type ValidationAgentClient added in v0.10.27 

type ValidationAgentClient interface {
	Invoke(ctx context.Context, in *ValidationRequest, opts ...grpc.CallOption) (*ValidationResponse, error)
}

ValidationAgentClient is the client API for ValidationAgent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewValidationAgentClient added in v0.10.27 

func NewValidationAgentClient(cc *grpc.ClientConn) ValidationAgentClient

type ValidationAgentServer added in v0.10.27 

type ValidationAgentServer interface {
	Invoke(context.Context, *ValidationRequest) (*ValidationResponse, error)
}

ValidationAgentServer is the server API for ValidationAgent service.

type ValidationOperation added in v0.10.27 

type ValidationOperation int32
const (
	ValidationOperation_VALIDATE ValidationOperation = 0
)

func (ValidationOperation) EnumDescriptor added in v0.10.27 

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

func (ValidationOperation) String added in v0.10.27 

func (x ValidationOperation) String() string

type ValidationRequest added in v0.10.27 

type ValidationRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ValidationRequest) Descriptor added in v0.10.27 

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

func (*ValidationRequest) ProtoMessage added in v0.10.27 

func (*ValidationRequest) ProtoMessage()

func (*ValidationRequest) Reset added in v0.10.27 

func (m *ValidationRequest) Reset()

func (*ValidationRequest) String added in v0.10.27 

func (m *ValidationRequest) String() string

func (*ValidationRequest) XXX_DiscardUnknown added in v0.10.27 

func (m *ValidationRequest) XXX_DiscardUnknown()

func (*ValidationRequest) XXX_Marshal added in v0.10.27 

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

func (*ValidationRequest) XXX_Merge added in v0.10.27 

func (m *ValidationRequest) XXX_Merge(src proto.Message)

func (*ValidationRequest) XXX_Size added in v0.10.27 

func (m *ValidationRequest) XXX_Size() int

func (*ValidationRequest) XXX_Unmarshal added in v0.10.27 

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

type ValidationResponse added in v0.10.27 

type ValidationResponse struct {
	Error                string   `protobuf:"bytes,1,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ValidationResponse) Descriptor added in v0.10.27 

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

func (*ValidationResponse) GetError added in v0.10.27 

func (m *ValidationResponse) GetError() string

func (*ValidationResponse) ProtoMessage added in v0.10.27 

func (*ValidationResponse) ProtoMessage()

func (*ValidationResponse) Reset added in v0.10.27 

func (m *ValidationResponse) Reset()

func (*ValidationResponse) String added in v0.10.27 

func (m *ValidationResponse) String() string

func (*ValidationResponse) XXX_DiscardUnknown added in v0.10.27 

func (m *ValidationResponse) XXX_DiscardUnknown()

func (*ValidationResponse) XXX_Marshal added in v0.10.27 

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

func (*ValidationResponse) XXX_Merge added in v0.10.27 

func (m *ValidationResponse) XXX_Merge(src proto.Message)

func (*ValidationResponse) XXX_Size added in v0.10.27 

func (m *ValidationResponse) XXX_Size() int

func (*ValidationResponse) XXX_Unmarshal added in v0.10.27 

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

type VerboseLevel added in v0.10.29 

type VerboseLevel int32
const (
	VerboseLevel_Min_Level VerboseLevel = 0
	VerboseLevel_Max_Level VerboseLevel = 9
)

func (VerboseLevel) EnumDescriptor added in v0.10.29 

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

func (VerboseLevel) String added in v0.10.29 

func (x VerboseLevel) String() string

type VersionAgentClient added in v0.10.21 

type VersionAgentClient interface {
	Get(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
}

VersionAgentClient is the client API for VersionAgent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewVersionAgentClient added in v0.10.21 

func NewVersionAgentClient(cc *grpc.ClientConn) VersionAgentClient

type VersionAgentServer added in v0.10.21 

type VersionAgentServer interface {
	Get(context.Context, *VersionRequest) (*VersionResponse, error)
}

VersionAgentServer is the server API for VersionAgent service.

type VersionRequest added in v0.10.21 

type VersionRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VersionRequest) Descriptor added in v0.10.21 

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

func (*VersionRequest) ProtoMessage added in v0.10.21 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) Reset added in v0.10.21 

func (m *VersionRequest) Reset()

func (*VersionRequest) String added in v0.10.21 

func (m *VersionRequest) String() string

func (*VersionRequest) XXX_DiscardUnknown added in v0.10.21 

func (m *VersionRequest) XXX_DiscardUnknown()

func (*VersionRequest) XXX_Marshal added in v0.10.21 

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

func (*VersionRequest) XXX_Merge added in v0.10.21 

func (m *VersionRequest) XXX_Merge(src proto.Message)

func (*VersionRequest) XXX_Size added in v0.10.21 

func (m *VersionRequest) XXX_Size() int

func (*VersionRequest) XXX_Unmarshal added in v0.10.21 

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

type VersionResponse added in v0.10.21 

type VersionResponse struct {
	Version              string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Mocversion           string   `protobuf:"bytes,2,opt,name=mocversion,proto3" json:"mocversion,omitempty"`
	Error                string   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VersionResponse) Descriptor added in v0.10.21 

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

func (*VersionResponse) GetError added in v0.10.21 

func (m *VersionResponse) GetError() string

func (*VersionResponse) GetMocversion added in v0.10.21 

func (m *VersionResponse) GetMocversion() string

func (*VersionResponse) GetVersion added in v0.10.21 

func (m *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage added in v0.10.21 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) Reset added in v0.10.21 

func (m *VersionResponse) Reset()

func (*VersionResponse) String added in v0.10.21 

func (m *VersionResponse) String() string

func (*VersionResponse) XXX_DiscardUnknown added in v0.10.21 

func (m *VersionResponse) XXX_DiscardUnknown()

func (*VersionResponse) XXX_Marshal added in v0.10.21 

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

func (*VersionResponse) XXX_Merge added in v0.10.21 

func (m *VersionResponse) XXX_Merge(src proto.Message)

func (*VersionResponse) XXX_Size added in v0.10.21 

func (m *VersionResponse) XXX_Size() int

func (*VersionResponse) XXX_Unmarshal added in v0.10.21 

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

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.