recover_data

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Jun 15, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthRecoverdatapb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRecoverdatapb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRecoverdatapb = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterRecoverDataServer

func RegisterRecoverDataServer(s *grpc.Server, srv RecoverDataServer)

Types

type Error

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

func (*Error) Descriptor

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

func (*Error) GetMsg

func (m *Error) GetMsg() string

func (*Error) Marshal

func (m *Error) Marshal() (dAtA []byte, err error)

func (*Error) MarshalTo

func (m *Error) MarshalTo(dAtA []byte) (int, error)

func (*Error) MarshalToSizedBuffer

func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) Reset

func (m *Error) Reset()

func (*Error) Size

func (m *Error) Size() (n int)

func (*Error) String

func (m *Error) String() string

func (*Error) Unmarshal

func (m *Error) Unmarshal(dAtA []byte) error

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 ReadRegionMetaRequest

type ReadRegionMetaRequest struct {
	StoreId              uint64   `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

request to read region meata from a store

func (*ReadRegionMetaRequest) Descriptor

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

func (*ReadRegionMetaRequest) GetStoreId

func (m *ReadRegionMetaRequest) GetStoreId() uint64

func (*ReadRegionMetaRequest) Marshal

func (m *ReadRegionMetaRequest) Marshal() (dAtA []byte, err error)

func (*ReadRegionMetaRequest) MarshalTo

func (m *ReadRegionMetaRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReadRegionMetaRequest) MarshalToSizedBuffer

func (m *ReadRegionMetaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadRegionMetaRequest) ProtoMessage

func (*ReadRegionMetaRequest) ProtoMessage()

func (*ReadRegionMetaRequest) Reset

func (m *ReadRegionMetaRequest) Reset()

func (*ReadRegionMetaRequest) Size

func (m *ReadRegionMetaRequest) Size() (n int)

func (*ReadRegionMetaRequest) String

func (m *ReadRegionMetaRequest) String() string

func (*ReadRegionMetaRequest) Unmarshal

func (m *ReadRegionMetaRequest) Unmarshal(dAtA []byte) error

func (*ReadRegionMetaRequest) XXX_DiscardUnknown

func (m *ReadRegionMetaRequest) XXX_DiscardUnknown()

func (*ReadRegionMetaRequest) XXX_Marshal

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

func (*ReadRegionMetaRequest) XXX_Merge

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

func (*ReadRegionMetaRequest) XXX_Size

func (m *ReadRegionMetaRequest) XXX_Size() int

func (*ReadRegionMetaRequest) XXX_Unmarshal

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

type RecoverDataClient

type RecoverDataClient interface {
	// read region meta to ready region meta
	ReadRegionMeta(ctx context.Context, in *ReadRegionMetaRequest, opts ...grpc.CallOption) (RecoverData_ReadRegionMetaClient, error)
	// execute the recovery command
	RecoverRegion(ctx context.Context, opts ...grpc.CallOption) (RecoverData_RecoverRegionClient, error)
	// wait all region apply to last index
	WaitApply(ctx context.Context, in *WaitApplyRequest, opts ...grpc.CallOption) (*WaitApplyResponse, error)
	// execute delete data from kv db
	ResolveKvData(ctx context.Context, in *ResolveKvDataRequest, opts ...grpc.CallOption) (RecoverData_ResolveKvDataClient, error)
}

RecoverDataClient is the client API for RecoverData service.

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

func NewRecoverDataClient

func NewRecoverDataClient(cc *grpc.ClientConn) RecoverDataClient

type RecoverDataServer

type RecoverDataServer interface {
	// read region meta to ready region meta
	ReadRegionMeta(*ReadRegionMetaRequest, RecoverData_ReadRegionMetaServer) error
	// execute the recovery command
	RecoverRegion(RecoverData_RecoverRegionServer) error
	// wait all region apply to last index
	WaitApply(context.Context, *WaitApplyRequest) (*WaitApplyResponse, error)
	// execute delete data from kv db
	ResolveKvData(*ResolveKvDataRequest, RecoverData_ResolveKvDataServer) error
}

RecoverDataServer is the server API for RecoverData service.

type RecoverData_ReadRegionMetaClient

type RecoverData_ReadRegionMetaClient interface {
	Recv() (*RegionMeta, error)
	grpc.ClientStream
}

type RecoverData_ReadRegionMetaServer

type RecoverData_ReadRegionMetaServer interface {
	Send(*RegionMeta) error
	grpc.ServerStream
}

type RecoverData_RecoverRegionClient

type RecoverData_RecoverRegionClient interface {
	Send(*RecoverRegionRequest) error
	CloseAndRecv() (*RecoverRegionResponse, error)
	grpc.ClientStream
}

type RecoverData_RecoverRegionServer

type RecoverData_RecoverRegionServer interface {
	SendAndClose(*RecoverRegionResponse) error
	Recv() (*RecoverRegionRequest, error)
	grpc.ServerStream
}

type RecoverData_ResolveKvDataClient

type RecoverData_ResolveKvDataClient interface {
	Recv() (*ResolveKvDataResponse, error)
	grpc.ClientStream
}

type RecoverData_ResolveKvDataServer

type RecoverData_ResolveKvDataServer interface {
	Send(*ResolveKvDataResponse) error
	grpc.ServerStream
}

type RecoverRegionRequest

type RecoverRegionRequest struct {
	RegionId             uint64   `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	AsLeader             bool     `protobuf:"varint,2,opt,name=as_leader,json=asLeader,proto3" json:"as_leader,omitempty"`
	Tombstone            bool     `protobuf:"varint,3,opt,name=tombstone,proto3" json:"tombstone,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

command to store for recover region

func (*RecoverRegionRequest) Descriptor

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

func (*RecoverRegionRequest) GetAsLeader

func (m *RecoverRegionRequest) GetAsLeader() bool

func (*RecoverRegionRequest) GetRegionId

func (m *RecoverRegionRequest) GetRegionId() uint64

func (*RecoverRegionRequest) GetTombstone

func (m *RecoverRegionRequest) GetTombstone() bool

func (*RecoverRegionRequest) Marshal

func (m *RecoverRegionRequest) Marshal() (dAtA []byte, err error)

func (*RecoverRegionRequest) MarshalTo

func (m *RecoverRegionRequest) MarshalTo(dAtA []byte) (int, error)

func (*RecoverRegionRequest) MarshalToSizedBuffer

func (m *RecoverRegionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecoverRegionRequest) ProtoMessage

func (*RecoverRegionRequest) ProtoMessage()

func (*RecoverRegionRequest) Reset

func (m *RecoverRegionRequest) Reset()

func (*RecoverRegionRequest) Size

func (m *RecoverRegionRequest) Size() (n int)

func (*RecoverRegionRequest) String

func (m *RecoverRegionRequest) String() string

func (*RecoverRegionRequest) Unmarshal

func (m *RecoverRegionRequest) Unmarshal(dAtA []byte) error

func (*RecoverRegionRequest) XXX_DiscardUnknown

func (m *RecoverRegionRequest) XXX_DiscardUnknown()

func (*RecoverRegionRequest) XXX_Marshal

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

func (*RecoverRegionRequest) XXX_Merge

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

func (*RecoverRegionRequest) XXX_Size

func (m *RecoverRegionRequest) XXX_Size() int

func (*RecoverRegionRequest) XXX_Unmarshal

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

type RecoverRegionResponse

type RecoverRegionResponse struct {
	Error                *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	StoreId              uint64   `protobuf:"varint,2,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RecoverRegionResponse) Descriptor

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

func (*RecoverRegionResponse) GetError

func (m *RecoverRegionResponse) GetError() *Error

func (*RecoverRegionResponse) GetStoreId

func (m *RecoverRegionResponse) GetStoreId() uint64

func (*RecoverRegionResponse) Marshal

func (m *RecoverRegionResponse) Marshal() (dAtA []byte, err error)

func (*RecoverRegionResponse) MarshalTo

func (m *RecoverRegionResponse) MarshalTo(dAtA []byte) (int, error)

func (*RecoverRegionResponse) MarshalToSizedBuffer

func (m *RecoverRegionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecoverRegionResponse) ProtoMessage

func (*RecoverRegionResponse) ProtoMessage()

func (*RecoverRegionResponse) Reset

func (m *RecoverRegionResponse) Reset()

func (*RecoverRegionResponse) Size

func (m *RecoverRegionResponse) Size() (n int)

func (*RecoverRegionResponse) String

func (m *RecoverRegionResponse) String() string

func (*RecoverRegionResponse) Unmarshal

func (m *RecoverRegionResponse) Unmarshal(dAtA []byte) error

func (*RecoverRegionResponse) XXX_DiscardUnknown

func (m *RecoverRegionResponse) XXX_DiscardUnknown()

func (*RecoverRegionResponse) XXX_Marshal

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

func (*RecoverRegionResponse) XXX_Merge

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

func (*RecoverRegionResponse) XXX_Size

func (m *RecoverRegionResponse) XXX_Size() int

func (*RecoverRegionResponse) XXX_Unmarshal

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

type RegionMeta

type RegionMeta struct {
	RegionId             uint64   `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	PeerId               uint64   `protobuf:"varint,2,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	LastLogTerm          uint64   `protobuf:"varint,3,opt,name=last_log_term,json=lastLogTerm,proto3" json:"last_log_term,omitempty"`
	LastIndex            uint64   `protobuf:"varint,4,opt,name=last_index,json=lastIndex,proto3" json:"last_index,omitempty"`
	CommitIndex          uint64   `protobuf:"varint,5,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	Version              uint64   `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
	Tombstone            bool     `protobuf:"varint,7,opt,name=tombstone,proto3" json:"tombstone,omitempty"`
	StartKey             []byte   `protobuf:"bytes,8,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey               []byte   `protobuf:"bytes,9,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegionMeta) Descriptor

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

func (*RegionMeta) GetCommitIndex

func (m *RegionMeta) GetCommitIndex() uint64

func (*RegionMeta) GetEndKey

func (m *RegionMeta) GetEndKey() []byte

func (*RegionMeta) GetLastIndex

func (m *RegionMeta) GetLastIndex() uint64

func (*RegionMeta) GetLastLogTerm

func (m *RegionMeta) GetLastLogTerm() uint64

func (*RegionMeta) GetPeerId

func (m *RegionMeta) GetPeerId() uint64

func (*RegionMeta) GetRegionId

func (m *RegionMeta) GetRegionId() uint64

func (*RegionMeta) GetStartKey

func (m *RegionMeta) GetStartKey() []byte

func (*RegionMeta) GetTombstone

func (m *RegionMeta) GetTombstone() bool

func (*RegionMeta) GetVersion

func (m *RegionMeta) GetVersion() uint64

func (*RegionMeta) Marshal

func (m *RegionMeta) Marshal() (dAtA []byte, err error)

func (*RegionMeta) MarshalTo

func (m *RegionMeta) MarshalTo(dAtA []byte) (int, error)

func (*RegionMeta) MarshalToSizedBuffer

func (m *RegionMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegionMeta) ProtoMessage

func (*RegionMeta) ProtoMessage()

func (*RegionMeta) Reset

func (m *RegionMeta) Reset()

func (*RegionMeta) Size

func (m *RegionMeta) Size() (n int)

func (*RegionMeta) String

func (m *RegionMeta) String() string

func (*RegionMeta) Unmarshal

func (m *RegionMeta) Unmarshal(dAtA []byte) error

func (*RegionMeta) XXX_DiscardUnknown

func (m *RegionMeta) XXX_DiscardUnknown()

func (*RegionMeta) XXX_Marshal

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

func (*RegionMeta) XXX_Merge

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

func (*RegionMeta) XXX_Size

func (m *RegionMeta) XXX_Size() int

func (*RegionMeta) XXX_Unmarshal

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

type ResolveKvDataRequest

type ResolveKvDataRequest struct {
	ResolvedTs           uint64   `protobuf:"varint,1,opt,name=resolved_ts,json=resolvedTs,proto3" json:"resolved_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

resolve data by resolved_ts

func (*ResolveKvDataRequest) Descriptor

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

func (*ResolveKvDataRequest) GetResolvedTs

func (m *ResolveKvDataRequest) GetResolvedTs() uint64

func (*ResolveKvDataRequest) Marshal

func (m *ResolveKvDataRequest) Marshal() (dAtA []byte, err error)

func (*ResolveKvDataRequest) MarshalTo

func (m *ResolveKvDataRequest) MarshalTo(dAtA []byte) (int, error)

func (*ResolveKvDataRequest) MarshalToSizedBuffer

func (m *ResolveKvDataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResolveKvDataRequest) ProtoMessage

func (*ResolveKvDataRequest) ProtoMessage()

func (*ResolveKvDataRequest) Reset

func (m *ResolveKvDataRequest) Reset()

func (*ResolveKvDataRequest) Size

func (m *ResolveKvDataRequest) Size() (n int)

func (*ResolveKvDataRequest) String

func (m *ResolveKvDataRequest) String() string

func (*ResolveKvDataRequest) Unmarshal

func (m *ResolveKvDataRequest) Unmarshal(dAtA []byte) error

func (*ResolveKvDataRequest) XXX_DiscardUnknown

func (m *ResolveKvDataRequest) XXX_DiscardUnknown()

func (*ResolveKvDataRequest) XXX_Marshal

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

func (*ResolveKvDataRequest) XXX_Merge

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

func (*ResolveKvDataRequest) XXX_Size

func (m *ResolveKvDataRequest) XXX_Size() int

func (*ResolveKvDataRequest) XXX_Unmarshal

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

type ResolveKvDataResponse

type ResolveKvDataResponse struct {
	Error            *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	StoreId          uint64 `protobuf:"varint,2,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	ResolvedKeyCount uint64 `protobuf:"varint,3,opt,name=resolved_key_count,json=resolvedKeyCount,proto3" json:"resolved_key_count,omitempty"`
	// cursor of delete key.commit_ts, reserved for progress of restore
	// progress is (current_commit_ts - resolved_ts) / (backup_ts - resolved_ts) x 100%
	CurrentCommitTs      uint64   `protobuf:"varint,4,opt,name=current_commit_ts,json=currentCommitTs,proto3" json:"current_commit_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResolveKvDataResponse) Descriptor

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

func (*ResolveKvDataResponse) GetCurrentCommitTs

func (m *ResolveKvDataResponse) GetCurrentCommitTs() uint64

func (*ResolveKvDataResponse) GetError

func (m *ResolveKvDataResponse) GetError() *Error

func (*ResolveKvDataResponse) GetResolvedKeyCount

func (m *ResolveKvDataResponse) GetResolvedKeyCount() uint64

func (*ResolveKvDataResponse) GetStoreId

func (m *ResolveKvDataResponse) GetStoreId() uint64

func (*ResolveKvDataResponse) Marshal

func (m *ResolveKvDataResponse) Marshal() (dAtA []byte, err error)

func (*ResolveKvDataResponse) MarshalTo

func (m *ResolveKvDataResponse) MarshalTo(dAtA []byte) (int, error)

func (*ResolveKvDataResponse) MarshalToSizedBuffer

func (m *ResolveKvDataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResolveKvDataResponse) ProtoMessage

func (*ResolveKvDataResponse) ProtoMessage()

func (*ResolveKvDataResponse) Reset

func (m *ResolveKvDataResponse) Reset()

func (*ResolveKvDataResponse) Size

func (m *ResolveKvDataResponse) Size() (n int)

func (*ResolveKvDataResponse) String

func (m *ResolveKvDataResponse) String() string

func (*ResolveKvDataResponse) Unmarshal

func (m *ResolveKvDataResponse) Unmarshal(dAtA []byte) error

func (*ResolveKvDataResponse) XXX_DiscardUnknown

func (m *ResolveKvDataResponse) XXX_DiscardUnknown()

func (*ResolveKvDataResponse) XXX_Marshal

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

func (*ResolveKvDataResponse) XXX_Merge

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

func (*ResolveKvDataResponse) XXX_Size

func (m *ResolveKvDataResponse) XXX_Size() int

func (*ResolveKvDataResponse) XXX_Unmarshal

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

type UnimplementedRecoverDataServer

type UnimplementedRecoverDataServer struct {
}

UnimplementedRecoverDataServer can be embedded to have forward compatible implementations.

func (*UnimplementedRecoverDataServer) ReadRegionMeta

func (*UnimplementedRecoverDataServer) RecoverRegion

func (*UnimplementedRecoverDataServer) ResolveKvData

func (*UnimplementedRecoverDataServer) WaitApply

type WaitApplyRequest

type WaitApplyRequest struct {
	StoreId              uint64   `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

wait apply to last index

func (*WaitApplyRequest) Descriptor

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

func (*WaitApplyRequest) GetStoreId

func (m *WaitApplyRequest) GetStoreId() uint64

func (*WaitApplyRequest) Marshal

func (m *WaitApplyRequest) Marshal() (dAtA []byte, err error)

func (*WaitApplyRequest) MarshalTo

func (m *WaitApplyRequest) MarshalTo(dAtA []byte) (int, error)

func (*WaitApplyRequest) MarshalToSizedBuffer

func (m *WaitApplyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WaitApplyRequest) ProtoMessage

func (*WaitApplyRequest) ProtoMessage()

func (*WaitApplyRequest) Reset

func (m *WaitApplyRequest) Reset()

func (*WaitApplyRequest) Size

func (m *WaitApplyRequest) Size() (n int)

func (*WaitApplyRequest) String

func (m *WaitApplyRequest) String() string

func (*WaitApplyRequest) Unmarshal

func (m *WaitApplyRequest) Unmarshal(dAtA []byte) error

func (*WaitApplyRequest) XXX_DiscardUnknown

func (m *WaitApplyRequest) XXX_DiscardUnknown()

func (*WaitApplyRequest) XXX_Marshal

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

func (*WaitApplyRequest) XXX_Merge

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

func (*WaitApplyRequest) XXX_Size

func (m *WaitApplyRequest) XXX_Size() int

func (*WaitApplyRequest) XXX_Unmarshal

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

type WaitApplyResponse

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

func (*WaitApplyResponse) Descriptor

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

func (*WaitApplyResponse) GetError

func (m *WaitApplyResponse) GetError() *Error

func (*WaitApplyResponse) Marshal

func (m *WaitApplyResponse) Marshal() (dAtA []byte, err error)

func (*WaitApplyResponse) MarshalTo

func (m *WaitApplyResponse) MarshalTo(dAtA []byte) (int, error)

func (*WaitApplyResponse) MarshalToSizedBuffer

func (m *WaitApplyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WaitApplyResponse) ProtoMessage

func (*WaitApplyResponse) ProtoMessage()

func (*WaitApplyResponse) Reset

func (m *WaitApplyResponse) Reset()

func (*WaitApplyResponse) Size

func (m *WaitApplyResponse) Size() (n int)

func (*WaitApplyResponse) String

func (m *WaitApplyResponse) String() string

func (*WaitApplyResponse) Unmarshal

func (m *WaitApplyResponse) Unmarshal(dAtA []byte) error

func (*WaitApplyResponse) XXX_DiscardUnknown

func (m *WaitApplyResponse) XXX_DiscardUnknown()

func (*WaitApplyResponse) XXX_Marshal

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

func (*WaitApplyResponse) XXX_Merge

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

func (*WaitApplyResponse) XXX_Size

func (m *WaitApplyResponse) XXX_Size() int

func (*WaitApplyResponse) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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