recover_data

package
v0.0.0-...-e1fa7ea Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2024 License: Apache-2.0 Imports: 10 Imported by: 3

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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) ReadRegionMeta(req *ReadRegionMetaRequest, srv RecoverData_ReadRegionMetaServer) error

func (*UnimplementedRecoverDataServer) RecoverRegion 

func (*UnimplementedRecoverDataServer) RecoverRegion(srv RecoverData_RecoverRegionServer) error

func (*UnimplementedRecoverDataServer) ResolveKvData 

func (*UnimplementedRecoverDataServer) ResolveKvData(req *ResolveKvDataRequest, srv RecoverData_ResolveKvDataServer) error

func (*UnimplementedRecoverDataServer) WaitApply 

func (*UnimplementedRecoverDataServer) WaitApply(ctx context.Context, req *WaitApplyRequest) (*WaitApplyResponse, error)

type WaitApplyRequest 

type WaitApplyRequest struct {
	StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
}

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"`
}

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

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.