messages

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Jan 12, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BackupType_name = map[int32]string{
	0: "BACKUP_TYPE_INVALID",
	1: "BACKUP_TYPE_LOGICAL",
	2: "BACKUP_TYPE_HOTBACKUP",
}
View Source 
var BackupType_value = map[string]int32{
	"BACKUP_TYPE_INVALID":   0,
	"BACKUP_TYPE_LOGICAL":   1,
	"BACKUP_TYPE_HOTBACKUP": 2,
}
View Source 
var CompressionType_name = map[int32]string{
	0: "COMPRESSION_TYPE_INVALID",
	1: "COMPRESSION_TYPE_NO_COMPRESSION",
	2: "COMPRESSION_TYPE_GZIP",
	3: "COMPRESSION_TYPE_SNAPPY",
	4: "COMPRESSION_TYPE_LZ4",
}
View Source 
var CompressionType_value = map[string]int32{
	"COMPRESSION_TYPE_INVALID":        0,
	"COMPRESSION_TYPE_NO_COMPRESSION": 1,
	"COMPRESSION_TYPE_GZIP":           2,
	"COMPRESSION_TYPE_SNAPPY":         3,
	"COMPRESSION_TYPE_LZ4":            4,
}
View Source 
var Cypher_name = map[int32]string{
	0: "CYPHER_INVALID",
	1: "CYPHER_NO_CYPHER",
	2: "CYPHER_AES",
	3: "CYPHER_DES",
	4: "CYPHER_RC4",
	5: "CYPHER_RSA",
}
View Source 
var Cypher_value = map[string]int32{
	"CYPHER_INVALID":   0,
	"CYPHER_NO_CYPHER": 1,
	"CYPHER_AES":       2,
	"CYPHER_DES":       3,
	"CYPHER_RC4":       4,
	"CYPHER_RSA":       5,
}
View Source 
var DestinationType_name = map[int32]string{
	0: "DESTINATION_TYPE_INVALID",
	1: "DESTINATION_TYPE_FILE",
	2: "DESTINATION_TYPE_AWS",
}
View Source 
var DestinationType_value = map[string]int32{
	"DESTINATION_TYPE_INVALID": 0,
	"DESTINATION_TYPE_FILE":    1,
	"DESTINATION_TYPE_AWS":     2,
}
View Source 
var ErrorType_name = map[int32]string{
	0: "ERROR_TYPE_INVALID",
	1: "ERROR_TYPE_NOT_IMPLEMENTED_YET",
	2: "ERROR_TYPE_COMMUNICATION_ERROR",
	3: "ERROR_TYPE_CLIENT_ALREADY_REGISTERED",
}
View Source 
var ErrorType_value = map[string]int32{
	"ERROR_TYPE_INVALID":                   0,
	"ERROR_TYPE_NOT_IMPLEMENTED_YET":       1,
	"ERROR_TYPE_COMMUNICATION_ERROR":       2,
	"ERROR_TYPE_CLIENT_ALREADY_REGISTERED": 3,
}
View Source 
var NodeType_name = map[int32]string{
	0: "NODE_TYPE_INVALID",
	1: "NODE_TYPE_MONGOD",
	2: "NODE_TYPE_MONGOD_REPLSET",
	3: "NODE_TYPE_MONGOD_SHARDSVR",
	4: "NODE_TYPE_MONGOD_CONFIGSVR",
	5: "NODE_TYPE_MONGOS",
}
View Source 
var NodeType_value = map[string]int32{
	"NODE_TYPE_INVALID":          0,
	"NODE_TYPE_MONGOD":           1,
	"NODE_TYPE_MONGOD_REPLSET":   2,
	"NODE_TYPE_MONGOD_SHARDSVR":  3,
	"NODE_TYPE_MONGOD_CONFIGSVR": 4,
	"NODE_TYPE_MONGOS":           5,
}
View Source 
var RestoreStatus_name = map[int32]string{
	0: "RESTORE_STATUS_INVALID",
	1: "RESTORE_STATUS_NOT_RUNNING",
	2: "RESTORE_STATUS_RESTORINGDB",
	3: "RESTORE_STATUS_RESTORINGOPLOG",
}
View Source 
var RestoreStatus_value = map[string]int32{
	"RESTORE_STATUS_INVALID":        0,
	"RESTORE_STATUS_NOT_RUNNING":    1,
	"RESTORE_STATUS_RESTORINGDB":    2,
	"RESTORE_STATUS_RESTORINGOPLOG": 3,
}

Functions

func RegisterMessagesServer 

func RegisterMessagesServer(s *grpc.Server, srv MessagesServer)

Types

type Ack 

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

func (*Ack) Descriptor 

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

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) Reset 

func (m *Ack) Reset()

func (*Ack) String 

func (m *Ack) String() string

func (*Ack) XXX_DiscardUnknown 

func (m *Ack) XXX_DiscardUnknown()

func (*Ack) XXX_Marshal 

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

func (*Ack) XXX_Merge 

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

func (*Ack) XXX_Size 

func (m *Ack) XXX_Size() int

func (*Ack) XXX_Unmarshal 

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

type BackupMetadata 

