admin

package
v0.10.9-alpha.6 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2021 License: Apache-2.0 Imports: 10 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Operation_name = map[int32]string{
	0: "BACKUP",
	1: "RESTORE",
}
View Source 
var Operation_value = map[string]int32{
	"BACKUP":  0,
	"RESTORE": 1,
}

Functions

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)

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*AgentInfoResponse) Descriptor 

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

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

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

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

func (*UnimplementedLogAgentServer) Rotate(ctx context.Context, req *LogRotateRequest) (*LogRotateResponse, 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)

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.