esbak

package
v0.0.0-...-5357738 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_es_history_proto protoreflect.FileDescriptor
View Source 
var File_estask_proto protoreflect.FileDescriptor
View Source 
var File_proto_backupAgent_esbak_es_bak_proto protoreflect.FileDescriptor

Functions

func NewEsBakServiceEndpoints 

func NewEsBakServiceEndpoints() []*api.Endpoint

func NewEsHistoryServiceEndpoints 

func NewEsHistoryServiceEndpoints() []*api.Endpoint

func NewEsServiceEndpoints 

func NewEsServiceEndpoints() []*api.Endpoint

func RegisterEsBakServiceHandler 

func RegisterEsBakServiceHandler(s server.Server, hdlr EsBakServiceHandler, opts ...server.HandlerOption) error

func RegisterEsHistoryServiceHandler 

func RegisterEsHistoryServiceHandler(s server.Server, hdlr EsHistoryServiceHandler, opts ...server.HandlerOption) error

func RegisterEsServiceHandler 

func RegisterEsServiceHandler(s server.Server, hdlr EsServiceHandler, opts ...server.HandlerOption) error

Types

type ESHistoryIDInput 

type ESHistoryIDInput struct {
	ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

func (*ESHistoryIDInput) Descriptor deprecated 

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

Deprecated: Use ESHistoryIDInput.ProtoReflect.Descriptor instead.

func (*ESHistoryIDInput) GetID 

func (x *ESHistoryIDInput) GetID() int64

func (*ESHistoryIDInput) ProtoMessage 

func (*ESHistoryIDInput) ProtoMessage()

func (*ESHistoryIDInput) ProtoReflect 

func (x *ESHistoryIDInput) ProtoReflect() protoreflect.Message

func (*ESHistoryIDInput) Reset 

func (x *ESHistoryIDInput) Reset()

func (*ESHistoryIDInput) String 

func (x *ESHistoryIDInput) String() string

type ESHistoryListOutItem 

type ESHistoryListOutItem struct {

	// @inject_tag: json:"id"
	ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"id"`
	// @inject_tag: json:"task_id"
	TaskID int64 `protobuf:"varint,9,opt,name=TaskID,proto3" json:"task_id"`
	// @inject_tag: json:"uuid"
	UUID string `protobuf:"bytes,10,opt,name=UUID,proto3" json:"uuid"`
	// @inject_tag: json:"duration_in_millis"
	DurationInMillis int64 `protobuf:"varint,11,opt,name=DurationInMillis,proto3" json:"duration_in_millis"`
	// @inject_tag: json:"host"
	Host string `protobuf:"bytes,12,opt,name=Host,proto3" json:"host"`
	// @inject_tag: json:"snapshot"
	Snapshot string `protobuf:"bytes,2,opt,name=Snapshot,proto3" json:"snapshot"`
	// @inject_tag: json:"repository"
	Repository string `protobuf:"bytes,3,opt,name=Repository,proto3" json:"repository"`
	// @inject_tag: json:"indices"
	Indices string `protobuf:"bytes,4,opt,name=Indices,proto3" json:"indices"`
	// @inject_tag: json:"state"
	State string `protobuf:"bytes,5,opt,name=State,proto3" json:"state"`
	// @inject_tag: json:"start_time"
	StartTime string `protobuf:"bytes,6,opt,name=StartTime,proto3" json:"start_time"`
	// @inject_tag: json:"end_time"
	EndTime string `protobuf:"bytes,7,opt,name=EndTime,proto3" json:"end_time"`
	// @inject_tag: json:"message"
	Message string `protobuf:"bytes,8,opt,name=Message,proto3" json:"message"`
	// @inject_tag: json:"status"
	Status int64 `protobuf:"varint,13,opt,name=Status,proto3" json:"status"`
	// contains filtered or unexported fields
}

func (*ESHistoryListOutItem) Descriptor deprecated 

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

Deprecated: Use ESHistoryListOutItem.ProtoReflect.Descriptor instead.

func (*ESHistoryListOutItem) GetDurationInMillis 

func (x *ESHistoryListOutItem) GetDurationInMillis() int64

func (*ESHistoryListOutItem) GetEndTime 

func (x *ESHistoryListOutItem) GetEndTime() string

func (*ESHistoryListOutItem) GetHost 

func (x *ESHistoryListOutItem) GetHost() string

func (*ESHistoryListOutItem) GetID 

func (x *ESHistoryListOutItem) GetID() int64

func (*ESHistoryListOutItem) GetIndices 

func (x *ESHistoryListOutItem) GetIndices() string

func (*ESHistoryListOutItem) GetMessage 

func (x *ESHistoryListOutItem) GetMessage() string

func (*ESHistoryListOutItem) GetRepository 

func (x *ESHistoryListOutItem) GetRepository() string

func (*ESHistoryListOutItem) GetSnapshot 

func (x *ESHistoryListOutItem) GetSnapshot() string

func (*ESHistoryListOutItem) GetStartTime 

func (x *ESHistoryListOutItem) GetStartTime() string

func (*ESHistoryListOutItem) GetState 

func (x *ESHistoryListOutItem) GetState() string

func (*ESHistoryListOutItem) GetStatus 

func (x *ESHistoryListOutItem) GetStatus() int64

func (*ESHistoryListOutItem) GetTaskID 

func (x *ESHistoryListOutItem) GetTaskID() int64

func (*ESHistoryListOutItem) GetUUID 

func (x *ESHistoryListOutItem) GetUUID() string

func (*ESHistoryListOutItem) ProtoMessage 

func (*ESHistoryListOutItem) ProtoMessage()

func (*ESHistoryListOutItem) ProtoReflect 

func (x *ESHistoryListOutItem) ProtoReflect() protoreflect.Message

func (*ESHistoryListOutItem) Reset 

func (x *ESHistoryListOutItem) Reset()

func (*ESHistoryListOutItem) String 

func (x *ESHistoryListOutItem) String() string

type ESHistoryListOutput 

type ESHistoryListOutput struct {

	// @inject_tag: json:"total"
	Total int64 `protobuf:"varint,1,opt,name=Total,proto3" json:"total"`
	// @inject_tag: json:"list"
	EsHistoryListOutItem []*ESHistoryListOutItem `protobuf:"bytes,2,rep,name=esHistoryListOutItem,proto3" json:"list"`
	// @inject_tag: json:"page_no"
	PageNo int64 `protobuf:"varint,3,opt,name=PageNo,proto3" json:"page_no"`
	// @inject_tag: json:"page_size"
	PageSize int64 `protobuf:"varint,4,opt,name=PageSize,proto3" json:"page_size"`
	// contains filtered or unexported fields
}

func (*ESHistoryListOutput) Descriptor deprecated 

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

Deprecated: Use ESHistoryListOutput.ProtoReflect.Descriptor instead.

func (*ESHistoryListOutput) GetEsHistoryListOutItem 

func (x *ESHistoryListOutput) GetEsHistoryListOutItem() []*ESHistoryListOutItem

func (*ESHistoryListOutput) GetPageNo 

func (x *ESHistoryListOutput) GetPageNo() int64

func (*ESHistoryListOutput) GetPageSize 

func (x *ESHistoryListOutput) GetPageSize() int64

func (*ESHistoryListOutput) GetTotal 

func (x *ESHistoryListOutput) GetTotal() int64

func (*ESHistoryListOutput) ProtoMessage 

func (*ESHistoryListOutput) ProtoMessage()

func (*ESHistoryListOutput) ProtoReflect 

func (x *ESHistoryListOutput) ProtoReflect() protoreflect.Message

func (*ESHistoryListOutput) Reset 

func (x *ESHistoryListOutput) Reset()

func (*ESHistoryListOutput) String 

func (x *ESHistoryListOutput) String() string

type ESHistoryOneMessage 

type ESHistoryOneMessage struct {
	Message string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	OK      bool   `protobuf:"varint,2,opt,name=OK,proto3" json:"OK,omitempty"`
	// contains filtered or unexported fields
}

func (*ESHistoryOneMessage) Descriptor deprecated 

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

Deprecated: Use ESHistoryOneMessage.ProtoReflect.Descriptor instead.

func (*ESHistoryOneMessage) GetMessage 

func (x *ESHistoryOneMessage) GetMessage() string

func (*ESHistoryOneMessage) GetOK 

func (x *ESHistoryOneMessage) GetOK() bool

func (*ESHistoryOneMessage) ProtoMessage 

func (*ESHistoryOneMessage) ProtoMessage()

func (*ESHistoryOneMessage) ProtoReflect 

func (x *ESHistoryOneMessage) ProtoReflect() protoreflect.Message

func (*ESHistoryOneMessage) Reset 

func (x *ESHistoryOneMessage) Reset()

func (*ESHistoryOneMessage) String 

func (x *ESHistoryOneMessage) String() string

type ESTaskDetail 

type ESTaskDetail struct {

	// @inject_tag: json:"backup_cycle"
	BackupCycle string `protobuf:"bytes,1,opt,name=BackupCycle,proto3" json:"backup_cycle"`
	// @inject_tag: json:"keep_number"
	KeepNumber int64 `protobuf:"varint,2,opt,name=KeepNumber,proto3" json:"keep_number"`
	// @inject_tag: json:"status"
	Status int64 `protobuf:"varint,3,opt,name=Status,proto3" json:"status"`
	// @inject_tag: json:"create_at"
	CreateAt string `protobuf:"bytes,4,opt,name=CreateAt,proto3" json:"create_at"`
	// contains filtered or unexported fields
}

func (*ESTaskDetail) Descriptor deprecated 

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

Deprecated: Use ESTaskDetail.ProtoReflect.Descriptor instead.

func (*ESTaskDetail) GetBackupCycle 

func (x *ESTaskDetail) GetBackupCycle() string

func (*ESTaskDetail) GetCreateAt 

func (x *ESTaskDetail) GetCreateAt() string

func (*ESTaskDetail) GetKeepNumber 

func (x *ESTaskDetail) GetKeepNumber() int64

func (*ESTaskDetail) GetStatus 

func (x *ESTaskDetail) GetStatus() int64

func (*ESTaskDetail) ProtoMessage 

func (*ESTaskDetail) ProtoMessage()

func (*ESTaskDetail) ProtoReflect 

func (x *ESTaskDetail) ProtoReflect() protoreflect.Message

func (*ESTaskDetail) Reset 

func (x *ESTaskDetail) Reset()

func (*ESTaskDetail) String 

func (x *ESTaskDetail) String() string

type EsBakOneMessage 

type EsBakOneMessage struct {
	Message string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	OK      bool   `protobuf:"varint,2,opt,name=OK,proto3" json:"OK,omitempty"`
	// contains filtered or unexported fields
}

func (*EsBakOneMessage) Descriptor deprecated 

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

Deprecated: Use EsBakOneMessage.ProtoReflect.Descriptor instead.

func (*EsBakOneMessage) GetMessage 

func (x *EsBakOneMessage) GetMessage() string

func (*EsBakOneMessage) GetOK 

func (x *EsBakOneMessage) GetOK() bool

func (*EsBakOneMessage) ProtoMessage 

func (*EsBakOneMessage) ProtoMessage()

func (*EsBakOneMessage) ProtoReflect 

func (x *EsBakOneMessage) ProtoReflect() protoreflect.Message

func (*EsBakOneMessage) Reset 

func (x *EsBakOneMessage) Reset()

func (*EsBakOneMessage) String 

func (x *EsBakOneMessage) String() string

type EsBakService 

type EsBakService interface {
	Start(ctx context.Context, in *StartEsBakInput, opts ...client.CallOption) (*EsBakOneMessage, error)
	Stop(ctx context.Context, in *StopEsBakInput, opts ...client.CallOption) (*EsBakOneMessage, error)
}

func NewEsBakService 

func NewEsBakService(name string, c client.Client) EsBakService

type EsBakServiceHandler 

type EsBakServiceHandler interface {
	Start(context.Context, *StartEsBakInput, *EsBakOneMessage) error
	Stop(context.Context, *StopEsBakInput, *EsBakOneMessage) error
}

type EsBakTaskADDInput 

type EsBakTaskADDInput struct {
	HostID      int64  `protobuf:"varint,1,opt,name=HostID,proto3" json:"HostID,omitempty"`
	BackupCycle string `protobuf:"bytes,2,opt,name=BackupCycle,proto3" json:"BackupCycle,omitempty"`
	KeepNumber  int64  `protobuf:"varint,3,opt,name=KeepNumber,proto3" json:"KeepNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*EsBakTaskADDInput) Descriptor deprecated 

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

Deprecated: Use EsBakTaskADDInput.ProtoReflect.Descriptor instead.

func (*EsBakTaskADDInput) GetBackupCycle 

func (x *EsBakTaskADDInput) GetBackupCycle() string

func (*EsBakTaskADDInput) GetHostID 

func (x *EsBakTaskADDInput) GetHostID() int64

func (*EsBakTaskADDInput) GetKeepNumber 

func (x *EsBakTaskADDInput) GetKeepNumber() int64

func (*EsBakTaskADDInput) ProtoMessage 

func (*EsBakTaskADDInput) ProtoMessage()

func (*EsBakTaskADDInput) ProtoReflect 

func (x *EsBakTaskADDInput) ProtoReflect() protoreflect.Message

func (*EsBakTaskADDInput) Reset 

func (x *EsBakTaskADDInput) Reset()

func (*EsBakTaskADDInput) String 

func (x *EsBakTaskADDInput) String() string

type EsBakTaskUpdateInput 

type EsBakTaskUpdateInput struct {
	ID          int64  `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	HostID      int64  `protobuf:"varint,2,opt,name=HostID,proto3" json:"HostID,omitempty"`
	BackupCycle string `protobuf:"bytes,3,opt,name=BackupCycle,proto3" json:"BackupCycle,omitempty"`
	KeepNumber  int64  `protobuf:"varint,4,opt,name=KeepNumber,proto3" json:"KeepNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*EsBakTaskUpdateInput) Descriptor deprecated 

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

Deprecated: Use EsBakTaskUpdateInput.ProtoReflect.Descriptor instead.

func (*EsBakTaskUpdateInput) GetBackupCycle 

func (x *EsBakTaskUpdateInput) GetBackupCycle() string

func (*EsBakTaskUpdateInput) GetHostID 

func (x *EsBakTaskUpdateInput) GetHostID() int64

func (*EsBakTaskUpdateInput) GetID 

func (x *EsBakTaskUpdateInput) GetID() int64

func (*EsBakTaskUpdateInput) GetKeepNumber 

func (x *EsBakTaskUpdateInput) GetKeepNumber() int64

func (*EsBakTaskUpdateInput) ProtoMessage 

func (*EsBakTaskUpdateInput) ProtoMessage()

func (*EsBakTaskUpdateInput) ProtoReflect 

func (x *EsBakTaskUpdateInput) ProtoReflect() protoreflect.Message

func (*EsBakTaskUpdateInput) Reset 

func (x *EsBakTaskUpdateInput) Reset()

func (*EsBakTaskUpdateInput) String 

func (x *EsBakTaskUpdateInput) String() string

type EsHistoryDetailOut 

type EsHistoryDetailOut struct {

	// @inject_tag: json:"es_host_detail"
	EsHostDetail *EsHostDetail `protobuf:"bytes,1,opt,name=EsHostDetail,proto3" json:"es_host_detail"`
	// @inject_tag: json:"es_task_detail"
	ESTaskDetail *ESTaskDetail `protobuf:"bytes,2,opt,name=ESTaskDetail,proto3" json:"es_task_detail"`
	// @inject_tag: json:"es_history_detail"
	EsHistoryDetail *ESHistoryListOutItem `protobuf:"bytes,3,opt,name=EsHistoryDetail,proto3" json:"es_history_detail"`
	// contains filtered or unexported fields
}

func (*EsHistoryDetailOut) Descriptor deprecated 

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

Deprecated: Use EsHistoryDetailOut.ProtoReflect.Descriptor instead.

func (*EsHistoryDetailOut) GetESTaskDetail 

func (x *EsHistoryDetailOut) GetESTaskDetail() *ESTaskDetail

func (*EsHistoryDetailOut) GetEsHistoryDetail 

func (x *EsHistoryDetailOut) GetEsHistoryDetail() *ESHistoryListOutItem

func (*EsHistoryDetailOut) GetEsHostDetail 

func (x *EsHistoryDetailOut) GetEsHostDetail() *EsHostDetail

func (*EsHistoryDetailOut) ProtoMessage 

func (*EsHistoryDetailOut) ProtoMessage()

func (*EsHistoryDetailOut) ProtoReflect 

func (x *EsHistoryDetailOut) ProtoReflect() protoreflect.Message

func (*EsHistoryDetailOut) Reset 

func (x *EsHistoryDetailOut) Reset()

func (*EsHistoryDetailOut) String 

func (x *EsHistoryDetailOut) String() string

type EsHistoryEmpty 

type EsHistoryEmpty struct {
	// contains filtered or unexported fields
}

func (*EsHistoryEmpty) Descriptor deprecated 

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

Deprecated: Use EsHistoryEmpty.ProtoReflect.Descriptor instead.

func (*EsHistoryEmpty) ProtoMessage 

func (*EsHistoryEmpty) ProtoMessage()

func (*EsHistoryEmpty) ProtoReflect 

func (x *EsHistoryEmpty) ProtoReflect() protoreflect.Message

func (*EsHistoryEmpty) Reset 

func (x *EsHistoryEmpty) Reset()

func (*EsHistoryEmpty) String 

func (x *EsHistoryEmpty) String() string

type EsHistoryNumInfoOut 

type EsHistoryNumInfoOut struct {

	// @inject_tag: json:"all_nums"
	AllNums int64 `protobuf:"varint,1,opt,name=AllNums,proto3" json:"all_nums"`
	// @inject_tag: json:"week_nums"
	WeekNums int64 `protobuf:"varint,2,opt,name=WeekNums,proto3" json:"week_nums"`
	// @inject_tag: json:"fail_nums"
	FailNums int64 `protobuf:"varint,3,opt,name=FailNums,proto3" json:"fail_nums"`
	// contains filtered or unexported fields
}

获取历史记录顶部数量信息

func (*EsHistoryNumInfoOut) Descriptor deprecated 

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

Deprecated: Use EsHistoryNumInfoOut.ProtoReflect.Descriptor instead.

func (*EsHistoryNumInfoOut) GetAllNums 

func (x *EsHistoryNumInfoOut) GetAllNums() int64

func (*EsHistoryNumInfoOut) GetFailNums 

func (x *EsHistoryNumInfoOut) GetFailNums() int64

func (*EsHistoryNumInfoOut) GetWeekNums 

func (x *EsHistoryNumInfoOut) GetWeekNums() int64

func (*EsHistoryNumInfoOut) ProtoMessage 

func (*EsHistoryNumInfoOut) ProtoMessage()

func (*EsHistoryNumInfoOut) ProtoReflect 

func (x *EsHistoryNumInfoOut) ProtoReflect() protoreflect.Message

func (*EsHistoryNumInfoOut) Reset 

func (x *EsHistoryNumInfoOut) Reset()

func (*EsHistoryNumInfoOut) String 

func (x *EsHistoryNumInfoOut) String() string

type EsHistoryService 

type EsHistoryService interface {
	GetEsHistoryList(ctx context.Context, in *GetEsHistoryListInput, opts ...client.CallOption) (*ESHistoryListOutput, error)
	DeleteESHistory(ctx context.Context, in *ESHistoryIDInput, opts ...client.CallOption) (*ESHistoryOneMessage, error)
	GetEsHistoryDetail(ctx context.Context, in *ESHistoryIDInput, opts ...client.CallOption) (*EsHistoryDetailOut, error)
	GetEsHistoryNumInfo(ctx context.Context, in *EsHistoryEmpty, opts ...client.CallOption) (*EsHistoryNumInfoOut, error)
}

func NewEsHistoryService 

func NewEsHistoryService(name string, c client.Client) EsHistoryService

type EsHistoryServiceHandler 

type EsHistoryServiceHandler interface {
	GetEsHistoryList(context.Context, *GetEsHistoryListInput, *ESHistoryListOutput) error
	DeleteESHistory(context.Context, *ESHistoryIDInput, *ESHistoryOneMessage) error
	GetEsHistoryDetail(context.Context, *ESHistoryIDInput, *EsHistoryDetailOut) error
	GetEsHistoryNumInfo(context.Context, *EsHistoryEmpty, *EsHistoryNumInfoOut) error
}

type EsHostDetail 

type EsHostDetail struct {

	// @inject_tag: json:"host_id"
	HostID int64 `protobuf:"varint,4,opt,name=HostID,proto3" json:"host_id"`
	// @inject_tag: json:"host"
	Host string `protobuf:"bytes,1,opt,name=Host,proto3" json:"host"`
	// @inject_tag: json:"create_at"
	CreateAt string `protobuf:"bytes,2,opt,name=CreateAt,proto3" json:"create_at"`
	// @inject_tag: json:"update_at"
	UpdateAt string `protobuf:"bytes,3,opt,name=UpdateAt,proto3" json:"update_at"`
	// @inject_tag: json:"status"
	Status int64 `protobuf:"varint,5,opt,name=Status,proto3" json:"status"`
	// contains filtered or unexported fields
}

查看历史记录详情

func (*EsHostDetail) Descriptor deprecated 

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

Deprecated: Use EsHostDetail.ProtoReflect.Descriptor instead.

func (*EsHostDetail) GetCreateAt 

func (x *EsHostDetail) GetCreateAt() string

func (*EsHostDetail) GetHost 

func (x *EsHostDetail) GetHost() string

func (*EsHostDetail) GetHostID 

func (x *EsHostDetail) GetHostID() int64

func (*EsHostDetail) GetStatus 

func (x *EsHostDetail) GetStatus() int64

func (*EsHostDetail) GetUpdateAt 

func (x *EsHostDetail) GetUpdateAt() string

func (*EsHostDetail) ProtoMessage 

func (*EsHostDetail) ProtoMessage()

func (*EsHostDetail) ProtoReflect 

func (x *EsHostDetail) ProtoReflect() protoreflect.Message

func (*EsHostDetail) Reset 

func (x *EsHostDetail) Reset()

func (*EsHostDetail) String 

func (x *EsHostDetail) String() string

type EsOneMessage 

type EsOneMessage struct {
	Message string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	OK      bool   `protobuf:"varint,2,opt,name=OK,proto3" json:"OK,omitempty"`
	// contains filtered or unexported fields
}

func (*EsOneMessage) Descriptor deprecated 

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

Deprecated: Use EsOneMessage.ProtoReflect.Descriptor instead.

func (*EsOneMessage) GetMessage 

func (x *EsOneMessage) GetMessage() string

func (*EsOneMessage) GetOK 

func (x *EsOneMessage) GetOK() bool

func (*EsOneMessage) ProtoMessage 

func (*EsOneMessage) ProtoMessage()

func (*EsOneMessage) ProtoReflect 

func (x *EsOneMessage) ProtoReflect() protoreflect.Message

func (*EsOneMessage) Reset 

func (x *EsOneMessage) Reset()

func (*EsOneMessage) String 

func (x *EsOneMessage) String() string

type EsService 

type EsService interface {
	TaskAdd(ctx context.Context, in *EsBakTaskADDInput, opts ...client.CallOption) (*EsOneMessage, error)
	TaskDelete(ctx context.Context, in *EsTaskIDInput, opts ...client.CallOption) (*EsOneMessage, error)
	TaskRestore(ctx context.Context, in *EsTaskIDInput, opts ...client.CallOption) (*EsOneMessage, error)
	TaskUpdate(ctx context.Context, in *EsBakTaskUpdateInput, opts ...client.CallOption) (*EsOneMessage, error)
	GetTaskList(ctx context.Context, in *EsTaskListInput, opts ...client.CallOption) (*EsTaskListOutPut, error)
	GetTaskDetail(ctx context.Context, in *EsTaskIDInput, opts ...client.CallOption) (*EsTaskDetailOutPut, error)
}

func NewEsService 

func NewEsService(name string, c client.Client) EsService

type EsServiceHandler 

type EsServiceHandler interface {
	TaskAdd(context.Context, *EsBakTaskADDInput, *EsOneMessage) error
	TaskDelete(context.Context, *EsTaskIDInput, *EsOneMessage) error
	TaskRestore(context.Context, *EsTaskIDInput, *EsOneMessage) error
	TaskUpdate(context.Context, *EsBakTaskUpdateInput, *EsOneMessage) error
	GetTaskList(context.Context, *EsTaskListInput, *EsTaskListOutPut) error
	GetTaskDetail(context.Context, *EsTaskIDInput, *EsTaskDetailOutPut) error
}

type EsTaskDetailOutPut 

type EsTaskDetailOutPut struct {
	EsTaskInfo *EsTaskInfo `protobuf:"bytes,1,opt,name=esTaskInfo,proto3" json:"esTaskInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*EsTaskDetailOutPut) Descriptor deprecated 

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

Deprecated: Use EsTaskDetailOutPut.ProtoReflect.Descriptor instead.

func (*EsTaskDetailOutPut) GetEsTaskInfo 

func (x *EsTaskDetailOutPut) GetEsTaskInfo() *EsTaskInfo

func (*EsTaskDetailOutPut) ProtoMessage 

func (*EsTaskDetailOutPut) ProtoMessage()

func (*EsTaskDetailOutPut) ProtoReflect 

func (x *EsTaskDetailOutPut) ProtoReflect() protoreflect.Message

func (*EsTaskDetailOutPut) Reset 

func (x *EsTaskDetailOutPut) Reset()

func (*EsTaskDetailOutPut) String 

func (x *EsTaskDetailOutPut) String() string

type EsTaskIDInput 

type EsTaskIDInput struct {
	ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

func (*EsTaskIDInput) Descriptor deprecated 

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

Deprecated: Use EsTaskIDInput.ProtoReflect.Descriptor instead.

func (*EsTaskIDInput) GetID 

func (x *EsTaskIDInput) GetID() int64

func (*EsTaskIDInput) ProtoMessage 

func (*EsTaskIDInput) ProtoMessage()

func (*EsTaskIDInput) ProtoReflect 

func (x *EsTaskIDInput) ProtoReflect() protoreflect.Message

func (*EsTaskIDInput) Reset 

func (x *EsTaskIDInput) Reset()

func (*EsTaskIDInput) String 

func (x *EsTaskIDInput) String() string

type EsTaskInfo 

type EsTaskInfo struct {
	EsHost      string `protobuf:"bytes,1,opt,name=EsHost,proto3" json:"EsHost,omitempty"`
	EsUser      string `protobuf:"bytes,2,opt,name=EsUser,proto3" json:"EsUser,omitempty"`
	EsPassword  string `protobuf:"bytes,3,opt,name=EsPassword,proto3" json:"EsPassword,omitempty"`
	BackupCycle string `protobuf:"bytes,4,opt,name=BackupCycle,proto3" json:"BackupCycle,omitempty"`
	KeepNumber  int64  `protobuf:"varint,5,opt,name=KeepNumber,proto3" json:"KeepNumber,omitempty"`
	Status      bool   `protobuf:"varint,7,opt,name=Status,proto3" json:"Status,omitempty"`
	CreateAt    string `protobuf:"bytes,8,opt,name=CreateAt,proto3" json:"CreateAt,omitempty"`
	// contains filtered or unexported fields
}

func (*EsTaskInfo) Descriptor deprecated 

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

Deprecated: Use EsTaskInfo.ProtoReflect.Descriptor instead.

func (*EsTaskInfo) GetBackupCycle 

func (x *EsTaskInfo) GetBackupCycle() string

func (*EsTaskInfo) GetCreateAt 

func (x *EsTaskInfo) GetCreateAt() string

func (*EsTaskInfo) GetEsHost 

func (x *EsTaskInfo) GetEsHost() string

func (*EsTaskInfo) GetEsPassword 

func (x *EsTaskInfo) GetEsPassword() string

func (*EsTaskInfo) GetEsUser 

func (x *EsTaskInfo) GetEsUser() string

func (*EsTaskInfo) GetKeepNumber 

func (x *EsTaskInfo) GetKeepNumber() int64

func (*EsTaskInfo) GetStatus 

func (x *EsTaskInfo) GetStatus() bool

func (*EsTaskInfo) ProtoMessage 

func (*EsTaskInfo) ProtoMessage()

func (*EsTaskInfo) ProtoReflect 

func (x *EsTaskInfo) ProtoReflect() protoreflect.Message

func (*EsTaskInfo) Reset 

func (x *EsTaskInfo) Reset()

func (*EsTaskInfo) String 

func (x *EsTaskInfo) String() string

type EsTaskListInput 

type EsTaskListInput struct {
	HostID   int64  `protobuf:"varint,1,opt,name=HostID,proto3" json:"HostID,omitempty"`
	Info     string `protobuf:"bytes,2,opt,name=Info,proto3" json:"Info,omitempty"`
	PageNo   int64  `protobuf:"varint,3,opt,name=PageNo,proto3" json:"PageNo,omitempty"`
	PageSize int64  `protobuf:"varint,4,opt,name=PageSize,proto3" json:"PageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*EsTaskListInput) Descriptor deprecated 

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

Deprecated: Use EsTaskListInput.ProtoReflect.Descriptor instead.

func (*EsTaskListInput) GetHostID 

func (x *EsTaskListInput) GetHostID() int64

func (*EsTaskListInput) GetInfo 

func (x *EsTaskListInput) GetInfo() string

func (*EsTaskListInput) GetPageNo 

func (x *EsTaskListInput) GetPageNo() int64

func (*EsTaskListInput) GetPageSize 

func (x *EsTaskListInput) GetPageSize() int64

func (*EsTaskListInput) ProtoMessage 

func (*EsTaskListInput) ProtoMessage()

func (*EsTaskListInput) ProtoReflect 

func (x *EsTaskListInput) ProtoReflect() protoreflect.Message

func (*EsTaskListInput) Reset 

func (x *EsTaskListInput) Reset()

func (*EsTaskListInput) String 

func (x *EsTaskListInput) String() string

type EsTaskListOutPut 

type EsTaskListOutPut struct {

	// @inject_tag: json:"total"
	Total int64 `protobuf:"varint,1,opt,name=Total,proto3" json:"total"`
	// @inject_tag: json:"list"
	EsTaskListOutPutItem []*EsTaskListOutPutItem `protobuf:"bytes,2,rep,name=esTaskListOutPutItem,proto3" json:"list"`
	// @inject_tag: json:"page_no"
	PageNo int64 `protobuf:"varint,3,opt,name=PageNo,proto3" json:"page_no"`
	// @inject_tag: json:"page_size"
	PageSize int64 `protobuf:"varint,4,opt,name=PageSize,proto3" json:"page_size"`
	// contains filtered or unexported fields
}

func (*EsTaskListOutPut) Descriptor deprecated 

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

Deprecated: Use EsTaskListOutPut.ProtoReflect.Descriptor instead.

func (*EsTaskListOutPut) GetEsTaskListOutPutItem 

func (x *EsTaskListOutPut) GetEsTaskListOutPutItem() []*EsTaskListOutPutItem

func (*EsTaskListOutPut) GetPageNo 

func (x *EsTaskListOutPut) GetPageNo() int64

func (*EsTaskListOutPut) GetPageSize 

func (x *EsTaskListOutPut) GetPageSize() int64

func (*EsTaskListOutPut) GetTotal 

func (x *EsTaskListOutPut) GetTotal() int64

func (*EsTaskListOutPut) ProtoMessage 

func (*EsTaskListOutPut) ProtoMessage()

func (*EsTaskListOutPut) ProtoReflect 

func (x *EsTaskListOutPut) ProtoReflect() protoreflect.Message

func (*EsTaskListOutPut) Reset 

func (x *EsTaskListOutPut) Reset()

func (*EsTaskListOutPut) String 

func (x *EsTaskListOutPut) String() string

type EsTaskListOutPutItem 

type EsTaskListOutPutItem struct {

	// @inject_tag: json:"id"
	ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"id"`
	// @inject_tag: json:"es_host"
	EsHost string `protobuf:"bytes,2,opt,name=EsHost,proto3" json:"es_host"`
	// @inject_tag: json:"backup_cycle"
	BackupCycle string `protobuf:"bytes,5,opt,name=BackupCycle,proto3" json:"backup_cycle"`
	// @inject_tag: json:"keep_number"
	KeepNumber int64 `protobuf:"varint,6,opt,name=KeepNumber,proto3" json:"keep_number"`
	// @inject_tag: json:"status"
	Status bool `protobuf:"varint,7,opt,name=Status,proto3" json:"status"`
	// @inject_tag: json:"create_at"
	CreateAt string `protobuf:"bytes,8,opt,name=CreateAt,proto3" json:"create_at"`
	// contains filtered or unexported fields
}

func (*EsTaskListOutPutItem) Descriptor deprecated 

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

Deprecated: Use EsTaskListOutPutItem.ProtoReflect.Descriptor instead.

func (*EsTaskListOutPutItem) GetBackupCycle 

func (x *EsTaskListOutPutItem) GetBackupCycle() string

func (*EsTaskListOutPutItem) GetCreateAt 

func (x *EsTaskListOutPutItem) GetCreateAt() string

func (*EsTaskListOutPutItem) GetEsHost 

func (x *EsTaskListOutPutItem) GetEsHost() string

func (*EsTaskListOutPutItem) GetID 

func (x *EsTaskListOutPutItem) GetID() int64

func (*EsTaskListOutPutItem) GetKeepNumber 

func (x *EsTaskListOutPutItem) GetKeepNumber() int64

func (*EsTaskListOutPutItem) GetStatus 

func (x *EsTaskListOutPutItem) GetStatus() bool

func (*EsTaskListOutPutItem) ProtoMessage 

func (*EsTaskListOutPutItem) ProtoMessage()

func (*EsTaskListOutPutItem) ProtoReflect 

func (x *EsTaskListOutPutItem) ProtoReflect() protoreflect.Message

func (*EsTaskListOutPutItem) Reset 

func (x *EsTaskListOutPutItem) Reset()

func (*EsTaskListOutPutItem) String 

func (x *EsTaskListOutPutItem) String() string

type GetEsHistoryListInput 

type GetEsHistoryListInput struct {
	Info      string `protobuf:"bytes,1,opt,name=Info,proto3" json:"Info,omitempty"`
	PageNo    int64  `protobuf:"varint,2,opt,name=PageNo,proto3" json:"PageNo,omitempty"`
	PageSize  int64  `protobuf:"varint,3,opt,name=PageSize,proto3" json:"PageSize,omitempty"`
	SortField string `protobuf:"bytes,5,opt,name=SortField,proto3" json:"SortField,omitempty"`
	SortOrder string `protobuf:"bytes,6,opt,name=SortOrder,proto3" json:"SortOrder,omitempty"`
	Status    string `protobuf:"bytes,7,opt,name=Status,proto3" json:"Status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEsHistoryListInput) Descriptor deprecated 

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

Deprecated: Use GetEsHistoryListInput.ProtoReflect.Descriptor instead.

func (*GetEsHistoryListInput) GetInfo 

func (x *GetEsHistoryListInput) GetInfo() string

func (*GetEsHistoryListInput) GetPageNo 

func (x *GetEsHistoryListInput) GetPageNo() int64

func (*GetEsHistoryListInput) GetPageSize 

func (x *GetEsHistoryListInput) GetPageSize() int64

func (*GetEsHistoryListInput) GetSortField 

func (x *GetEsHistoryListInput) GetSortField() string

func (*GetEsHistoryListInput) GetSortOrder 

func (x *GetEsHistoryListInput) GetSortOrder() string

func (*GetEsHistoryListInput) GetStatus 

func (x *GetEsHistoryListInput) GetStatus() string

func (*GetEsHistoryListInput) ProtoMessage 

func (*GetEsHistoryListInput) ProtoMessage()

func (*GetEsHistoryListInput) ProtoReflect 

func (x *GetEsHistoryListInput) ProtoReflect() protoreflect.Message

func (*GetEsHistoryListInput) Reset 

func (x *GetEsHistoryListInput) Reset()

func (*GetEsHistoryListInput) String 

func (x *GetEsHistoryListInput) String() string

type StartEsBakInput 

type StartEsBakInput struct {
	TaskID int64 `protobuf:"varint,1,opt,name=TaskID,proto3" json:"TaskID,omitempty"`
	// contains filtered or unexported fields
}

func (*StartEsBakInput) Descriptor deprecated 

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

Deprecated: Use StartEsBakInput.ProtoReflect.Descriptor instead.

func (*StartEsBakInput) GetTaskID 

func (x *StartEsBakInput) GetTaskID() int64

func (*StartEsBakInput) ProtoMessage 

func (*StartEsBakInput) ProtoMessage()

func (*StartEsBakInput) ProtoReflect 

func (x *StartEsBakInput) ProtoReflect() protoreflect.Message

func (*StartEsBakInput) Reset 

func (x *StartEsBakInput) Reset()

func (*StartEsBakInput) String 

func (x *StartEsBakInput) String() string

type StopEsBakInput 

type StopEsBakInput struct {
	TaskID int64 `protobuf:"varint,1,opt,name=TaskID,proto3" json:"TaskID,omitempty"`
	// contains filtered or unexported fields
}

func (*StopEsBakInput) Descriptor deprecated 

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

Deprecated: Use StopEsBakInput.ProtoReflect.Descriptor instead.

func (*StopEsBakInput) GetTaskID 

func (x *StopEsBakInput) GetTaskID() int64

func (*StopEsBakInput) ProtoMessage 

func (*StopEsBakInput) ProtoMessage()

func (*StopEsBakInput) ProtoReflect 

func (x *StopEsBakInput) ProtoReflect() protoreflect.Message

func (*StopEsBakInput) Reset 

func (x *StopEsBakInput) Reset()

func (*StopEsBakInput) String 

func (x *StopEsBakInput) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.