type BackupMetadata struct {
	StartTs              int64                          `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	EndTs                int64                          `protobuf:"varint,2,opt,name=end_ts,json=endTs,proto3" json:"end_ts,omitempty"`
	BackupType           BackupType                     `protobuf:"varint,3,opt,name=backup_type,json=backupType,proto3,enum=messages.BackupType" json:"backup_type,omitempty"`
	OplogStartTime       int64                          `protobuf:"varint,4,opt,name=oplog_start_time,json=oplogStartTime,proto3" json:"oplog_start_time,omitempty"`
	LastOplogTs          int64                          `protobuf:"varint,5,opt,name=last_oplog_ts,json=lastOplogTs,proto3" json:"last_oplog_ts,omitempty"`
	DestinationType      DestinationType                `` /* 137-byte string literal not displayed */
	DestinationDir       string                         `protobuf:"bytes,7,opt,name=destination_dir,json=destinationDir,proto3" json:"destination_dir,omitempty"`
	DestinationName      string                         `protobuf:"bytes,8,opt,name=destination_name,json=destinationName,proto3" json:"destination_name,omitempty"`
	Cypher               Cypher                         `protobuf:"varint,9,opt,name=cypher,proto3,enum=messages.Cypher" json:"cypher,omitempty"`
	CompressionType      CompressionType                `` /* 138-byte string literal not displayed */
	Description          string                         `protobuf:"bytes,11,opt,name=description,proto3" json:"description,omitempty"`
	Replicasets          map[string]*ReplicasetMetadata `` /* 164-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*BackupMetadata) Descriptor 

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

func (*BackupMetadata) GetBackupType 

func (m *BackupMetadata) GetBackupType() BackupType

func (*BackupMetadata) GetCompressionType 

func (m *BackupMetadata) GetCompressionType() CompressionType

func (*BackupMetadata) GetCypher 

func (m *BackupMetadata) GetCypher() Cypher

func (*BackupMetadata) GetDescription 

func (m *BackupMetadata) GetDescription() string

func (*BackupMetadata) GetDestinationDir 

func (m *BackupMetadata) GetDestinationDir() string

func (*BackupMetadata) GetDestinationName 

func (m *BackupMetadata) GetDestinationName() string

func (*BackupMetadata) GetDestinationType 

func (m *BackupMetadata) GetDestinationType() DestinationType

func (*BackupMetadata) GetEndTs 

func (m *BackupMetadata) GetEndTs() int64

func (*BackupMetadata) GetLastOplogTs 

func (m *BackupMetadata) GetLastOplogTs() int64

func (*BackupMetadata) GetOplogStartTime 

func (m *BackupMetadata) GetOplogStartTime() int64

func (*BackupMetadata) GetReplicasets 

func (m *BackupMetadata) GetReplicasets() map[string]*ReplicasetMetadata

func (*BackupMetadata) GetStartTs 

func (m *BackupMetadata) GetStartTs() int64

func (*BackupMetadata) ProtoMessage 

func (*BackupMetadata) ProtoMessage()

func (*BackupMetadata) Reset 

func (m *BackupMetadata) Reset()

func (*BackupMetadata) String 

func (m *BackupMetadata) String() string

func (*BackupMetadata) XXX_DiscardUnknown 

func (m *BackupMetadata) XXX_DiscardUnknown()

func (*BackupMetadata) XXX_Marshal 

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

func (*BackupMetadata) XXX_Merge 

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

func (*BackupMetadata) XXX_Size 

func (m *BackupMetadata) XXX_Size() int

func (*BackupMetadata) XXX_Unmarshal 

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

type BackupSource 

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

func (*BackupSource) Descriptor 

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

func (*BackupSource) GetSourceClient 

func (m *BackupSource) GetSourceClient() string

func (*BackupSource) ProtoMessage 

func (*BackupSource) ProtoMessage()

func (*BackupSource) Reset 

func (m *BackupSource) Reset()

func (*BackupSource) String 

func (m *BackupSource) String() string

func (*BackupSource) XXX_DiscardUnknown 

func (m *BackupSource) XXX_DiscardUnknown()

func (*BackupSource) XXX_Marshal 

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

func (*BackupSource) XXX_Merge 

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

func (*BackupSource) XXX_Size 

func (m *BackupSource) XXX_Size() int

func (*BackupSource) XXX_Unmarshal 

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

type BackupType 

type BackupType int32
const (
	BackupType_BACKUP_TYPE_INVALID   BackupType = 0
	BackupType_BACKUP_TYPE_LOGICAL   BackupType = 1
	BackupType_BACKUP_TYPE_HOTBACKUP BackupType = 2
)

func (BackupType) EnumDescriptor 

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

func (BackupType) String 

func (x BackupType) String() string

type CanRestoreBackup 

type CanRestoreBackup struct {
	BackupType           BackupType      `protobuf:"varint,1,opt,name=backup_type,json=backupType,proto3,enum=messages.BackupType" json:"backup_type,omitempty"`
	DestinationType      DestinationType `` /* 137-byte string literal not displayed */
	DestinationDir       string          `protobuf:"bytes,3,opt,name=destination_dir,json=destinationDir,proto3" json:"destination_dir,omitempty"`
	BackupName           string          `protobuf:"bytes,4,opt,name=backup_name,json=backupName,proto3" json:"backup_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*CanRestoreBackup) Descriptor 

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

func (*CanRestoreBackup) GetBackupName 

func (m *CanRestoreBackup) GetBackupName() string

func (*CanRestoreBackup) GetBackupType 

func (m *CanRestoreBackup) GetBackupType() BackupType

func (*CanRestoreBackup) GetDestinationDir 

func (m *CanRestoreBackup) GetDestinationDir() string

func (*CanRestoreBackup) GetDestinationType 

func (m *CanRestoreBackup) GetDestinationType() DestinationType

func (*CanRestoreBackup) ProtoMessage 

func (*CanRestoreBackup) ProtoMessage()

func (*CanRestoreBackup) Reset 

func (m *CanRestoreBackup) Reset()

func (*CanRestoreBackup) String 

func (m *CanRestoreBackup) String() string

func (*CanRestoreBackup) XXX_DiscardUnknown 

func (m *CanRestoreBackup) XXX_DiscardUnknown()

func (*CanRestoreBackup) XXX_Marshal 

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

func (*CanRestoreBackup) XXX_Merge 

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

func (*CanRestoreBackup) XXX_Size 

func (m *CanRestoreBackup) XXX_Size() int

func (*CanRestoreBackup) XXX_Unmarshal 

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

type CanRestoreBackupResponse 

type CanRestoreBackupResponse struct {
	ClientId             string   `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Replicaset           string   `protobuf:"bytes,2,opt,name=replicaset,proto3" json:"replicaset,omitempty"`
	IsPrimary            bool     `protobuf:"varint,3,opt,name=is_primary,json=isPrimary,proto3" json:"is_primary,omitempty"`
	CanRestore           bool     `protobuf:"varint,4,opt,name=can_restore,json=canRestore,proto3" json:"can_restore,omitempty"`
	Host                 string   `protobuf:"bytes,5,opt,name=host,proto3" json:"host,omitempty"`
	Port                 string   `protobuf:"bytes,6,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CanRestoreBackupResponse) Descriptor 

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

func (*CanRestoreBackupResponse) GetCanRestore 

func (m *CanRestoreBackupResponse) GetCanRestore() bool

func (*CanRestoreBackupResponse) GetClientId 

func (m *CanRestoreBackupResponse) GetClientId() string

func (*CanRestoreBackupResponse) GetHost 

func (m *CanRestoreBackupResponse) GetHost() string

func (*CanRestoreBackupResponse) GetIsPrimary 

func (m *CanRestoreBackupResponse) GetIsPrimary() bool

func (*CanRestoreBackupResponse) GetPort 

func (m *CanRestoreBackupResponse) GetPort() string

func (*CanRestoreBackupResponse) GetReplicaset 

func (m *CanRestoreBackupResponse) GetReplicaset() string

func (*CanRestoreBackupResponse) ProtoMessage 

func (*CanRestoreBackupResponse) ProtoMessage()

func (*CanRestoreBackupResponse) Reset 

func (m *CanRestoreBackupResponse) Reset()

func (*CanRestoreBackupResponse) String 

func (m *CanRestoreBackupResponse) String() string

func (*CanRestoreBackupResponse) XXX_DiscardUnknown 

func (m *CanRestoreBackupResponse) XXX_DiscardUnknown()

func (*CanRestoreBackupResponse) XXX_Marshal 

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

func (*CanRestoreBackupResponse) XXX_Merge 

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

func (*CanRestoreBackupResponse) XXX_Size 

func (m *CanRestoreBackupResponse) XXX_Size() int

func (*CanRestoreBackupResponse) XXX_Unmarshal 

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

type CancelBackup 

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

func (*CancelBackup) Descriptor 

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

func (*CancelBackup) ProtoMessage 

func (*CancelBackup) ProtoMessage()

func (*CancelBackup) Reset 

func (m *CancelBackup) Reset()

func (*CancelBackup) String 

func (m *CancelBackup) String() string

func (*CancelBackup) XXX_DiscardUnknown 

func (m *CancelBackup) XXX_DiscardUnknown()

func (*CancelBackup) XXX_Marshal 

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

func (*CancelBackup) XXX_Merge 

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

func (*CancelBackup) XXX_Size 

func (m *CancelBackup) XXX_Size() int

func (*CancelBackup) XXX_Unmarshal 

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

type ClientMessage 

type ClientMessage struct {
	Version  int32  `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	ClientId string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// Types that are valid to be assigned to Payload:
	//	*ClientMessage_AckMsg
	//	*ClientMessage_BackupSourceMsg
	//	*ClientMessage_BackupFinishedMsg
	//	*ClientMessage_ErrorMsg
	//	*ClientMessage_OplogFinishedMsg
	//	*ClientMessage_LastOplogTs
	//	*ClientMessage_PongMsg
	//	*ClientMessage_RegisterMsg
	//	*ClientMessage_ReplicasetsMsg
	//	*ClientMessage_StatusMsg
	//	*ClientMessage_CanRestoreBackupMsg
	Payload              isClientMessage_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ClientMessage) Descriptor 

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

func (*ClientMessage) GetAckMsg 

func (m *ClientMessage) GetAckMsg() *Ack

func (*ClientMessage) GetBackupFinishedMsg 

func (m *ClientMessage) GetBackupFinishedMsg() *DBBackupFinishStatus

func (*ClientMessage) GetBackupSourceMsg 

func (m *ClientMessage) GetBackupSourceMsg() *BackupSource

func (*ClientMessage) GetCanRestoreBackupMsg 

func (m *ClientMessage) GetCanRestoreBackupMsg() *CanRestoreBackupResponse

func (*ClientMessage) GetClientId 

func (m *ClientMessage) GetClientId() string

func (*ClientMessage) GetErrorMsg 

func (m *ClientMessage) GetErrorMsg() *Error

func (*ClientMessage) GetLastOplogTs 

func (m *ClientMessage) GetLastOplogTs() *LastOplogTs

func (*ClientMessage) GetOplogFinishedMsg 

func (m *ClientMessage) GetOplogFinishedMsg() *OplogBackupFinishStatus

func (*ClientMessage) GetPayload 

func (m *ClientMessage) GetPayload() isClientMessage_Payload

func (*ClientMessage) GetPongMsg 

func (m *ClientMessage) GetPongMsg() *Pong

func (*ClientMessage) GetRegisterMsg 

func (m *ClientMessage) GetRegisterMsg() *Register

func (*ClientMessage) GetReplicasetsMsg 

func (m *ClientMessage) GetReplicasetsMsg() *Replicasets

func (*ClientMessage) GetStatusMsg 

func (m *ClientMessage) GetStatusMsg() *Status

func (*ClientMessage) GetVersion 

func (m *ClientMessage) GetVersion() int32

func (*ClientMessage) ProtoMessage 

func (*ClientMessage) ProtoMessage()

func (*ClientMessage) Reset 

func (m *ClientMessage) Reset()

func (*ClientMessage) String 

func (m *ClientMessage) String() string

func (*ClientMessage) XXX_DiscardUnknown 

func (m *ClientMessage) XXX_DiscardUnknown()

func (*ClientMessage) XXX_Marshal 

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

func (*ClientMessage) XXX_Merge 

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

func (*ClientMessage) XXX_OneofFuncs 

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

XXX_OneofFuncs is for the internal use of the proto package.

func (*ClientMessage) XXX_Size 

func (m *ClientMessage) XXX_Size() int

func (*ClientMessage) XXX_Unmarshal 

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

type ClientMessage_AckMsg 

type ClientMessage_AckMsg struct {
	AckMsg *Ack `protobuf:"bytes,3,opt,name=ack_msg,json=ackMsg,proto3,oneof"`
}

type ClientMessage_BackupFinishedMsg 

type ClientMessage_BackupFinishedMsg struct {
	BackupFinishedMsg *DBBackupFinishStatus `protobuf:"bytes,5,opt,name=backup_finished_msg,json=backupFinishedMsg,proto3,oneof"`
}

type ClientMessage_BackupSourceMsg 

type ClientMessage_BackupSourceMsg struct {
	BackupSourceMsg *BackupSource `protobuf:"bytes,4,opt,name=backup_source_msg,json=backupSourceMsg,proto3,oneof"`
}

type ClientMessage_CanRestoreBackupMsg 

type ClientMessage_CanRestoreBackupMsg struct {
	CanRestoreBackupMsg *CanRestoreBackupResponse `protobuf:"bytes,13,opt,name=can_restore_backup_msg,json=canRestoreBackupMsg,proto3,oneof"`
}

type ClientMessage_ErrorMsg 

type ClientMessage_ErrorMsg struct {
	ErrorMsg *Error `protobuf:"bytes,6,opt,name=error_msg,json=errorMsg,proto3,oneof"`
}

type ClientMessage_LastOplogTs 

type ClientMessage_LastOplogTs struct {
	LastOplogTs *LastOplogTs `protobuf:"bytes,8,opt,name=last_oplog_ts,json=lastOplogTs,proto3,oneof"`
}

type ClientMessage_OplogFinishedMsg 

type ClientMessage_OplogFinishedMsg struct {
	OplogFinishedMsg *OplogBackupFinishStatus `protobuf:"bytes,7,opt,name=oplog_finished_msg,json=oplogFinishedMsg,proto3,oneof"`
}

type ClientMessage_PongMsg 

type ClientMessage_PongMsg struct {
	PongMsg *Pong `protobuf:"bytes,9,opt,name=pong_msg,json=pongMsg,proto3,oneof"`
}

type ClientMessage_RegisterMsg 

type ClientMessage_RegisterMsg struct {
	RegisterMsg *Register `protobuf:"bytes,10,opt,name=register_msg,json=registerMsg,proto3,oneof"`
}

type ClientMessage_ReplicasetsMsg 

type ClientMessage_ReplicasetsMsg struct {
	ReplicasetsMsg *Replicasets `protobuf:"bytes,11,opt,name=replicasets_msg,json=replicasetsMsg,proto3,oneof"`
}

type ClientMessage_StatusMsg 

type ClientMessage_StatusMsg struct {
	StatusMsg *Status `protobuf:"bytes,12,opt,name=status_msg,json=statusMsg,proto3,oneof"`
}

type CompressionType 

type CompressionType int32
const (
	CompressionType_COMPRESSION_TYPE_INVALID        CompressionType = 0
	CompressionType_COMPRESSION_TYPE_NO_COMPRESSION CompressionType = 1
	CompressionType_COMPRESSION_TYPE_GZIP           CompressionType = 2
	CompressionType_COMPRESSION_TYPE_SNAPPY         CompressionType = 3
	CompressionType_COMPRESSION_TYPE_LZ4            CompressionType = 4
)

func (CompressionType) EnumDescriptor 

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

func (CompressionType) String 

func (x CompressionType) String() string

type Cypher 

type Cypher int32
const (
	Cypher_CYPHER_INVALID   Cypher = 0
	Cypher_CYPHER_NO_CYPHER Cypher = 1
	Cypher_CYPHER_AES       Cypher = 2
	Cypher_CYPHER_DES       Cypher = 3
	Cypher_CYPHER_RC4       Cypher = 4
	Cypher_CYPHER_RSA       Cypher = 5
)

func (Cypher) EnumDescriptor 

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

func (Cypher) String 

func (x Cypher) String() string

type DBBackupFinishStatus 

type DBBackupFinishStatus struct {
	ClientId             string   `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Ok                   bool     `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	Ts                   int64    `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"`
	Error                string   `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBBackupFinishStatus) Descriptor 

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

func (*DBBackupFinishStatus) GetClientId 

func (m *DBBackupFinishStatus) GetClientId() string

func (*DBBackupFinishStatus) GetError 

func (m *DBBackupFinishStatus) GetError() string

func (*DBBackupFinishStatus) GetOk 

func (m *DBBackupFinishStatus) GetOk() bool

func (*DBBackupFinishStatus) GetTs 

func (m *DBBackupFinishStatus) GetTs() int64

func (*DBBackupFinishStatus) ProtoMessage 

func (*DBBackupFinishStatus) ProtoMessage()

func (*DBBackupFinishStatus) Reset 

func (m *DBBackupFinishStatus) Reset()

func (*DBBackupFinishStatus) String 

func (m *DBBackupFinishStatus) String() string

func (*DBBackupFinishStatus) XXX_DiscardUnknown 

func (m *DBBackupFinishStatus) XXX_DiscardUnknown()

func (*DBBackupFinishStatus) XXX_Marshal 

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

func (*DBBackupFinishStatus) XXX_Merge 

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

func (*DBBackupFinishStatus) XXX_Size 

func (m *DBBackupFinishStatus) XXX_Size() int

func (*DBBackupFinishStatus) XXX_Unmarshal 

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

type DBBackupFinishedAck 

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

func (*DBBackupFinishedAck) Descriptor 

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

func (*DBBackupFinishedAck) ProtoMessage 

func (*DBBackupFinishedAck) ProtoMessage()

func (*DBBackupFinishedAck) Reset 

func (m *DBBackupFinishedAck) Reset()

func (*DBBackupFinishedAck) String 

func (m *DBBackupFinishedAck) String() string

func (*DBBackupFinishedAck) XXX_DiscardUnknown 

func (m *DBBackupFinishedAck) XXX_DiscardUnknown()

func (*DBBackupFinishedAck) XXX_Marshal 

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

func (*DBBackupFinishedAck) XXX_Merge 

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

func (*DBBackupFinishedAck) XXX_Size 

func (m *DBBackupFinishedAck) XXX_Size() int

func (*DBBackupFinishedAck) XXX_Unmarshal 

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

type DestinationType 

type DestinationType int32
const (
	DestinationType_DESTINATION_TYPE_INVALID DestinationType = 0
	DestinationType_DESTINATION_TYPE_FILE    DestinationType = 1
	DestinationType_DESTINATION_TYPE_AWS     DestinationType = 2
)

func (DestinationType) EnumDescriptor 

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

func (DestinationType) String 

func (x DestinationType) String() string

type Empty 

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

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type Error 

type Error struct {
	Message              string    `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Code                 ErrorType `protobuf:"varint,2,opt,name=code,proto3,enum=messages.ErrorType" json:"code,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Error) Descriptor 

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

func (*Error) GetCode 

func (m *Error) GetCode() ErrorType

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type ErrorType 

type ErrorType int32
const (
	ErrorType_ERROR_TYPE_INVALID                   ErrorType = 0
	ErrorType_ERROR_TYPE_NOT_IMPLEMENTED_YET       ErrorType = 1
	ErrorType_ERROR_TYPE_COMMUNICATION_ERROR       ErrorType = 2
	ErrorType_ERROR_TYPE_CLIENT_ALREADY_REGISTERED ErrorType = 3
)

func (ErrorType) EnumDescriptor 

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

func (ErrorType) String 

func (x ErrorType) String() string

type GetBackupSource 

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

func (*GetBackupSource) Descriptor 

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

func (*GetBackupSource) ProtoMessage 

func (*GetBackupSource) ProtoMessage()

func (*GetBackupSource) Reset 

func (m *GetBackupSource) Reset()

func (*GetBackupSource) String 

func (m *GetBackupSource) String() string

func (*GetBackupSource) XXX_DiscardUnknown 

func (m *GetBackupSource) XXX_DiscardUnknown()

func (*GetBackupSource) XXX_Marshal 

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

func (*GetBackupSource) XXX_Merge 

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

func (*GetBackupSource) XXX_Size 

func (m *GetBackupSource) XXX_Size() int

func (*GetBackupSource) XXX_Unmarshal 

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

type GetLastOplogTs 

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

func (*GetLastOplogTs) Descriptor 

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

func (*GetLastOplogTs) ProtoMessage 

func (*GetLastOplogTs) ProtoMessage()

func (*GetLastOplogTs) Reset 

func (m *GetLastOplogTs) Reset()

func (*GetLastOplogTs) String 

func (m *GetLastOplogTs) String() string

func (*GetLastOplogTs) XXX_DiscardUnknown 

func (m *GetLastOplogTs) XXX_DiscardUnknown()

func (*GetLastOplogTs) XXX_Marshal 

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

func (*GetLastOplogTs) XXX_Merge 

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

func (*GetLastOplogTs) XXX_Size 

func (m *GetLastOplogTs) XXX_Size() int

func (*GetLastOplogTs) XXX_Unmarshal 

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

type GetStatus 

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

func (*GetStatus) Descriptor 

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

func (*GetStatus) ProtoMessage 

func (*GetStatus) ProtoMessage()

func (*GetStatus) Reset 

func (m *GetStatus) Reset()

func (*GetStatus) String 

func (m *GetStatus) String() string

func (*GetStatus) XXX_DiscardUnknown 

func (m *GetStatus) XXX_DiscardUnknown()

func (*GetStatus) XXX_Marshal 

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

func (*GetStatus) XXX_Merge 

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

func (*GetStatus) XXX_Size 

func (m *GetStatus) XXX_Size() int

func (*GetStatus) XXX_Unmarshal 

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

type LastOplogTs 

type LastOplogTs struct {
	LastOplogTs          int64    `protobuf:"varint,1,opt,name=last_oplog_ts,json=lastOplogTs,proto3" json:"last_oplog_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LastOplogTs) Descriptor 

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

func (*LastOplogTs) GetLastOplogTs 

func (m *LastOplogTs) GetLastOplogTs() int64

func (*LastOplogTs) ProtoMessage 

func (*LastOplogTs) ProtoMessage()

func (*LastOplogTs) Reset 

func (m *LastOplogTs) Reset()

func (*LastOplogTs) String 

func (m *LastOplogTs) String() string

func (*LastOplogTs) XXX_DiscardUnknown 

func (m *LastOplogTs) XXX_DiscardUnknown()

func (*LastOplogTs) XXX_Marshal 

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

func (*LastOplogTs) XXX_Merge 

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

func (*LastOplogTs) XXX_Size 

func (m *LastOplogTs) XXX_Size() int

func (*LastOplogTs) XXX_Unmarshal 

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

type ListReplicasets 

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

func (*ListReplicasets) Descriptor 

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

func (*ListReplicasets) ProtoMessage 

func (*ListReplicasets) ProtoMessage()

func (*ListReplicasets) Reset 

func (m *ListReplicasets) Reset()

func (*ListReplicasets) String 

func (m *ListReplicasets) String() string

func (*ListReplicasets) XXX_DiscardUnknown 

func (m *ListReplicasets) XXX_DiscardUnknown()

func (*ListReplicasets) XXX_Marshal 

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

func (*ListReplicasets) XXX_Merge 

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

func (*ListReplicasets) XXX_Size 

func (m *ListReplicasets) XXX_Size() int

func (*ListReplicasets) XXX_Unmarshal 

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

type LogEntry 

type LogEntry struct {
	ClientId             string   `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Level                uint32   `protobuf:"varint,2,opt,name=level,proto3" json:"level,omitempty"`
	Ts                   int64    `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"`
	Message              string   `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogEntry) Descriptor 

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

func (*LogEntry) GetClientId 

func (m *LogEntry) GetClientId() string

func (*LogEntry) GetLevel 

func (m *LogEntry) GetLevel() uint32

func (*LogEntry) GetMessage 

func (m *LogEntry) GetMessage() string

func (*LogEntry) GetTs 

func (m *LogEntry) GetTs() int64

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) String 

func (m *LogEntry) String() string

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

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

func (*LogEntry) XXX_Merge 

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

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

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

type MessagesClient 

type MessagesClient interface {
	// streams
	Logging(ctx context.Context, opts ...grpc.CallOption) (Messages_LoggingClient, error)
	MessagesChat(ctx context.Context, opts ...grpc.CallOption) (Messages_MessagesChatClient, error)
	// Invidividual responses
	DBBackupFinished(ctx context.Context, in *DBBackupFinishStatus, opts ...grpc.CallOption) (*DBBackupFinishedAck, error)
	OplogBackupFinished(ctx context.Context, in *OplogBackupFinishStatus, opts ...grpc.CallOption) (*OplogBackupFinishedAck, error)
	RestoreCompleted(ctx context.Context, in *RestoreComplete, opts ...grpc.CallOption) (*RestoreCompletedAck, error)
}

MessagesClient is the client API for Messages service.

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

func NewMessagesClient 

func NewMessagesClient(cc *grpc.ClientConn) MessagesClient

type MessagesServer 

type MessagesServer interface {
	// streams
	Logging(Messages_LoggingServer) error
	MessagesChat(Messages_MessagesChatServer) error
	// Invidividual responses
	DBBackupFinished(context.Context, *DBBackupFinishStatus) (*DBBackupFinishedAck, error)
	OplogBackupFinished(context.Context, *OplogBackupFinishStatus) (*OplogBackupFinishedAck, error)
	RestoreCompleted(context.Context, *RestoreComplete) (*RestoreCompletedAck, error)
}

MessagesServer is the server API for Messages service.

type Messages_LoggingClient 

type Messages_LoggingClient interface {
	Send(*LogEntry) error
	CloseAndRecv() (*Ack, error)
	grpc.ClientStream
}

type Messages_LoggingServer 

type Messages_LoggingServer interface {
	SendAndClose(*Ack) error
	Recv() (*LogEntry, error)
	grpc.ServerStream
}

type Messages_MessagesChatClient 

type Messages_MessagesChatClient interface {
	Send(*ClientMessage) error
	Recv() (*ServerMessage, error)
	grpc.ClientStream
}

type Messages_MessagesChatServer 

type Messages_MessagesChatServer interface {
	Send(*ServerMessage) error
	Recv() (*ClientMessage, error)
	grpc.ServerStream
}

type NodeType 

type NodeType int32
const (
	NodeType_NODE_TYPE_INVALID          NodeType = 0
	NodeType_NODE_TYPE_MONGOD           NodeType = 1
	NodeType_NODE_TYPE_MONGOD_REPLSET   NodeType = 2
	NodeType_NODE_TYPE_MONGOD_SHARDSVR  NodeType = 3
	NodeType_NODE_TYPE_MONGOD_CONFIGSVR NodeType = 4
	NodeType_NODE_TYPE_MONGOS           NodeType = 5
)

func (NodeType) EnumDescriptor 

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

func (NodeType) String 

func (x NodeType) String() string

type OplogBackupFinishStatus 

type OplogBackupFinishStatus struct {
	ClientId             string   `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Ok                   bool     `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	Ts                   int64    `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"`
	Error                string   `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OplogBackupFinishStatus) Descriptor 

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

func (*OplogBackupFinishStatus) GetClientId 

func (m *OplogBackupFinishStatus) GetClientId() string

func (*OplogBackupFinishStatus) GetError 

func (m *OplogBackupFinishStatus) GetError() string

func (*OplogBackupFinishStatus) GetOk 

func (m *OplogBackupFinishStatus) GetOk() bool

func (*OplogBackupFinishStatus) GetTs 

func (m *OplogBackupFinishStatus) GetTs() int64

func (*OplogBackupFinishStatus) ProtoMessage 

func (*OplogBackupFinishStatus) ProtoMessage()

func (*OplogBackupFinishStatus) Reset 

func (m *OplogBackupFinishStatus) Reset()

func (*OplogBackupFinishStatus) String 

func (m *OplogBackupFinishStatus) String() string

func (*OplogBackupFinishStatus) XXX_DiscardUnknown 

func (m *OplogBackupFinishStatus) XXX_DiscardUnknown()

func (*OplogBackupFinishStatus) XXX_Marshal 

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

func (*OplogBackupFinishStatus) XXX_Merge 

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

func (*OplogBackupFinishStatus) XXX_Size 

func (m *OplogBackupFinishStatus) XXX_Size() int

func (*OplogBackupFinishStatus) XXX_Unmarshal 

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

type OplogBackupFinishedAck 

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

func (*OplogBackupFinishedAck) Descriptor 

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

func (*OplogBackupFinishedAck) ProtoMessage 

func (*OplogBackupFinishedAck) ProtoMessage()

func (*OplogBackupFinishedAck) Reset 

func (m *OplogBackupFinishedAck) Reset()

func (*OplogBackupFinishedAck) String 

func (m *OplogBackupFinishedAck) String() string

func (*OplogBackupFinishedAck) XXX_DiscardUnknown 

func (m *OplogBackupFinishedAck) XXX_DiscardUnknown()

func (*OplogBackupFinishedAck) XXX_Marshal 

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

func (*OplogBackupFinishedAck) XXX_Merge 

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

func (*OplogBackupFinishedAck) XXX_Size 

func (m *OplogBackupFinishedAck) XXX_Size() int

func (*OplogBackupFinishedAck) XXX_Unmarshal 

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

type Ping 

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

func (*Ping) Descriptor 

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

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) Reset 

func (m *Ping) Reset()

func (*Ping) String 

func (m *Ping) String() string

func (*Ping) XXX_DiscardUnknown 

func (m *Ping) XXX_DiscardUnknown()

func (*Ping) XXX_Marshal 

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

func (*Ping) XXX_Merge 

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

func (*Ping) XXX_Size 

func (m *Ping) XXX_Size() int

func (*Ping) XXX_Unmarshal 

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

type Pong 

type Pong struct {
	Timestamp            int64    `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	NodeType             NodeType `protobuf:"varint,2,opt,name=node_type,json=nodeType,proto3,enum=messages.NodeType" json:"node_type,omitempty"`
	ReplicaSetUuid       string   `protobuf:"bytes,3,opt,name=replica_set_uuid,json=replicaSetUuid,proto3" json:"replica_set_uuid,omitempty"`
	ReplicaSetVersion    int32    `protobuf:"varint,4,opt,name=replica_set_version,json=replicaSetVersion,proto3" json:"replica_set_version,omitempty"`
	IsPrimary            bool     `protobuf:"varint,5,opt,name=is_primary,json=isPrimary,proto3" json:"is_primary,omitempty"`
	IsSecondary          bool     `protobuf:"varint,6,opt,name=is_secondary,json=isSecondary,proto3" json:"is_secondary,omitempty"`
	IsTailing            bool     `protobuf:"varint,7,opt,name=is_tailing,json=isTailing,proto3" json:"is_tailing,omitempty"`
	LastTailedTimestamp  int64    `protobuf:"varint,8,opt,name=last_tailed_timestamp,json=lastTailedTimestamp,proto3" json:"last_tailed_timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Pong) Descriptor 

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

func (*Pong) GetIsPrimary 

func (m *Pong) GetIsPrimary() bool

func (*Pong) GetIsSecondary 

func (m *Pong) GetIsSecondary() bool

func (*Pong) GetIsTailing 

func (m *Pong) GetIsTailing() bool

func (*Pong) GetLastTailedTimestamp 

func (m *Pong) GetLastTailedTimestamp() int64

func (*Pong) GetNodeType 

func (m *Pong) GetNodeType() NodeType

func (*Pong) GetReplicaSetUuid 

func (m *Pong) GetReplicaSetUuid() string

func (*Pong) GetReplicaSetVersion 

func (m *Pong) GetReplicaSetVersion() int32

func (*Pong) GetTimestamp 

func (m *Pong) GetTimestamp() int64

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) Reset 

func (m *Pong) Reset()

func (*Pong) String 

func (m *Pong) String() string

func (*Pong) XXX_DiscardUnknown 

func (m *Pong) XXX_DiscardUnknown()

func (*Pong) XXX_Marshal 

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

func (*Pong) XXX_Merge 

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

func (*Pong) XXX_Size 

func (m *Pong) XXX_Size() int

func (*Pong) XXX_Unmarshal 

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

type Register 

type Register struct {
	NodeType             NodeType `protobuf:"varint,1,opt,name=node_type,json=nodeType,proto3,enum=messages.NodeType" json:"node_type,omitempty"`
	NodeName             string   `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	ClusterId            string   `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	ReplicasetId         string   `protobuf:"bytes,4,opt,name=replicaset_id,json=replicasetId,proto3" json:"replicaset_id,omitempty"`
	ReplicasetName       string   `protobuf:"bytes,5,opt,name=replicaset_name,json=replicasetName,proto3" json:"replicaset_name,omitempty"`
	BackupDir            string   `protobuf:"bytes,6,opt,name=backup_dir,json=backupDir,proto3" json:"backup_dir,omitempty"`
	IsPrimary            bool     `protobuf:"varint,7,opt,name=is_primary,json=isPrimary,proto3" json:"is_primary,omitempty"`
	IsSecondary          bool     `protobuf:"varint,8,opt,name=is_secondary,json=isSecondary,proto3" json:"is_secondary,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Register) Descriptor 

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

func (*Register) GetBackupDir 

func (m *Register) GetBackupDir() string

func (*Register) GetClusterId 

func (m *Register) GetClusterId() string

func (*Register) GetIsPrimary 

func (m *Register) GetIsPrimary() bool

func (*Register) GetIsSecondary 

func (m *Register) GetIsSecondary() bool

func (*Register) GetNodeName 

func (m *Register) GetNodeName() string

func (*Register) GetNodeType 

func (m *Register) GetNodeType() NodeType

func (*Register) GetReplicasetId 

func (m *Register) GetReplicasetId() string

func (*Register) GetReplicasetName 

func (m *Register) GetReplicasetName() string

func (*Register) ProtoMessage 

func (*Register) ProtoMessage()

func (*Register) Reset 

func (m *Register) Reset()

func (*Register) String 

func (m *Register) String() string

func (*Register) XXX_DiscardUnknown 

func (m *Register) XXX_DiscardUnknown()

func (*Register) XXX_Marshal 

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

func (*Register) XXX_Merge 

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

func (*Register) XXX_Size 

func (m *Register) XXX_Size() int

func (*Register) XXX_Unmarshal 

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

type ReplicasetMetadata 

type ReplicasetMetadata struct {
	ClusterId            string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	ReplicasetUuid       string   `protobuf:"bytes,2,opt,name=replicaset_uuid,json=replicasetUuid,proto3" json:"replicaset_uuid,omitempty"`
	ReplicasetName       string   `protobuf:"bytes,3,opt,name=replicaset_name,json=replicasetName,proto3" json:"replicaset_name,omitempty"`
	DbBackupName         string   `protobuf:"bytes,4,opt,name=db_backup_name,json=dbBackupName,proto3" json:"db_backup_name,omitempty"`
	OplogBackupName      string   `protobuf:"bytes,5,opt,name=oplog_backup_name,json=oplogBackupName,proto3" json:"oplog_backup_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplicasetMetadata) Descriptor 

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

func (*ReplicasetMetadata) GetClusterId 

func (m *ReplicasetMetadata) GetClusterId() string

func (*ReplicasetMetadata) GetDbBackupName 

func (m *ReplicasetMetadata) GetDbBackupName() string

func (*ReplicasetMetadata) GetOplogBackupName 

func (m *ReplicasetMetadata) GetOplogBackupName() string

func (*ReplicasetMetadata) GetReplicasetName 

func (m *ReplicasetMetadata) GetReplicasetName() string

func (*ReplicasetMetadata) GetReplicasetUuid 

func (m *ReplicasetMetadata) GetReplicasetUuid() string

func (*ReplicasetMetadata) ProtoMessage 

func (*ReplicasetMetadata) ProtoMessage()

func (*ReplicasetMetadata) Reset 

func (m *ReplicasetMetadata) Reset()

func (*ReplicasetMetadata) String 

func (m *ReplicasetMetadata) String() string

func (*ReplicasetMetadata) XXX_DiscardUnknown 

func (m *ReplicasetMetadata) XXX_DiscardUnknown()

func (*ReplicasetMetadata) XXX_Marshal 

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

func (*ReplicasetMetadata) XXX_Merge 

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

func (*ReplicasetMetadata) XXX_Size 

func (m *ReplicasetMetadata) XXX_Size() int

func (*ReplicasetMetadata) XXX_Unmarshal 

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

type Replicasets 

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

func (*Replicasets) Descriptor 

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

func (*Replicasets) GetReplicasets 

func (m *Replicasets) GetReplicasets() []string

func (*Replicasets) ProtoMessage 

func (*Replicasets) ProtoMessage()

func (*Replicasets) Reset 

func (m *Replicasets) Reset()

func (*Replicasets) String 

func (m *Replicasets) String() string

func (*Replicasets) XXX_DiscardUnknown 

func (m *Replicasets) XXX_DiscardUnknown()

func (*Replicasets) XXX_Marshal 

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

func (*Replicasets) XXX_Merge 

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

func (*Replicasets) XXX_Size 

func (m *Replicasets) XXX_Size() int

func (*Replicasets) XXX_Unmarshal 

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

type RestoreBackup 

type RestoreBackup struct {
	MongodbHost          string          `protobuf:"bytes,1,opt,name=mongodb_host,json=mongodbHost,proto3" json:"mongodb_host,omitempty"`
	BackupType           BackupType      `protobuf:"varint,2,opt,name=backup_type,json=backupType,proto3,enum=messages.BackupType" json:"backup_type,omitempty"`
	SourceType           DestinationType `protobuf:"varint,3,opt,name=source_type,json=sourceType,proto3,enum=messages.DestinationType" json:"source_type,omitempty"`
	SourceBucket         string          `protobuf:"bytes,4,opt,name=source_bucket,json=sourceBucket,proto3" json:"source_bucket,omitempty"`
	DbSourceName         string          `protobuf:"bytes,5,opt,name=db_source_name,json=dbSourceName,proto3" json:"db_source_name,omitempty"`
	OplogSourceName      string          `protobuf:"bytes,6,opt,name=oplog_source_name,json=oplogSourceName,proto3" json:"oplog_source_name,omitempty"`
	CompressionType      CompressionType `` /* 137-byte string literal not displayed */
	Cypher               Cypher          `protobuf:"varint,8,opt,name=cypher,proto3,enum=messages.Cypher" json:"cypher,omitempty"`
	OplogStartTime       int64           `protobuf:"varint,9,opt,name=oplog_start_time,json=oplogStartTime,proto3" json:"oplog_start_time,omitempty"`
	SkipUsersAndRoles    bool            `protobuf:"varint,10,opt,name=skip_users_and_roles,json=skipUsersAndRoles,proto3" json:"skip_users_and_roles,omitempty"`
	Host                 string          `protobuf:"bytes,11,opt,name=host,proto3" json:"host,omitempty"`
	Port                 string          `protobuf:"bytes,12,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RestoreBackup) Descriptor 

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

func (*RestoreBackup) GetBackupType 

func (m *RestoreBackup) GetBackupType() BackupType

func (*RestoreBackup) GetCompressionType 

func (m *RestoreBackup) GetCompressionType() CompressionType

func (*RestoreBackup) GetCypher 

func (m *RestoreBackup) GetCypher() Cypher

func (*RestoreBackup) GetDbSourceName 

func (m *RestoreBackup) GetDbSourceName() string

func (*RestoreBackup) GetHost 

func (m *RestoreBackup) GetHost() string

func (*RestoreBackup) GetMongodbHost 

func (m *RestoreBackup) GetMongodbHost() string

func (*RestoreBackup) GetOplogSourceName 

func (m *RestoreBackup) GetOplogSourceName() string

func (*RestoreBackup) GetOplogStartTime 

func (m *RestoreBackup) GetOplogStartTime() int64

func (*RestoreBackup) GetPort 

func (m *RestoreBackup) GetPort() string

func (*RestoreBackup) GetSkipUsersAndRoles 

func (m *RestoreBackup) GetSkipUsersAndRoles() bool

func (*RestoreBackup) GetSourceBucket 

func (m *RestoreBackup) GetSourceBucket() string

func (*RestoreBackup) GetSourceType 

func (m *RestoreBackup) GetSourceType() DestinationType

func (*RestoreBackup) ProtoMessage 

func (*RestoreBackup) ProtoMessage()

func (*RestoreBackup) Reset 

func (m *RestoreBackup) Reset()

func (*RestoreBackup) String 

func (m *RestoreBackup) String() string

func (*RestoreBackup) XXX_DiscardUnknown 

func (m *RestoreBackup) XXX_DiscardUnknown()

func (*RestoreBackup) XXX_Marshal 

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

func (*RestoreBackup) XXX_Merge 

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

func (*RestoreBackup) XXX_Size 

func (m *RestoreBackup) XXX_Size() int

func (*RestoreBackup) XXX_Unmarshal 

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

type RestoreComplete 

type RestoreComplete struct {
	ClientId             string   `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Err                  *Error   `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RestoreComplete) Descriptor 

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

func (*RestoreComplete) GetClientId 

func (m *RestoreComplete) GetClientId() string

func (*RestoreComplete) GetErr 

func (m *RestoreComplete) GetErr() *Error

func (*RestoreComplete) ProtoMessage 

func (*RestoreComplete) ProtoMessage()

func (*RestoreComplete) Reset 

func (m *RestoreComplete) Reset()

func (*RestoreComplete) String 

func (m *RestoreComplete) String() string

func (*RestoreComplete) XXX_DiscardUnknown 

func (m *RestoreComplete) XXX_DiscardUnknown()

func (*RestoreComplete) XXX_Marshal 

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

func (*RestoreComplete) XXX_Merge 

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

func (*RestoreComplete) XXX_Size 

func (m *RestoreComplete) XXX_Size() int

func (*RestoreComplete) XXX_Unmarshal 

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

type RestoreCompletedAck 

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

func (*RestoreCompletedAck) Descriptor 

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

func (*RestoreCompletedAck) ProtoMessage 

func (*RestoreCompletedAck) ProtoMessage()

func (*RestoreCompletedAck) Reset 

func (m *RestoreCompletedAck) Reset()

func (*RestoreCompletedAck) String 

func (m *RestoreCompletedAck) String() string

func (*RestoreCompletedAck) XXX_DiscardUnknown 

func (m *RestoreCompletedAck) XXX_DiscardUnknown()

func (*RestoreCompletedAck) XXX_Marshal 

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

func (*RestoreCompletedAck) XXX_Merge 

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

func (*RestoreCompletedAck) XXX_Size 

func (m *RestoreCompletedAck) XXX_Size() int

func (*RestoreCompletedAck) XXX_Unmarshal 

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

type RestoreStatus 

type RestoreStatus int32
const (
	RestoreStatus_RESTORE_STATUS_INVALID        RestoreStatus = 0
	RestoreStatus_RESTORE_STATUS_NOT_RUNNING    RestoreStatus = 1
	RestoreStatus_RESTORE_STATUS_RESTORINGDB    RestoreStatus = 2
	RestoreStatus_RESTORE_STATUS_RESTORINGOPLOG RestoreStatus = 3
)

func (RestoreStatus) EnumDescriptor 

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

func (RestoreStatus) String 

func (x RestoreStatus) String() string

type ServerMessage 

type ServerMessage struct {
	Version int32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// Types that are valid to be assigned to Payload:
	//	*ServerMessage_AckMsg
	//	*ServerMessage_CancelBackupMsg
	//	*ServerMessage_CanRestoreBackupMsg
	//	*ServerMessage_ErrorMsg
	//	*ServerMessage_BackupSourceMsg
	//	*ServerMessage_GetStatusMsg
	//	*ServerMessage_ListReplicasets
	//	*ServerMessage_LastOplogTs
	//	*ServerMessage_PingMsg
	//	*ServerMessage_RestoreBackupMsg
	//	*ServerMessage_StartBackupMsg
	//	*ServerMessage_StartBalancerMsg
	//	*ServerMessage_StopBalancerMsg
	//	*ServerMessage_StopOplogTailMsg
	Payload              isServerMessage_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ServerMessage) Descriptor 

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

func (*ServerMessage) GetAckMsg 

func (m *ServerMessage) GetAckMsg() *Ack

func (*ServerMessage) GetBackupSourceMsg 

func (m *ServerMessage) GetBackupSourceMsg() *GetBackupSource

func (*ServerMessage) GetCanRestoreBackupMsg 

func (m *ServerMessage) GetCanRestoreBackupMsg() *CanRestoreBackup

func (*ServerMessage) GetCancelBackupMsg 

func (m *ServerMessage) GetCancelBackupMsg() *CancelBackup

func (*ServerMessage) GetErrorMsg 

func (m *ServerMessage) GetErrorMsg() *Error

func (*ServerMessage) GetGetStatusMsg 

func (m *ServerMessage) GetGetStatusMsg() *GetStatus

func (*ServerMessage) GetLastOplogTs 

func (m *ServerMessage) GetLastOplogTs() *GetLastOplogTs

func (*ServerMessage) GetListReplicasets 

func (m *ServerMessage) GetListReplicasets() *ListReplicasets

func (*ServerMessage) GetPayload 

func (m *ServerMessage) GetPayload() isServerMessage_Payload

func (*ServerMessage) GetPingMsg 

func (m *ServerMessage) GetPingMsg() *Ping

func (*ServerMessage) GetRestoreBackupMsg 

func (m *ServerMessage) GetRestoreBackupMsg() *RestoreBackup

func (*ServerMessage) GetStartBackupMsg 

func (m *ServerMessage) GetStartBackupMsg() *StartBackup

func (*ServerMessage) GetStartBalancerMsg 

func (m *ServerMessage) GetStartBalancerMsg() *StartBalancer

func (*ServerMessage) GetStopBalancerMsg 

func (m *ServerMessage) GetStopBalancerMsg() *StopBalancer

func (*ServerMessage) GetStopOplogTailMsg 

func (m *ServerMessage) GetStopOplogTailMsg() *StopOplogTail

func (*ServerMessage) GetVersion 

func (m *ServerMessage) GetVersion() int32

func (*ServerMessage) ProtoMessage 

func (*ServerMessage) ProtoMessage()

func (*ServerMessage) Reset 

func (m *ServerMessage) Reset()

func (*ServerMessage) String 

func (m *ServerMessage) String() string

func (*ServerMessage) XXX_DiscardUnknown 

func (m *ServerMessage) XXX_DiscardUnknown()

func (*ServerMessage) XXX_Marshal 

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

func (*ServerMessage) XXX_Merge 

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

func (*ServerMessage) XXX_OneofFuncs 

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

XXX_OneofFuncs is for the internal use of the proto package.

func (*ServerMessage) XXX_Size 

func (m *ServerMessage) XXX_Size() int

func (*ServerMessage) XXX_Unmarshal 

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

type ServerMessage_AckMsg 

type ServerMessage_AckMsg struct {
	AckMsg *Ack `protobuf:"bytes,2,opt,name=ack_msg,json=ackMsg,proto3,oneof"`
}

type ServerMessage_BackupSourceMsg 

type ServerMessage_BackupSourceMsg struct {
	BackupSourceMsg *GetBackupSource `protobuf:"bytes,6,opt,name=backup_source_msg,json=backupSourceMsg,proto3,oneof"`
}

type ServerMessage_CanRestoreBackupMsg 

type ServerMessage_CanRestoreBackupMsg struct {
	CanRestoreBackupMsg *CanRestoreBackup `protobuf:"bytes,4,opt,name=can_restore_backup_msg,json=canRestoreBackupMsg,proto3,oneof"`
}

type ServerMessage_CancelBackupMsg 

type ServerMessage_CancelBackupMsg struct {
	CancelBackupMsg *CancelBackup `protobuf:"bytes,3,opt,name=cancel_backup_msg,json=cancelBackupMsg,proto3,oneof"`
}

type ServerMessage_ErrorMsg 

type ServerMessage_ErrorMsg struct {
	ErrorMsg *Error `protobuf:"bytes,5,opt,name=error_msg,json=errorMsg,proto3,oneof"`
}

type ServerMessage_GetStatusMsg 

type ServerMessage_GetStatusMsg struct {
	GetStatusMsg *GetStatus `protobuf:"bytes,7,opt,name=get_status_msg,json=getStatusMsg,proto3,oneof"`
}

type ServerMessage_LastOplogTs 

type ServerMessage_LastOplogTs struct {
	LastOplogTs *GetLastOplogTs `protobuf:"bytes,9,opt,name=last_oplog_ts,json=lastOplogTs,proto3,oneof"`
}

type ServerMessage_ListReplicasets 

type ServerMessage_ListReplicasets struct {
	ListReplicasets *ListReplicasets `protobuf:"bytes,8,opt,name=list_replicasets,json=listReplicasets,proto3,oneof"`
}

type ServerMessage_PingMsg 

type ServerMessage_PingMsg struct {
	PingMsg *Ping `protobuf:"bytes,10,opt,name=ping_msg,json=pingMsg,proto3,oneof"`
}

type ServerMessage_RestoreBackupMsg 

type ServerMessage_RestoreBackupMsg struct {
	RestoreBackupMsg *RestoreBackup `protobuf:"bytes,11,opt,name=restore_backup_msg,json=restoreBackupMsg,proto3,oneof"`
}

type ServerMessage_StartBackupMsg 

type ServerMessage_StartBackupMsg struct {
	StartBackupMsg *StartBackup `protobuf:"bytes,12,opt,name=start_backup_msg,json=startBackupMsg,proto3,oneof"`
}

type ServerMessage_StartBalancerMsg 

type ServerMessage_StartBalancerMsg struct {
	StartBalancerMsg *StartBalancer `protobuf:"bytes,13,opt,name=start_balancer_msg,json=startBalancerMsg,proto3,oneof"`
}

type ServerMessage_StopBalancerMsg 

type ServerMessage_StopBalancerMsg struct {
	StopBalancerMsg *StopBalancer `protobuf:"bytes,14,opt,name=stop_balancer_msg,json=stopBalancerMsg,proto3,oneof"`
}

type ServerMessage_StopOplogTailMsg 

type ServerMessage_StopOplogTailMsg struct {
	StopOplogTailMsg *StopOplogTail `protobuf:"bytes,15,opt,name=stop_oplog_tail_msg,json=stopOplogTailMsg,proto3,oneof"`
}

type StartBackup 

type StartBackup struct {
	BackupType           BackupType      `protobuf:"varint,1,opt,name=backup_type,json=backupType,proto3,enum=messages.BackupType" json:"backup_type,omitempty"`
	DestinationType      DestinationType `` /* 137-byte string literal not displayed */
	NamePrefix           string          `protobuf:"bytes,3,opt,name=name_prefix,json=namePrefix,proto3" json:"name_prefix,omitempty"`
	DbBackupName         string          `protobuf:"bytes,4,opt,name=db_backup_name,json=dbBackupName,proto3" json:"db_backup_name,omitempty"`
	OplogBackupName      string          `protobuf:"bytes,5,opt,name=oplog_backup_name,json=oplogBackupName,proto3" json:"oplog_backup_name,omitempty"`
	DestinationDir       string          `protobuf:"bytes,6,opt,name=destination_dir,json=destinationDir,proto3" json:"destination_dir,omitempty"`
	CompressionType      CompressionType `` /* 137-byte string literal not displayed */
	Cypher               Cypher          `protobuf:"varint,8,opt,name=cypher,proto3,enum=messages.Cypher" json:"cypher,omitempty"`
	OplogStartTime       int64           `protobuf:"varint,9,opt,name=oplog_start_time,json=oplogStartTime,proto3" json:"oplog_start_time,omitempty"`
	Description          string          `protobuf:"bytes,10,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*StartBackup) Descriptor 

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

func (*StartBackup) GetBackupType 

func (m *StartBackup) GetBackupType() BackupType

func (*StartBackup) GetCompressionType 

func (m *StartBackup) GetCompressionType() CompressionType

func (*StartBackup) GetCypher 

func (m *StartBackup) GetCypher() Cypher

func (*StartBackup) GetDbBackupName 

func (m *StartBackup) GetDbBackupName() string

func (*StartBackup) GetDescription 

func (m *StartBackup) GetDescription() string

func (*StartBackup) GetDestinationDir 

func (m *StartBackup) GetDestinationDir() string

func (*StartBackup) GetDestinationType 

func (m *StartBackup) GetDestinationType() DestinationType

func (*StartBackup) GetNamePrefix 

func (m *StartBackup) GetNamePrefix() string

func (*StartBackup) GetOplogBackupName 

func (m *StartBackup) GetOplogBackupName() string

func (*StartBackup) GetOplogStartTime 

func (m *StartBackup) GetOplogStartTime() int64

func (*StartBackup) ProtoMessage 

func (*StartBackup) ProtoMessage()

func (*StartBackup) Reset 

func (m *StartBackup) Reset()

func (*StartBackup) String 

func (m *StartBackup) String() string

func (*StartBackup) XXX_DiscardUnknown 

func (m *StartBackup) XXX_DiscardUnknown()

func (*StartBackup) XXX_Marshal 

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

func (*StartBackup) XXX_Merge 

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

func (*StartBackup) XXX_Size 

func (m *StartBackup) XXX_Size() int

func (*StartBackup) XXX_Unmarshal 

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

type StartBalancer 

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

func (*StartBalancer) Descriptor 

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

func (*StartBalancer) ProtoMessage 

func (*StartBalancer) ProtoMessage()

func (*StartBalancer) Reset 

func (m *StartBalancer) Reset()

func (*StartBalancer) String 

func (m *StartBalancer) String() string

func (*StartBalancer) XXX_DiscardUnknown 

func (m *StartBalancer) XXX_DiscardUnknown()

func (*StartBalancer) XXX_Marshal 

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

func (*StartBalancer) XXX_Merge 

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

func (*StartBalancer) XXX_Size 

func (m *StartBalancer) XXX_Size() int

func (*StartBalancer) XXX_Unmarshal 

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

type Status 

type Status struct {
	RunningDbBackup      bool            `protobuf:"varint,1,opt,name=running_db_backup,json=runningDbBackup,proto3" json:"running_db_backup,omitempty"`
	RunningOplogBackup   bool            `protobuf:"varint,2,opt,name=running_oplog_backup,json=runningOplogBackup,proto3" json:"running_oplog_backup,omitempty"`
	RestoreStatus        RestoreStatus   `` /* 129-byte string literal not displayed */
	BackupType           BackupType      `protobuf:"varint,4,opt,name=backup_type,json=backupType,proto3,enum=messages.BackupType" json:"backup_type,omitempty"`
	BytesSent            uint64          `protobuf:"varint,5,opt,name=bytes_sent,json=bytesSent,proto3" json:"bytes_sent,omitempty"`
	LastOplogTs          int64           `protobuf:"varint,6,opt,name=last_oplog_ts,json=lastOplogTs,proto3" json:"last_oplog_ts,omitempty"`
	BackupCompleted      int64           `protobuf:"varint,7,opt,name=backup_completed,json=backupCompleted,proto3" json:"backup_completed,omitempty"`
	LastError            string          `protobuf:"bytes,8,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"`
	ReplicasetVersion    uint64          `protobuf:"varint,9,opt,name=replicaset_version,json=replicasetVersion,proto3" json:"replicaset_version,omitempty"`
	DestinationType      DestinationType `` /* 138-byte string literal not displayed */
	DestinationName      string          `protobuf:"bytes,11,opt,name=destination_name,json=destinationName,proto3" json:"destination_name,omitempty"`
	DestinationDir       string          `protobuf:"bytes,12,opt,name=destination_dir,json=destinationDir,proto3" json:"destination_dir,omitempty"`
	CompressionType      CompressionType `` /* 138-byte string literal not displayed */
	Cypher               Cypher          `protobuf:"varint,14,opt,name=cypher,proto3,enum=messages.Cypher" json:"cypher,omitempty"`
	StartOplogTs         int64           `protobuf:"varint,15,opt,name=start_oplog_ts,json=startOplogTs,proto3" json:"start_oplog_ts,omitempty"`
	IsPrimary            bool            `protobuf:"varint,16,opt,name=is_primary,json=isPrimary,proto3" json:"is_primary,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Status) Descriptor 

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

func (*Status) GetBackupCompleted 

func (m *Status) GetBackupCompleted() int64

func (*Status) GetBackupType 

func (m *Status) GetBackupType() BackupType

func (*Status) GetBytesSent 

func (m *Status) GetBytesSent() uint64

func (*Status) GetCompressionType 

func (m *Status) GetCompressionType() CompressionType

func (*Status) GetCypher 

func (m *Status) GetCypher() Cypher

func (*Status) GetDestinationDir 

func (m *Status) GetDestinationDir() string

func (*Status) GetDestinationName 

func (m *Status) GetDestinationName() string

func (*Status) GetDestinationType 

func (m *Status) GetDestinationType() DestinationType

func (*Status) GetIsPrimary 

func (m *Status) GetIsPrimary() bool

func (*Status) GetLastError 

func (m *Status) GetLastError() string

func (*Status) GetLastOplogTs 

func (m *Status) GetLastOplogTs() int64

func (*Status) GetReplicasetVersion 

func (m *Status) GetReplicasetVersion() uint64

func (*Status) GetRestoreStatus 

func (m *Status) GetRestoreStatus() RestoreStatus

func (*Status) GetRunningDbBackup 

func (m *Status) GetRunningDbBackup() bool

func (*Status) GetRunningOplogBackup 

func (m *Status) GetRunningOplogBackup() bool

func (*Status) GetStartOplogTs 

func (m *Status) GetStartOplogTs() int64

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) String 

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

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

func (*Status) XXX_Merge 

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

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

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

type StopBalancer 

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

func (*StopBalancer) Descriptor 

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

func (*StopBalancer) ProtoMessage 

func (*StopBalancer) ProtoMessage()

func (*StopBalancer) Reset 

func (m *StopBalancer) Reset()

func (*StopBalancer) String 

func (m *StopBalancer) String() string

func (*StopBalancer) XXX_DiscardUnknown 

func (m *StopBalancer) XXX_DiscardUnknown()

func (*StopBalancer) XXX_Marshal 

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

func (*StopBalancer) XXX_Merge 

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

func (*StopBalancer) XXX_Size 

func (m *StopBalancer) XXX_Size() int

func (*StopBalancer) XXX_Unmarshal 

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

type StopOplogTail 

type StopOplogTail struct {
	Ts                   int64    `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopOplogTail) Descriptor 

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

func (*StopOplogTail) GetTs 

func (m *StopOplogTail) GetTs() int64

func (*StopOplogTail) ProtoMessage 

func (*StopOplogTail) ProtoMessage()

func (*StopOplogTail) Reset 

func (m *StopOplogTail) Reset()

func (*StopOplogTail) String 

func (m *StopOplogTail) String() string

func (*StopOplogTail) XXX_DiscardUnknown 

func (m *StopOplogTail) XXX_DiscardUnknown()

func (*StopOplogTail) XXX_Marshal 

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

func (*StopOplogTail) XXX_Merge 

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

func (*StopOplogTail) XXX_Size 

func (m *StopOplogTail) XXX_Size() int

func (*StopOplogTail) XXX_Unmarshal 

func (m *StopOplogTail) 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.