admin

package
v0.18.0 Latest Latest
Warning

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

Go to latest
Published: Apr 9, 2024 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

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

type UnimplementedHealthAgentServer

type UnimplementedHealthAgentServer struct {
}

UnimplementedHealthAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedHealthAgentServer) CheckHealth

func (*UnimplementedHealthAgentServer) GetAgentInfo

type UnimplementedLogAgentServer

type UnimplementedLogAgentServer struct {
}

UnimplementedLogAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedLogAgentServer) Get

func (*UnimplementedLogAgentServer) GetLevel added in v0.10.29

func (*UnimplementedLogAgentServer) Rotate

func (*UnimplementedLogAgentServer) Set added in v0.10.29

type UnimplementedRecoveryAgentServer

type UnimplementedRecoveryAgentServer struct {
}

UnimplementedRecoveryAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedRecoveryAgentServer) Invoke

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

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

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

Jump to

Keyboard shortcuts

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