snpb

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Nov 23, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLogIo        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogIo          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLogIo = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthLogStreamReporter        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogStreamReporter          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLogStreamReporter = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthManagement        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowManagement          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupManagement = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMetadata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetadata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMetadata = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthReplicator        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowReplicator          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupReplicator = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var InvalidLogStreamCommitResult = LogStreamCommitResult{}
View Source 
var InvalidLogStreamUncommitReport = LogStreamUncommitReport{}

InvalidLogStreamUncommitReport is empty report. Do **NOT** modify this.

View Source 
var SyncState_name = map[int32]string{
	0: "ERROR",
	1: "IN_PROGRESS",
	2: "COMPLETE",
}
View Source 
var SyncState_value = map[string]int32{
	"ERROR":       0,
	"IN_PROGRESS": 1,
	"COMPLETE":    2,
}

Functions

func RegisterLogIOServer 

func RegisterLogIOServer(s *grpc.Server, srv LogIOServer)

func RegisterLogStreamReporterServer 

func RegisterLogStreamReporterServer(s *grpc.Server, srv LogStreamReporterServer)

func RegisterManagementServer 

func RegisterManagementServer(s *grpc.Server, srv ManagementServer)

func RegisterReplicatorServer 

func RegisterReplicatorServer(s *grpc.Server, srv ReplicatorServer)

Types

type AddLogStreamReplicaRequest 

type AddLogStreamReplicaRequest struct {
	ClusterID       github_com_kakao_varlog_pkg_types.ClusterID     `` /* 142-byte string literal not displayed */
	StorageNodeID   github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	TopicID         github_com_kakao_varlog_pkg_types.TopicID       `` /* 134-byte string literal not displayed */
	LogStreamID     github_com_kakao_varlog_pkg_types.LogStreamID   `` /* 152-byte string literal not displayed */
	StorageNodePath string                                          `protobuf:"bytes,5,opt,name=storage_node_path,json=storageNodePath,proto3" json:"storage_node_path,omitempty"`
}

func (*AddLogStreamReplicaRequest) Descriptor 

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

func (*AddLogStreamReplicaRequest) GetClusterID 

func (m *AddLogStreamReplicaRequest) GetClusterID() github_com_kakao_varlog_pkg_types.ClusterID

func (*AddLogStreamReplicaRequest) GetLogStreamID 

func (m *AddLogStreamReplicaRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*AddLogStreamReplicaRequest) GetStorageNodeID 

func (m *AddLogStreamReplicaRequest) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID

func (*AddLogStreamReplicaRequest) GetStorageNodePath added in v0.4.0 

func (m *AddLogStreamReplicaRequest) GetStorageNodePath() string

func (*AddLogStreamReplicaRequest) GetTopicID 

func (m *AddLogStreamReplicaRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*AddLogStreamReplicaRequest) Marshal 

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

func (*AddLogStreamReplicaRequest) MarshalTo 

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

func (*AddLogStreamReplicaRequest) MarshalToSizedBuffer 

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

func (*AddLogStreamReplicaRequest) ProtoMessage 

func (*AddLogStreamReplicaRequest) ProtoMessage()

func (*AddLogStreamReplicaRequest) ProtoSize 

func (m *AddLogStreamReplicaRequest) ProtoSize() (n int)

func (*AddLogStreamReplicaRequest) Reset 

func (m *AddLogStreamReplicaRequest) Reset()

func (*AddLogStreamReplicaRequest) String 

func (m *AddLogStreamReplicaRequest) String() string

func (*AddLogStreamReplicaRequest) Unmarshal 

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

func (*AddLogStreamReplicaRequest) XXX_DiscardUnknown 

func (m *AddLogStreamReplicaRequest) XXX_DiscardUnknown()

func (*AddLogStreamReplicaRequest) XXX_Marshal 

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

func (*AddLogStreamReplicaRequest) XXX_Merge 

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

func (*AddLogStreamReplicaRequest) XXX_Size 

func (m *AddLogStreamReplicaRequest) XXX_Size() int

func (*AddLogStreamReplicaRequest) XXX_Unmarshal 

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

type AddLogStreamReplicaResponse 

type AddLogStreamReplicaResponse struct {
	LogStreamReplica LogStreamReplicaMetadataDescriptor `protobuf:"bytes,1,opt,name=log_stream_replica,json=logStreamReplica,proto3" json:"log_stream_replica"`
}

func (*AddLogStreamReplicaResponse) Descriptor 

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

func (*AddLogStreamReplicaResponse) GetLogStreamReplica added in v0.4.0 

func (m *AddLogStreamReplicaResponse) GetLogStreamReplica() LogStreamReplicaMetadataDescriptor

func (*AddLogStreamReplicaResponse) Marshal 

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

func (*AddLogStreamReplicaResponse) MarshalTo 

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

func (*AddLogStreamReplicaResponse) MarshalToSizedBuffer 

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

func (*AddLogStreamReplicaResponse) ProtoMessage 

func (*AddLogStreamReplicaResponse) ProtoMessage()

func (*AddLogStreamReplicaResponse) ProtoSize 

func (m *AddLogStreamReplicaResponse) ProtoSize() (n int)

func (*AddLogStreamReplicaResponse) Reset 

func (m *AddLogStreamReplicaResponse) Reset()

func (*AddLogStreamReplicaResponse) String 

func (m *AddLogStreamReplicaResponse) String() string

func (*AddLogStreamReplicaResponse) Unmarshal 

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

func (*AddLogStreamReplicaResponse) XXX_DiscardUnknown 

func (m *AddLogStreamReplicaResponse) XXX_DiscardUnknown()

func (*AddLogStreamReplicaResponse) XXX_Marshal 

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

func (*AddLogStreamReplicaResponse) XXX_Merge 

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

func (*AddLogStreamReplicaResponse) XXX_Size 

func (m *AddLogStreamReplicaResponse) XXX_Size() int

func (*AddLogStreamReplicaResponse) XXX_Unmarshal 

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

type AppendRequest 

type AppendRequest struct {
	TopicID     github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
	Payload     [][]byte                                      `protobuf:"bytes,3,rep,name=payload,proto3" json:"payload,omitempty"`
	Backups     []varlogpb.StorageNode                        `protobuf:"bytes,4,rep,name=backups,proto3" json:"backups"`
}

AppendRequest is a message to send a payload to a storage node. It contains a vector of storage nodes to replicate the payload.

func (*AppendRequest) Descriptor 

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

func (*AppendRequest) GetBackups 

func (m *AppendRequest) GetBackups() []varlogpb.StorageNode

func (*AppendRequest) GetLogStreamID 

func (m *AppendRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*AppendRequest) GetPayload 

func (m *AppendRequest) GetPayload() [][]byte

func (*AppendRequest) GetTopicID 

func (m *AppendRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*AppendRequest) Marshal 

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

func (*AppendRequest) MarshalTo 

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

func (*AppendRequest) MarshalToSizedBuffer 

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

func (*AppendRequest) ProtoMessage 

func (*AppendRequest) ProtoMessage()

func (*AppendRequest) ProtoSize 

func (m *AppendRequest) ProtoSize() (n int)

func (*AppendRequest) Reset 

func (m *AppendRequest) Reset()

func (*AppendRequest) String 

func (m *AppendRequest) String() string

func (*AppendRequest) Unmarshal 

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

func (*AppendRequest) XXX_DiscardUnknown 

func (m *AppendRequest) XXX_DiscardUnknown()

func (*AppendRequest) XXX_Marshal 

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

func (*AppendRequest) XXX_Merge 

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

func (*AppendRequest) XXX_Size 

func (m *AppendRequest) XXX_Size() int

func (*AppendRequest) XXX_Unmarshal 

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

type AppendResponse 

type AppendResponse struct {
	Results []AppendResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results"`
}

AppendResponse is a response message of Append RPC.

func (*AppendResponse) Descriptor 

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

func (*AppendResponse) GetResults 

func (m *AppendResponse) GetResults() []AppendResult

func (*AppendResponse) Marshal 

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

func (*AppendResponse) MarshalTo 

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

func (*AppendResponse) MarshalToSizedBuffer 

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

func (*AppendResponse) ProtoMessage 

func (*AppendResponse) ProtoMessage()

func (*AppendResponse) ProtoSize 

func (m *AppendResponse) ProtoSize() (n int)

func (*AppendResponse) Reset 

func (m *AppendResponse) Reset()

func (*AppendResponse) String 

func (m *AppendResponse) String() string

func (*AppendResponse) Unmarshal 

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

func (*AppendResponse) XXX_DiscardUnknown 

func (m *AppendResponse) XXX_DiscardUnknown()

func (*AppendResponse) XXX_Marshal 

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

func (*AppendResponse) XXX_Merge 

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

func (*AppendResponse) XXX_Size 

func (m *AppendResponse) XXX_Size() int

func (*AppendResponse) XXX_Unmarshal 

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

type AppendResult 

type AppendResult struct {
	Meta  varlogpb.LogEntryMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta"`
	Error string                `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*AppendResult) Descriptor 

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

func (*AppendResult) GetError 

func (m *AppendResult) GetError() string

func (*AppendResult) GetMeta 

func (m *AppendResult) GetMeta() varlogpb.LogEntryMeta

func (*AppendResult) Marshal 

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

func (*AppendResult) MarshalTo 

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

func (*AppendResult) MarshalToSizedBuffer 

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

func (*AppendResult) ProtoMessage 

func (*AppendResult) ProtoMessage()

func (*AppendResult) ProtoSize 

func (m *AppendResult) ProtoSize() (n int)

func (*AppendResult) Reset 

func (m *AppendResult) Reset()

func (*AppendResult) String 

func (m *AppendResult) String() string

func (*AppendResult) Unmarshal 

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

func (*AppendResult) XXX_DiscardUnknown 

func (m *AppendResult) XXX_DiscardUnknown()

func (*AppendResult) XXX_Marshal 

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

func (*AppendResult) XXX_Merge 

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

func (*AppendResult) XXX_Size 

func (m *AppendResult) XXX_Size() int

func (*AppendResult) XXX_Unmarshal 

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

type CommitBatchRequest added in v0.7.0 

type CommitBatchRequest struct {
	StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	CommitResults []LogStreamCommitResult                         `protobuf:"bytes,2,rep,name=commit_results,json=commitResults,proto3" json:"commit_results"`
}

func (*CommitBatchRequest) Descriptor added in v0.7.0 

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

func (*CommitBatchRequest) GetCommitResults added in v0.7.0 

func (m *CommitBatchRequest) GetCommitResults() []LogStreamCommitResult

func (*CommitBatchRequest) GetStorageNodeID added in v0.7.0 

func (m *CommitBatchRequest) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID

func (*CommitBatchRequest) Marshal added in v0.7.0 

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

func (*CommitBatchRequest) MarshalTo added in v0.7.0 

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

func (*CommitBatchRequest) MarshalToSizedBuffer added in v0.7.0 

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

func (*CommitBatchRequest) ProtoMessage added in v0.7.0 

func (*CommitBatchRequest) ProtoMessage()

func (*CommitBatchRequest) ProtoSize added in v0.7.0 

func (m *CommitBatchRequest) ProtoSize() (n int)

func (*CommitBatchRequest) Reset added in v0.7.0 

func (m *CommitBatchRequest) Reset()

func (*CommitBatchRequest) String added in v0.7.0 

func (m *CommitBatchRequest) String() string

func (*CommitBatchRequest) Unmarshal added in v0.7.0 

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

func (*CommitBatchRequest) XXX_DiscardUnknown added in v0.7.0 

func (m *CommitBatchRequest) XXX_DiscardUnknown()

func (*CommitBatchRequest) XXX_Marshal added in v0.7.0 

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

func (*CommitBatchRequest) XXX_Merge added in v0.7.0 

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

func (*CommitBatchRequest) XXX_Size added in v0.7.0 

func (m *CommitBatchRequest) XXX_Size() int

func (*CommitBatchRequest) XXX_Unmarshal added in v0.7.0 

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

type CommitBatchResponse added in v0.7.0 

type CommitBatchResponse struct {
}

func (*CommitBatchResponse) Descriptor added in v0.7.0 

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

func (*CommitBatchResponse) Marshal added in v0.7.0 

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

func (*CommitBatchResponse) MarshalTo added in v0.7.0 

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

func (*CommitBatchResponse) MarshalToSizedBuffer added in v0.7.0 

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

func (*CommitBatchResponse) ProtoMessage added in v0.7.0 

func (*CommitBatchResponse) ProtoMessage()

func (*CommitBatchResponse) ProtoSize added in v0.7.0 

func (m *CommitBatchResponse) ProtoSize() (n int)

func (*CommitBatchResponse) Reset added in v0.7.0 

func (m *CommitBatchResponse) Reset()

func (*CommitBatchResponse) String added in v0.7.0 

func (m *CommitBatchResponse) String() string

func (*CommitBatchResponse) Unmarshal added in v0.7.0 

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

func (*CommitBatchResponse) XXX_DiscardUnknown added in v0.7.0 

func (m *CommitBatchResponse) XXX_DiscardUnknown()

func (*CommitBatchResponse) XXX_Marshal added in v0.7.0 

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

func (*CommitBatchResponse) XXX_Merge added in v0.7.0 

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

func (*CommitBatchResponse) XXX_Size added in v0.7.0 

func (m *CommitBatchResponse) XXX_Size() int

func (*CommitBatchResponse) XXX_Unmarshal added in v0.7.0 

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

type CommitRequest 

type CommitRequest struct {
	StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	CommitResult  LogStreamCommitResult                           `protobuf:"bytes,2,opt,name=commit_result,json=commitResult,proto3" json:"commit_result"`
}

func (*CommitRequest) Descriptor 

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

func (*CommitRequest) GetCommitResult 

func (m *CommitRequest) GetCommitResult() LogStreamCommitResult

func (*CommitRequest) GetStorageNodeID 

func (m *CommitRequest) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID

func (*CommitRequest) Marshal 

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

func (*CommitRequest) MarshalTo 

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

func (*CommitRequest) MarshalToSizedBuffer 

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

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) ProtoSize 

func (m *CommitRequest) ProtoSize() (n int)

func (*CommitRequest) Reset 

func (m *CommitRequest) Reset()

func (*CommitRequest) String 

func (m *CommitRequest) String() string

func (*CommitRequest) Unmarshal 

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

func (*CommitRequest) XXX_DiscardUnknown 

func (m *CommitRequest) XXX_DiscardUnknown()

func (*CommitRequest) XXX_Marshal 

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

func (*CommitRequest) XXX_Merge 

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

func (*CommitRequest) XXX_Size 

func (m *CommitRequest) XXX_Size() int

func (*CommitRequest) XXX_Unmarshal 

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

type CommitResponse 

type CommitResponse struct {
}

func (*CommitResponse) Descriptor 

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

func (*CommitResponse) Marshal 

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

func (*CommitResponse) MarshalTo 

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

func (*CommitResponse) MarshalToSizedBuffer 

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

func (*CommitResponse) ProtoMessage 

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) ProtoSize 

func (m *CommitResponse) ProtoSize() (n int)

func (*CommitResponse) Reset 

func (m *CommitResponse) Reset()

func (*CommitResponse) String 

func (m *CommitResponse) String() string

func (*CommitResponse) Unmarshal 

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

func (*CommitResponse) XXX_DiscardUnknown 

func (m *CommitResponse) XXX_DiscardUnknown()

func (*CommitResponse) XXX_Marshal 

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

func (*CommitResponse) XXX_Merge 

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

func (*CommitResponse) XXX_Size 

func (m *CommitResponse) XXX_Size() int

func (*CommitResponse) XXX_Unmarshal 

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

type GetMetadataRequest 

type GetMetadataRequest struct {
	ClusterID github_com_kakao_varlog_pkg_types.ClusterID `` /* 142-byte string literal not displayed */
}

func (*GetMetadataRequest) Descriptor 

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

func (*GetMetadataRequest) GetClusterID 

func (m *GetMetadataRequest) GetClusterID() github_com_kakao_varlog_pkg_types.ClusterID

func (*GetMetadataRequest) Marshal 

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

func (*GetMetadataRequest) MarshalTo 

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

func (*GetMetadataRequest) MarshalToSizedBuffer 

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

func (*GetMetadataRequest) ProtoMessage 

func (*GetMetadataRequest) ProtoMessage()

func (*GetMetadataRequest) ProtoSize 

func (m *GetMetadataRequest) ProtoSize() (n int)

func (*GetMetadataRequest) Reset 

func (m *GetMetadataRequest) Reset()

func (*GetMetadataRequest) String 

func (m *GetMetadataRequest) String() string

func (*GetMetadataRequest) Unmarshal 

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

func (*GetMetadataRequest) XXX_DiscardUnknown 

func (m *GetMetadataRequest) XXX_DiscardUnknown()

func (*GetMetadataRequest) XXX_Marshal 

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

func (*GetMetadataRequest) XXX_Merge 

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

func (*GetMetadataRequest) XXX_Size 

func (m *GetMetadataRequest) XXX_Size() int

func (*GetMetadataRequest) XXX_Unmarshal 

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

type GetMetadataResponse 

type GetMetadataResponse struct {
	StorageNodeMetadata *StorageNodeMetadataDescriptor `protobuf:"bytes,1,opt,name=storage_node_metadata,json=storageNodeMetadata,proto3" json:"storage_node_metadata,omitempty"`
}

func (*GetMetadataResponse) Descriptor 

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

func (*GetMetadataResponse) GetStorageNodeMetadata 

func (m *GetMetadataResponse) GetStorageNodeMetadata() *StorageNodeMetadataDescriptor

func (*GetMetadataResponse) Marshal 

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

func (*GetMetadataResponse) MarshalTo 

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

func (*GetMetadataResponse) MarshalToSizedBuffer 

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

func (*GetMetadataResponse) ProtoMessage 

func (*GetMetadataResponse) ProtoMessage()

func (*GetMetadataResponse) ProtoSize 

func (m *GetMetadataResponse) ProtoSize() (n int)

func (*GetMetadataResponse) Reset 

func (m *GetMetadataResponse) Reset()

func (*GetMetadataResponse) String 

func (m *GetMetadataResponse) String() string

func (*GetMetadataResponse) Unmarshal 

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

func (*GetMetadataResponse) XXX_DiscardUnknown 

func (m *GetMetadataResponse) XXX_DiscardUnknown()

func (*GetMetadataResponse) XXX_Marshal 

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

func (*GetMetadataResponse) XXX_Merge 

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

func (*GetMetadataResponse) XXX_Size 

func (m *GetMetadataResponse) XXX_Size() int

func (*GetMetadataResponse) XXX_Unmarshal 

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

type GetReportRequest 

type GetReportRequest struct {
}

func (*GetReportRequest) Descriptor 

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

func (*GetReportRequest) Marshal 

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

func (*GetReportRequest) MarshalTo 

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

func (*GetReportRequest) MarshalToSizedBuffer 

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

func (*GetReportRequest) ProtoMessage 

func (*GetReportRequest) ProtoMessage()

func (*GetReportRequest) ProtoSize 

func (m *GetReportRequest) ProtoSize() (n int)

func (*GetReportRequest) Reset 

func (m *GetReportRequest) Reset()

func (*GetReportRequest) String 

func (m *GetReportRequest) String() string

func (*GetReportRequest) Unmarshal 

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

func (*GetReportRequest) XXX_DiscardUnknown 

func (m *GetReportRequest) XXX_DiscardUnknown()

func (*GetReportRequest) XXX_Marshal 

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

func (*GetReportRequest) XXX_Merge 

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

func (*GetReportRequest) XXX_Size 

func (m *GetReportRequest) XXX_Size() int

func (*GetReportRequest) XXX_Unmarshal 

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

type GetReportResponse 

type GetReportResponse struct {
	StorageNodeID   github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	UncommitReports []LogStreamUncommitReport                       `protobuf:"bytes,2,rep,name=uncommit_reports,json=uncommitReports,proto3" json:"uncommit_reports"`
}

func (*GetReportResponse) Descriptor 

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

func (*GetReportResponse) GetStorageNodeID 

func (m *GetReportResponse) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID

func (*GetReportResponse) GetUncommitReports 

func (m *GetReportResponse) GetUncommitReports() []LogStreamUncommitReport

func (*GetReportResponse) Marshal 

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

func (*GetReportResponse) MarshalTo 

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

func (*GetReportResponse) MarshalToSizedBuffer 

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

func (*GetReportResponse) ProtoMessage 

func (*GetReportResponse) ProtoMessage()

func (*GetReportResponse) ProtoSize 

func (m *GetReportResponse) ProtoSize() (n int)

func (*GetReportResponse) Reset 

func (m *GetReportResponse) Reset()

func (*GetReportResponse) String 

func (m *GetReportResponse) String() string

func (*GetReportResponse) Unmarshal 

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

func (*GetReportResponse) XXX_DiscardUnknown 

func (m *GetReportResponse) XXX_DiscardUnknown()

func (*GetReportResponse) XXX_Marshal 

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

func (*GetReportResponse) XXX_Merge 

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

func (*GetReportResponse) XXX_Size 

func (m *GetReportResponse) XXX_Size() int

func (*GetReportResponse) XXX_Unmarshal 

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

type LogIOClient 

type LogIOClient interface {
	Append(ctx context.Context, in *AppendRequest, opts ...grpc.CallOption) (*AppendResponse, error)
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (LogIO_SubscribeClient, error)
	SubscribeTo(ctx context.Context, in *SubscribeToRequest, opts ...grpc.CallOption) (LogIO_SubscribeToClient, error)
	TrimDeprecated(ctx context.Context, in *TrimDeprecatedRequest, opts ...grpc.CallOption) (*types.Empty, error)
	LogStreamReplicaMetadata(ctx context.Context, in *LogStreamReplicaMetadataRequest, opts ...grpc.CallOption) (*LogStreamReplicaMetadataResponse, error)
	LogStreamMetadata(ctx context.Context, in *LogStreamMetadataRequest, opts ...grpc.CallOption) (*LogStreamMetadataResponse, error)
}

LogIOClient is the client API for LogIO service.

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

func NewLogIOClient 

func NewLogIOClient(cc *grpc.ClientConn) LogIOClient

type LogIOServer 

type LogIOServer interface {
	Append(context.Context, *AppendRequest) (*AppendResponse, error)
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	Subscribe(*SubscribeRequest, LogIO_SubscribeServer) error
	SubscribeTo(*SubscribeToRequest, LogIO_SubscribeToServer) error
	TrimDeprecated(context.Context, *TrimDeprecatedRequest) (*types.Empty, error)
	LogStreamReplicaMetadata(context.Context, *LogStreamReplicaMetadataRequest) (*LogStreamReplicaMetadataResponse, error)
	LogStreamMetadata(context.Context, *LogStreamMetadataRequest) (*LogStreamMetadataResponse, error)
}

LogIOServer is the server API for LogIO service.

type LogIO_SubscribeClient 

type LogIO_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type LogIO_SubscribeServer 

type LogIO_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type LogIO_SubscribeToClient 

type LogIO_SubscribeToClient interface {
	Recv() (*SubscribeToResponse, error)
	grpc.ClientStream
}

type LogIO_SubscribeToServer 

type LogIO_SubscribeToServer interface {
	Send(*SubscribeToResponse) error
	grpc.ServerStream
}

type LogStreamCommitResult 

type LogStreamCommitResult struct {
	LogStreamID         github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
	TopicID             github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	CommittedLLSNOffset github_com_kakao_varlog_pkg_types.LLSN        `` /* 169-byte string literal not displayed */
	CommittedGLSNOffset github_com_kakao_varlog_pkg_types.GLSN        `` /* 169-byte string literal not displayed */
	CommittedGLSNLength uint64                                        `protobuf:"varint,5,opt,name=committed_glsn_length,json=committedGlsnLength,proto3" json:"committed_glsn_length,omitempty"`
	Version             github_com_kakao_varlog_pkg_types.Version     `protobuf:"varint,6,opt,name=version,proto3,casttype=github.com/kakao/varlog/pkg/types.Version" json:"version,omitempty"`
	HighWatermark       github_com_kakao_varlog_pkg_types.GLSN        `` /* 149-byte string literal not displayed */
}

GlobalLogStreamDescriptor is a committing result against with LocalLogStreamDescriptor. Field highest_glsn is the highest position in the global log space. Field commit_result contains positions of all log entries of log streams in a storage node which is a receiver of this GlobalLogStreamDescriptor.

func (*LogStreamCommitResult) Descriptor 

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

func (*LogStreamCommitResult) Equal 

func (this *LogStreamCommitResult) Equal(that interface{}) bool

func (*LogStreamCommitResult) GetCommittedGLSNLength 

func (m *LogStreamCommitResult) GetCommittedGLSNLength() uint64

func (*LogStreamCommitResult) GetCommittedGLSNOffset 

func (m *LogStreamCommitResult) GetCommittedGLSNOffset() github_com_kakao_varlog_pkg_types.GLSN

func (*LogStreamCommitResult) GetCommittedLLSNOffset 

func (m *LogStreamCommitResult) GetCommittedLLSNOffset() github_com_kakao_varlog_pkg_types.LLSN

func (*LogStreamCommitResult) GetHighWatermark 

func (m *LogStreamCommitResult) GetHighWatermark() github_com_kakao_varlog_pkg_types.GLSN

func (*LogStreamCommitResult) GetLogStreamID 

func (m *LogStreamCommitResult) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*LogStreamCommitResult) GetTopicID 

func (m *LogStreamCommitResult) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*LogStreamCommitResult) GetVersion 

func (m *LogStreamCommitResult) GetVersion() github_com_kakao_varlog_pkg_types.Version

func (*LogStreamCommitResult) Marshal 

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

func (*LogStreamCommitResult) MarshalTo 

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

func (*LogStreamCommitResult) MarshalToSizedBuffer 

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

func (*LogStreamCommitResult) ProtoMessage 

func (*LogStreamCommitResult) ProtoMessage()

func (*LogStreamCommitResult) ProtoSize 

func (m *LogStreamCommitResult) ProtoSize() (n int)

func (*LogStreamCommitResult) Reset 

func (m *LogStreamCommitResult) Reset()

func (*LogStreamCommitResult) String 

func (m *LogStreamCommitResult) String() string

func (*LogStreamCommitResult) Unmarshal 

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

func (*LogStreamCommitResult) XXX_DiscardUnknown 

func (m *LogStreamCommitResult) XXX_DiscardUnknown()

func (*LogStreamCommitResult) XXX_Marshal 

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

func (*LogStreamCommitResult) XXX_Merge 

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

func (*LogStreamCommitResult) XXX_Size 

func (m *LogStreamCommitResult) XXX_Size() int

func (*LogStreamCommitResult) XXX_Unmarshal 

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

type LogStreamMetadataRequest 

type LogStreamMetadataRequest struct {
	TopicID     github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
}

func (*LogStreamMetadataRequest) Descriptor 

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

func (*LogStreamMetadataRequest) GetLogStreamID 

func (m *LogStreamMetadataRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*LogStreamMetadataRequest) GetTopicID 

func (m *LogStreamMetadataRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*LogStreamMetadataRequest) Marshal 

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

func (*LogStreamMetadataRequest) MarshalTo 

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

func (*LogStreamMetadataRequest) MarshalToSizedBuffer 

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

func (*LogStreamMetadataRequest) ProtoMessage 

func (*LogStreamMetadataRequest) ProtoMessage()

func (*LogStreamMetadataRequest) ProtoSize 

func (m *LogStreamMetadataRequest) ProtoSize() (n int)

func (*LogStreamMetadataRequest) Reset 

func (m *LogStreamMetadataRequest) Reset()

func (*LogStreamMetadataRequest) String 

func (m *LogStreamMetadataRequest) String() string

func (*LogStreamMetadataRequest) Unmarshal 

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

func (*LogStreamMetadataRequest) XXX_DiscardUnknown 

func (m *LogStreamMetadataRequest) XXX_DiscardUnknown()

func (*LogStreamMetadataRequest) XXX_Marshal 

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

func (*LogStreamMetadataRequest) XXX_Merge 

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

func (*LogStreamMetadataRequest) XXX_Size 

func (m *LogStreamMetadataRequest) XXX_Size() int

func (*LogStreamMetadataRequest) XXX_Unmarshal 

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

type LogStreamMetadataResponse 

type LogStreamMetadataResponse struct {
	LogStreamDescriptor varlogpb.LogStreamDescriptor `protobuf:"bytes,1,opt,name=log_stream_descriptor,json=logStreamDescriptor,proto3" json:"log_stream_descriptor"`
}

func (*LogStreamMetadataResponse) Descriptor 

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

func (*LogStreamMetadataResponse) GetLogStreamDescriptor 

func (m *LogStreamMetadataResponse) GetLogStreamDescriptor() varlogpb.LogStreamDescriptor

func (*LogStreamMetadataResponse) Marshal 

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

func (*LogStreamMetadataResponse) MarshalTo 

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

func (*LogStreamMetadataResponse) MarshalToSizedBuffer 

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

func (*LogStreamMetadataResponse) ProtoMessage 

func (*LogStreamMetadataResponse) ProtoMessage()

func (*LogStreamMetadataResponse) ProtoSize 

func (m *LogStreamMetadataResponse) ProtoSize() (n int)

func (*LogStreamMetadataResponse) Reset 

func (m *LogStreamMetadataResponse) Reset()

func (*LogStreamMetadataResponse) String 

func (m *LogStreamMetadataResponse) String() string

func (*LogStreamMetadataResponse) Unmarshal 

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

func (*LogStreamMetadataResponse) XXX_DiscardUnknown 

func (m *LogStreamMetadataResponse) XXX_DiscardUnknown()

func (*LogStreamMetadataResponse) XXX_Marshal 

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

func (*LogStreamMetadataResponse) XXX_Merge 

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

func (*LogStreamMetadataResponse) XXX_Size 

func (m *LogStreamMetadataResponse) XXX_Size() int

func (*LogStreamMetadataResponse) XXX_Unmarshal 

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

type LogStreamReplicaMetadataDescriptor 

type LogStreamReplicaMetadataDescriptor struct {
	varlogpb.LogStreamReplica `protobuf:"bytes,1,opt,name=log_stream_replica,json=logStreamReplica,proto3,embedded=log_stream_replica" json:""`
	// Status is the status of the log stream replica.
	//
	// TODO: Use a separate type to represent the status of the log stream replica
	// rather than `varlogpb.LogStreamStatus` that is shared with the metadata
	// repository.
	Status varlogpb.LogStreamStatus `protobuf:"varint,2,opt,name=status,proto3,enum=varlog.varlogpb.LogStreamStatus" json:"status,omitempty"`
	// Version is the latest version of the commit received from the metadata
	// repository.
	Version github_com_kakao_varlog_pkg_types.Version `protobuf:"varint,3,opt,name=version,proto3,casttype=github.com/kakao/varlog/pkg/types.Version" json:"version,omitempty"`
	// GlobalHighWatermark is the latest high watermark received from the metadata
	// repository.
	GlobalHighWatermark github_com_kakao_varlog_pkg_types.GLSN `` /* 157-byte string literal not displayed */
	// LocalLowWatermark is the first log sequence number in the log stream
	// replica.
	// The LocalLowWatermark becomes higher when the log is truncated by prefix
	// trimming.
	LocalLowWatermark varlogpb.LogSequenceNumber `protobuf:"bytes,5,opt,name=local_low_watermark,json=localLowWatermark,proto3" json:"localLowWatermark"`
	// LocalHighWatermark is the last log sequence number in the log stream
	// replica.
	LocalHighWatermark varlogpb.LogSequenceNumber `protobuf:"bytes,6,opt,name=local_high_watermark,json=localHighWatermark,proto3" json:"localHighWatermark"`
	// Path is the directory where the data for the log stream replica is stored.
	Path             string `protobuf:"bytes,7,opt,name=path,proto3" json:"path,omitempty"`
	StorageSizeBytes uint64 `protobuf:"varint,8,opt,name=storage_size_bytes,json=storageSizeBytes,proto3" json:"storage_size_bytes,omitempty"`
	// CreatedTime
	//
	// FIXME: StartTime or UpTime
	CreatedTime time.Time `protobuf:"bytes,9,opt,name=created_time,json=createdTime,proto3,stdtime" json:"createdTime"`
	// UpdatedTime
	//
	// Deprecated:
	UpdatedTime time.Time `protobuf:"bytes,10,opt,name=updated_time,json=updatedTime,proto3,stdtime" json:"updatedTime"`
}

LogStreamReplicaMetadataDescriptor represents the metadata of log stream replica.

func (*LogStreamReplicaMetadataDescriptor) Descriptor 

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

func (*LogStreamReplicaMetadataDescriptor) Equal 

func (this *LogStreamReplicaMetadataDescriptor) Equal(that interface{}) bool

func (*LogStreamReplicaMetadataDescriptor) GetCreatedTime 

func (m *LogStreamReplicaMetadataDescriptor) GetCreatedTime() time.Time

func (*LogStreamReplicaMetadataDescriptor) GetGlobalHighWatermark 

func (m *LogStreamReplicaMetadataDescriptor) GetGlobalHighWatermark() github_com_kakao_varlog_pkg_types.GLSN

func (*LogStreamReplicaMetadataDescriptor) GetLocalHighWatermark 

func (m *LogStreamReplicaMetadataDescriptor) GetLocalHighWatermark() varlogpb.LogSequenceNumber

func (*LogStreamReplicaMetadataDescriptor) GetLocalLowWatermark 

func (m *LogStreamReplicaMetadataDescriptor) GetLocalLowWatermark() varlogpb.LogSequenceNumber

func (*LogStreamReplicaMetadataDescriptor) GetPath 

func (m *LogStreamReplicaMetadataDescriptor) GetPath() string

func (*LogStreamReplicaMetadataDescriptor) GetStatus 

func (m *LogStreamReplicaMetadataDescriptor) GetStatus() varlogpb.LogStreamStatus

func (*LogStreamReplicaMetadataDescriptor) GetStorageSizeBytes 

func (m *LogStreamReplicaMetadataDescriptor) GetStorageSizeBytes() uint64

func (*LogStreamReplicaMetadataDescriptor) GetUpdatedTime 

func (m *LogStreamReplicaMetadataDescriptor) GetUpdatedTime() time.Time

func (*LogStreamReplicaMetadataDescriptor) GetVersion 

func (m *LogStreamReplicaMetadataDescriptor) GetVersion() github_com_kakao_varlog_pkg_types.Version

func (*LogStreamReplicaMetadataDescriptor) Head added in v0.4.1 

func (lsrmd *LogStreamReplicaMetadataDescriptor) Head() varlogpb.LogEntryMeta

func (*LogStreamReplicaMetadataDescriptor) Marshal 

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

func (*LogStreamReplicaMetadataDescriptor) MarshalTo 

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

func (*LogStreamReplicaMetadataDescriptor) MarshalToSizedBuffer 

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

func (*LogStreamReplicaMetadataDescriptor) ProtoMessage 

func (*LogStreamReplicaMetadataDescriptor) ProtoMessage()

func (*LogStreamReplicaMetadataDescriptor) ProtoSize 

func (m *LogStreamReplicaMetadataDescriptor) ProtoSize() (n int)

func (*LogStreamReplicaMetadataDescriptor) Reset 

func (m *LogStreamReplicaMetadataDescriptor) Reset()

func (*LogStreamReplicaMetadataDescriptor) String 

func (m *LogStreamReplicaMetadataDescriptor) String() string

func (*LogStreamReplicaMetadataDescriptor) Tail added in v0.4.1 

func (lsrmd *LogStreamReplicaMetadataDescriptor) Tail() varlogpb.LogEntryMeta

func (*LogStreamReplicaMetadataDescriptor) Unmarshal 

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

func (*LogStreamReplicaMetadataDescriptor) XXX_DiscardUnknown 

func (m *LogStreamReplicaMetadataDescriptor) XXX_DiscardUnknown()

func (*LogStreamReplicaMetadataDescriptor) XXX_Marshal 

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

func (*LogStreamReplicaMetadataDescriptor) XXX_Merge 

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

func (*LogStreamReplicaMetadataDescriptor) XXX_Size 

func (m *LogStreamReplicaMetadataDescriptor) XXX_Size() int

func (*LogStreamReplicaMetadataDescriptor) XXX_Unmarshal 

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

type LogStreamReplicaMetadataRequest added in v0.4.1 

type LogStreamReplicaMetadataRequest struct {
	TopicID     github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
}

func (*LogStreamReplicaMetadataRequest) Descriptor added in v0.4.1 

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

func (*LogStreamReplicaMetadataRequest) GetLogStreamID added in v0.4.1 

func (m *LogStreamReplicaMetadataRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*LogStreamReplicaMetadataRequest) GetTopicID added in v0.4.1 

func (m *LogStreamReplicaMetadataRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*LogStreamReplicaMetadataRequest) Marshal added in v0.4.1 

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

func (*LogStreamReplicaMetadataRequest) MarshalTo added in v0.4.1 

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

func (*LogStreamReplicaMetadataRequest) MarshalToSizedBuffer added in v0.4.1 

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

func (*LogStreamReplicaMetadataRequest) ProtoMessage added in v0.4.1 

func (*LogStreamReplicaMetadataRequest) ProtoMessage()

func (*LogStreamReplicaMetadataRequest) ProtoSize added in v0.4.1 

func (m *LogStreamReplicaMetadataRequest) ProtoSize() (n int)

func (*LogStreamReplicaMetadataRequest) Reset added in v0.4.1 

func (m *LogStreamReplicaMetadataRequest) Reset()

func (*LogStreamReplicaMetadataRequest) String added in v0.4.1 

func (m *LogStreamReplicaMetadataRequest) String() string

func (*LogStreamReplicaMetadataRequest) Unmarshal added in v0.4.1 

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

func (*LogStreamReplicaMetadataRequest) XXX_DiscardUnknown added in v0.4.1 

func (m *LogStreamReplicaMetadataRequest) XXX_DiscardUnknown()

func (*LogStreamReplicaMetadataRequest) XXX_Marshal added in v0.4.1 

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

func (*LogStreamReplicaMetadataRequest) XXX_Merge added in v0.4.1 

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

func (*LogStreamReplicaMetadataRequest) XXX_Size added in v0.4.1 

func (m *LogStreamReplicaMetadataRequest) XXX_Size() int

func (*LogStreamReplicaMetadataRequest) XXX_Unmarshal added in v0.4.1 

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

type LogStreamReplicaMetadataResponse added in v0.4.1 

type LogStreamReplicaMetadataResponse struct {
	LogStreamReplica LogStreamReplicaMetadataDescriptor `protobuf:"bytes,1,opt,name=log_stream_replica,json=logStreamReplica,proto3" json:"log_stream_replica"`
}

func (*LogStreamReplicaMetadataResponse) Descriptor added in v0.4.1 

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

func (*LogStreamReplicaMetadataResponse) GetLogStreamReplica added in v0.4.1 

func (m *LogStreamReplicaMetadataResponse) GetLogStreamReplica() LogStreamReplicaMetadataDescriptor

func (*LogStreamReplicaMetadataResponse) Marshal added in v0.4.1 

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

func (*LogStreamReplicaMetadataResponse) MarshalTo added in v0.4.1 

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

func (*LogStreamReplicaMetadataResponse) MarshalToSizedBuffer added in v0.4.1 

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

func (*LogStreamReplicaMetadataResponse) ProtoMessage added in v0.4.1 

func (*LogStreamReplicaMetadataResponse) ProtoMessage()

func (*LogStreamReplicaMetadataResponse) ProtoSize added in v0.4.1 

func (m *LogStreamReplicaMetadataResponse) ProtoSize() (n int)

func (*LogStreamReplicaMetadataResponse) Reset added in v0.4.1 

func (m *LogStreamReplicaMetadataResponse) Reset()

func (*LogStreamReplicaMetadataResponse) String added in v0.4.1 

func (m *LogStreamReplicaMetadataResponse) String() string

func (*LogStreamReplicaMetadataResponse) Unmarshal added in v0.4.1 

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

func (*LogStreamReplicaMetadataResponse) XXX_DiscardUnknown added in v0.4.1 

func (m *LogStreamReplicaMetadataResponse) XXX_DiscardUnknown()

func (*LogStreamReplicaMetadataResponse) XXX_Marshal added in v0.4.1 

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

func (*LogStreamReplicaMetadataResponse) XXX_Merge added in v0.4.1 

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

func (*LogStreamReplicaMetadataResponse) XXX_Size added in v0.4.1 

func (m *LogStreamReplicaMetadataResponse) XXX_Size() int

func (*LogStreamReplicaMetadataResponse) XXX_Unmarshal added in v0.4.1 

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

type LogStreamReporterClient 

type LogStreamReporterClient interface {
	GetReport(ctx context.Context, opts ...grpc.CallOption) (LogStreamReporter_GetReportClient, error)
	Commit(ctx context.Context, opts ...grpc.CallOption) (LogStreamReporter_CommitClient, error)
	CommitBatch(ctx context.Context, opts ...grpc.CallOption) (LogStreamReporter_CommitBatchClient, error)
}

LogStreamReporterClient is the client API for LogStreamReporter service.

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

func NewLogStreamReporterClient 

func NewLogStreamReporterClient(cc *grpc.ClientConn) LogStreamReporterClient

type LogStreamReporterServer 

type LogStreamReporterServer interface {
	GetReport(LogStreamReporter_GetReportServer) error
	Commit(LogStreamReporter_CommitServer) error
	CommitBatch(LogStreamReporter_CommitBatchServer) error
}

LogStreamReporterServer is the server API for LogStreamReporter service.

type LogStreamReporter_CommitBatchClient added in v0.7.0 

type LogStreamReporter_CommitBatchClient interface {
	Send(*CommitBatchRequest) error
	CloseAndRecv() (*CommitBatchResponse, error)
	grpc.ClientStream
}

type LogStreamReporter_CommitBatchServer added in v0.7.0 

type LogStreamReporter_CommitBatchServer interface {
	SendAndClose(*CommitBatchResponse) error
	Recv() (*CommitBatchRequest, error)
	grpc.ServerStream
}

type LogStreamReporter_CommitClient 

type LogStreamReporter_CommitClient interface {
	Send(*CommitRequest) error
	CloseAndRecv() (*CommitResponse, error)
	grpc.ClientStream
}

type LogStreamReporter_CommitServer 

type LogStreamReporter_CommitServer interface {
	SendAndClose(*CommitResponse) error
	Recv() (*CommitRequest, error)
	grpc.ServerStream
}

type LogStreamReporter_GetReportClient 

type LogStreamReporter_GetReportClient interface {
	Send(*GetReportRequest) error
	Recv() (*GetReportResponse, error)
	grpc.ClientStream
}

type LogStreamReporter_GetReportServer 

type LogStreamReporter_GetReportServer interface {
	Send(*GetReportResponse) error
	Recv() (*GetReportRequest, error)
	grpc.ServerStream
}

type LogStreamUncommitReport 

type LogStreamUncommitReport struct {
	LogStreamID           github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
	UncommittedLLSNOffset github_com_kakao_varlog_pkg_types.LLSN        `` /* 175-byte string literal not displayed */
	UncommittedLLSNLength uint64                                        `` /* 127-byte string literal not displayed */
	Version               github_com_kakao_varlog_pkg_types.Version     `protobuf:"varint,4,opt,name=version,proto3,casttype=github.com/kakao/varlog/pkg/types.Version" json:"version,omitempty"`
	HighWatermark         github_com_kakao_varlog_pkg_types.GLSN        `` /* 149-byte string literal not displayed */
}

LogStreamUncommitReport is manifest that log stream reports to metadata repository about log entries those are waiting to commit.

func (*LogStreamUncommitReport) Descriptor 

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

func (*LogStreamUncommitReport) Equal 

func (this *LogStreamUncommitReport) Equal(that interface{}) bool

func (*LogStreamUncommitReport) GetHighWatermark 

func (m *LogStreamUncommitReport) GetHighWatermark() github_com_kakao_varlog_pkg_types.GLSN

func (*LogStreamUncommitReport) GetLogStreamID 

func (m *LogStreamUncommitReport) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*LogStreamUncommitReport) GetUncommittedLLSNLength 

func (m *LogStreamUncommitReport) GetUncommittedLLSNLength() uint64

func (*LogStreamUncommitReport) GetUncommittedLLSNOffset 

func (m *LogStreamUncommitReport) GetUncommittedLLSNOffset() github_com_kakao_varlog_pkg_types.LLSN

func (*LogStreamUncommitReport) GetVersion 

func (m *LogStreamUncommitReport) GetVersion() github_com_kakao_varlog_pkg_types.Version

func (*LogStreamUncommitReport) Invalid added in v0.5.0 

func (m *LogStreamUncommitReport) Invalid() bool

Invalid returns whether the LogStreamUncommitReport is acceptable. LogStreamUncommitReport with invalid logStream or invalid uncommittedLLSNOffset is not acceptable. MetadataRepository ignores these reports.

func (*LogStreamUncommitReport) Marshal 

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

func (*LogStreamUncommitReport) MarshalTo 

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

func (*LogStreamUncommitReport) MarshalToSizedBuffer 

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

func (*LogStreamUncommitReport) ProtoMessage 

func (*LogStreamUncommitReport) ProtoMessage()

func (*LogStreamUncommitReport) ProtoSize 

func (m *LogStreamUncommitReport) ProtoSize() (n int)

func (*LogStreamUncommitReport) Reset 

func (m *LogStreamUncommitReport) Reset()

func (*LogStreamUncommitReport) Seal 

func (m *LogStreamUncommitReport) Seal(end types.LLSN) types.LLSN

func (*LogStreamUncommitReport) String 

func (m *LogStreamUncommitReport) String() string

func (*LogStreamUncommitReport) UncommittedLLSNEnd 

func (m *LogStreamUncommitReport) UncommittedLLSNEnd() types.LLSN

func (*LogStreamUncommitReport) Unmarshal 

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

func (*LogStreamUncommitReport) XXX_DiscardUnknown 

func (m *LogStreamUncommitReport) XXX_DiscardUnknown()

func (*LogStreamUncommitReport) XXX_Marshal 

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

func (*LogStreamUncommitReport) XXX_Merge 

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

func (*LogStreamUncommitReport) XXX_Size 

func (m *LogStreamUncommitReport) XXX_Size() int

func (*LogStreamUncommitReport) XXX_Unmarshal 

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

type ManagementClient 

type ManagementClient interface {
	// GetMetadata returns metadata of StorageNode.
	GetMetadata(ctx context.Context, in *GetMetadataRequest, opts ...grpc.CallOption) (*GetMetadataResponse, error)
	// AddLogStreamReplica adds a new log stream replica to a storage node.
	AddLogStreamReplica(ctx context.Context, in *AddLogStreamReplicaRequest, opts ...grpc.CallOption) (*AddLogStreamReplicaResponse, error)
	// RemoveLogStream removes a LogStream from StorageNode.
	RemoveLogStream(ctx context.Context, in *RemoveLogStreamRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// Seal changes the status of LogStreamExecutor to LogStreamStatusSealing or
	// LogStreamStatusSealed.
	Seal(ctx context.Context, in *SealRequest, opts ...grpc.CallOption) (*SealResponse, error)
	// Unseal changes the status of LogStreamExecutor to LogStreamStatusRunning.
	Unseal(ctx context.Context, in *UnsealRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// Sync starts mirroring between two StorageNodes.
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error)
	Trim(ctx context.Context, in *TrimRequest, opts ...grpc.CallOption) (*TrimResponse, error)
}

ManagementClient is the client API for Management service.

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

func NewManagementClient 

func NewManagementClient(cc *grpc.ClientConn) ManagementClient

type ManagementServer 

type ManagementServer interface {
	// GetMetadata returns metadata of StorageNode.
	GetMetadata(context.Context, *GetMetadataRequest) (*GetMetadataResponse, error)
	// AddLogStreamReplica adds a new log stream replica to a storage node.
	AddLogStreamReplica(context.Context, *AddLogStreamReplicaRequest) (*AddLogStreamReplicaResponse, error)
	// RemoveLogStream removes a LogStream from StorageNode.
	RemoveLogStream(context.Context, *RemoveLogStreamRequest) (*types.Empty, error)
	// Seal changes the status of LogStreamExecutor to LogStreamStatusSealing or
	// LogStreamStatusSealed.
	Seal(context.Context, *SealRequest) (*SealResponse, error)
	// Unseal changes the status of LogStreamExecutor to LogStreamStatusRunning.
	Unseal(context.Context, *UnsealRequest) (*types.Empty, error)
	// Sync starts mirroring between two StorageNodes.
	Sync(context.Context, *SyncRequest) (*SyncResponse, error)
	Trim(context.Context, *TrimRequest) (*TrimResponse, error)
}

ManagementServer is the server API for Management service.

type ReadRequest 

type ReadRequest struct {
	GLSN        github_com_kakao_varlog_pkg_types.GLSN        `protobuf:"varint,1,opt,name=glsn,proto3,casttype=github.com/kakao/varlog/pkg/types.GLSN" json:"glsn,omitempty"`
	TopicID     github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
}

ReadRequest asks a storage node to retrieve log entry at the GLSN.

func (*ReadRequest) Descriptor 

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

func (*ReadRequest) GetGLSN 

func (m *ReadRequest) GetGLSN() github_com_kakao_varlog_pkg_types.GLSN

func (*ReadRequest) GetLogStreamID 

func (m *ReadRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*ReadRequest) GetTopicID 

func (m *ReadRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*ReadRequest) Marshal 

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

func (*ReadRequest) MarshalTo 

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

func (*ReadRequest) MarshalToSizedBuffer 

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

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoSize 

func (m *ReadRequest) ProtoSize() (n int)

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) String 

func (m *ReadRequest) String() string

func (*ReadRequest) Unmarshal 

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

func (*ReadRequest) XXX_DiscardUnknown 

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal 

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

func (*ReadRequest) XXX_Merge 

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

func (*ReadRequest) XXX_Size 

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal 

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

type ReadResponse 

type ReadResponse struct {
	GLSN    github_com_kakao_varlog_pkg_types.GLSN `protobuf:"varint,1,opt,name=glsn,proto3,casttype=github.com/kakao/varlog/pkg/types.GLSN" json:"glsn,omitempty"`
	LLSN    github_com_kakao_varlog_pkg_types.LLSN `protobuf:"varint,2,opt,name=llsn,proto3,casttype=github.com/kakao/varlog/pkg/types.LLSN" json:"llsn,omitempty"`
	Payload []byte                                 `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
}

ReadResponse contains the contents of the log entry which is retrieved by the ReadRequest.

func (*ReadResponse) Descriptor 

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

func (*ReadResponse) GetGLSN 

func (m *ReadResponse) GetGLSN() github_com_kakao_varlog_pkg_types.GLSN

func (*ReadResponse) GetLLSN 

func (m *ReadResponse) GetLLSN() github_com_kakao_varlog_pkg_types.LLSN

func (*ReadResponse) GetPayload 

func (m *ReadResponse) GetPayload() []byte

func (*ReadResponse) Marshal 

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

func (*ReadResponse) MarshalTo 

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

func (*ReadResponse) MarshalToSizedBuffer 

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

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoSize 

func (m *ReadResponse) ProtoSize() (n int)

func (*ReadResponse) Reset 

func (m *ReadResponse) Reset()

func (*ReadResponse) String 

func (m *ReadResponse) String() string

func (*ReadResponse) Unmarshal 

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

func (*ReadResponse) XXX_DiscardUnknown 

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal 

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

func (*ReadResponse) XXX_Merge 

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

func (*ReadResponse) XXX_Size 

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal 

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

type RemoveLogStreamRequest 

type RemoveLogStreamRequest struct {
	ClusterID     github_com_kakao_varlog_pkg_types.ClusterID     `` /* 142-byte string literal not displayed */
	StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	TopicID       github_com_kakao_varlog_pkg_types.TopicID       `` /* 134-byte string literal not displayed */
	LogStreamID   github_com_kakao_varlog_pkg_types.LogStreamID   `` /* 152-byte string literal not displayed */
}

func (*RemoveLogStreamRequest) Descriptor 

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

func (*RemoveLogStreamRequest) GetClusterID 

func (m *RemoveLogStreamRequest) GetClusterID() github_com_kakao_varlog_pkg_types.ClusterID

func (*RemoveLogStreamRequest) GetLogStreamID 

func (m *RemoveLogStreamRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*RemoveLogStreamRequest) GetStorageNodeID 

func (m *RemoveLogStreamRequest) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID

func (*RemoveLogStreamRequest) GetTopicID 

func (m *RemoveLogStreamRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*RemoveLogStreamRequest) Marshal 

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

func (*RemoveLogStreamRequest) MarshalTo 

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

func (*RemoveLogStreamRequest) MarshalToSizedBuffer 

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

func (*RemoveLogStreamRequest) ProtoMessage 

func (*RemoveLogStreamRequest) ProtoMessage()

func (*RemoveLogStreamRequest) ProtoSize 

func (m *RemoveLogStreamRequest) ProtoSize() (n int)

func (*RemoveLogStreamRequest) Reset 

func (m *RemoveLogStreamRequest) Reset()

func (*RemoveLogStreamRequest) String 

func (m *RemoveLogStreamRequest) String() string

func (*RemoveLogStreamRequest) Unmarshal 

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

func (*RemoveLogStreamRequest) XXX_DiscardUnknown 

func (m *RemoveLogStreamRequest) XXX_DiscardUnknown()

func (*RemoveLogStreamRequest) XXX_Marshal 

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

func (*RemoveLogStreamRequest) XXX_Merge 

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

func (*RemoveLogStreamRequest) XXX_Size 

func (m *RemoveLogStreamRequest) XXX_Size() int

func (*RemoveLogStreamRequest) XXX_Unmarshal 

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

type ReplicateRequest 

type ReplicateRequest struct {
	TopicID     github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
	LLSN        []github_com_kakao_varlog_pkg_types.LLSN      `protobuf:"varint,3,rep,packed,name=llsn,proto3,casttype=github.com/kakao/varlog/pkg/types.LLSN" json:"llsn,omitempty"`
	Data        [][]byte                                      `protobuf:"bytes,4,rep,name=data,proto3" json:"data,omitempty"`
}

func (*ReplicateRequest) Descriptor 

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

func (*ReplicateRequest) GetData 

func (m *ReplicateRequest) GetData() [][]byte

func (*ReplicateRequest) GetLLSN 

func (m *ReplicateRequest) GetLLSN() []github_com_kakao_varlog_pkg_types.LLSN

func (*ReplicateRequest) GetLogStreamID 

func (m *ReplicateRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*ReplicateRequest) GetTopicID 

func (m *ReplicateRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*ReplicateRequest) Marshal 

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

func (*ReplicateRequest) MarshalTo 

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

func (*ReplicateRequest) MarshalToSizedBuffer 

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

func (*ReplicateRequest) ProtoMessage 

func (*ReplicateRequest) ProtoMessage()

func (*ReplicateRequest) ProtoSize 

func (m *ReplicateRequest) ProtoSize() (n int)

func (*ReplicateRequest) Reset 

func (m *ReplicateRequest) Reset()

func (*ReplicateRequest) String 

func (m *ReplicateRequest) String() string

func (*ReplicateRequest) Unmarshal 

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

func (*ReplicateRequest) XXX_DiscardUnknown 

func (m *ReplicateRequest) XXX_DiscardUnknown()

func (*ReplicateRequest) XXX_Marshal 

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

func (*ReplicateRequest) XXX_Merge 

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

func (*ReplicateRequest) XXX_Size 

func (m *ReplicateRequest) XXX_Size() int

func (*ReplicateRequest) XXX_Unmarshal 

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

type ReplicateResponse 

type ReplicateResponse struct {
}

func (*ReplicateResponse) Descriptor 

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

func (*ReplicateResponse) Marshal 

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

func (*ReplicateResponse) MarshalTo 

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

func (*ReplicateResponse) MarshalToSizedBuffer 

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

func (*ReplicateResponse) ProtoMessage 

func (*ReplicateResponse) ProtoMessage()

func (*ReplicateResponse) ProtoSize 

func (m *ReplicateResponse) ProtoSize() (n int)

func (*ReplicateResponse) Reset 

func (m *ReplicateResponse) Reset()

func (*ReplicateResponse) String 

func (m *ReplicateResponse) String() string

func (*ReplicateResponse) Unmarshal 

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

func (*ReplicateResponse) XXX_DiscardUnknown 

func (m *ReplicateResponse) XXX_DiscardUnknown()

func (*ReplicateResponse) XXX_Marshal 

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

func (*ReplicateResponse) XXX_Merge 

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

func (*ReplicateResponse) XXX_Size 

func (m *ReplicateResponse) XXX_Size() int

func (*ReplicateResponse) XXX_Unmarshal 

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

type ReplicatorClient 

type ReplicatorClient interface {
	Replicate(ctx context.Context, opts ...grpc.CallOption) (Replicator_ReplicateClient, error)
	SyncInit(ctx context.Context, in *SyncInitRequest, opts ...grpc.CallOption) (*SyncInitResponse, error)
	SyncReplicate(ctx context.Context, in *SyncReplicateRequest, opts ...grpc.CallOption) (*SyncReplicateResponse, error)
}

ReplicatorClient is the client API for Replicator service.

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

func NewReplicatorClient 

func NewReplicatorClient(cc *grpc.ClientConn) ReplicatorClient

type ReplicatorServer 

type ReplicatorServer interface {
	Replicate(Replicator_ReplicateServer) error
	SyncInit(context.Context, *SyncInitRequest) (*SyncInitResponse, error)
	SyncReplicate(context.Context, *SyncReplicateRequest) (*SyncReplicateResponse, error)
}

ReplicatorServer is the server API for Replicator service.

type Replicator_ReplicateClient 

type Replicator_ReplicateClient interface {
	Send(*ReplicateRequest) error
	CloseAndRecv() (*ReplicateResponse, error)
	grpc.ClientStream
}

type Replicator_ReplicateServer 

type Replicator_ReplicateServer interface {
	SendAndClose(*ReplicateResponse) error
	Recv() (*ReplicateRequest, error)
	grpc.ServerStream
}

type SealRequest 

type SealRequest struct {
	ClusterID         github_com_kakao_varlog_pkg_types.ClusterID     `` /* 142-byte string literal not displayed */
	StorageNodeID     github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	TopicID           github_com_kakao_varlog_pkg_types.TopicID       `` /* 134-byte string literal not displayed */
	LogStreamID       github_com_kakao_varlog_pkg_types.LogStreamID   `` /* 152-byte string literal not displayed */
	LastCommittedGLSN github_com_kakao_varlog_pkg_types.GLSN          `` /* 163-byte string literal not displayed */
}

func (*SealRequest) Descriptor 

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

func (*SealRequest) GetClusterID 

func (m *SealRequest) GetClusterID() github_com_kakao_varlog_pkg_types.ClusterID

func (*SealRequest) GetLastCommittedGLSN 

func (m *SealRequest) GetLastCommittedGLSN() github_com_kakao_varlog_pkg_types.GLSN

func (*SealRequest) GetLogStreamID 

func (m *SealRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*SealRequest) GetStorageNodeID 

func (m *SealRequest) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID

func (*SealRequest) GetTopicID 

func (m *SealRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*SealRequest) Marshal 

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

func (*SealRequest) MarshalTo 

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

func (*SealRequest) MarshalToSizedBuffer 

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

func (*SealRequest) ProtoMessage 

func (*SealRequest) ProtoMessage()

func (*SealRequest) ProtoSize 

func (m *SealRequest) ProtoSize() (n int)

func (*SealRequest) Reset 

func (m *SealRequest) Reset()

func (*SealRequest) String 

func (m *SealRequest) String() string

func (*SealRequest) Unmarshal 

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

func (*SealRequest) XXX_DiscardUnknown 

func (m *SealRequest) XXX_DiscardUnknown()

func (*SealRequest) XXX_Marshal 

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

func (*SealRequest) XXX_Merge 

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

func (*SealRequest) XXX_Size 

func (m *SealRequest) XXX_Size() int

func (*SealRequest) XXX_Unmarshal 

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

type SealResponse 

type SealResponse struct {
	Status            varlogpb.LogStreamStatus               `protobuf:"varint,1,opt,name=status,proto3,enum=varlog.varlogpb.LogStreamStatus" json:"status,omitempty"`
	LastCommittedGLSN github_com_kakao_varlog_pkg_types.GLSN `` /* 163-byte string literal not displayed */
}

func (*SealResponse) Descriptor 

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

func (*SealResponse) GetLastCommittedGLSN 

func (m *SealResponse) GetLastCommittedGLSN() github_com_kakao_varlog_pkg_types.GLSN

func (*SealResponse) GetStatus 

func (m *SealResponse) GetStatus() varlogpb.LogStreamStatus

func (*SealResponse) Marshal 

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

func (*SealResponse) MarshalTo 

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

func (*SealResponse) MarshalToSizedBuffer 

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

func (*SealResponse) ProtoMessage 

func (*SealResponse) ProtoMessage()

func (*SealResponse) ProtoSize 

func (m *SealResponse) ProtoSize() (n int)

func (*SealResponse) Reset 

func (m *SealResponse) Reset()

func (*SealResponse) String 

func (m *SealResponse) String() string

func (*SealResponse) Unmarshal 

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

func (*SealResponse) XXX_DiscardUnknown 

func (m *SealResponse) XXX_DiscardUnknown()

func (*SealResponse) XXX_Marshal 

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

func (*SealResponse) XXX_Merge 

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

func (*SealResponse) XXX_Size 

func (m *SealResponse) XXX_Size() int

func (*SealResponse) XXX_Unmarshal 

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

type StorageNodeMetadataDescriptor 

type StorageNodeMetadataDescriptor struct {
	// ClusterID is the identifier of the cluster.
	ClusterID            github_com_kakao_varlog_pkg_types.ClusterID `` /* 131-byte string literal not displayed */
	varlogpb.StorageNode `protobuf:"bytes,2,opt,name=storage_node,json=storageNode,proto3,embedded=storage_node" json:""`
	Storages             []varlogpb.StorageDescriptor `protobuf:"bytes,3,rep,name=storages,proto3" json:"storages"`
	// LogStreams are the list of metadata for log stream replicas.
	LogStreamReplicas []LogStreamReplicaMetadataDescriptor `protobuf:"bytes,4,rep,name=log_stream_replicas,json=logStreamReplicas,proto3" json:"logStreams"`
	Status            varlogpb.StorageNodeStatus           `protobuf:"varint,5,opt,name=status,proto3,enum=varlog.varlogpb.StorageNodeStatus" json:"status,omitempty"`
	StartTime         time.Time                            `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3,stdtime" json:"startTime"`
}

StorageNodeMetadataDescriptor is the metadata of the storage node. It contains mutable properties, for instance, usage of storage, log streams, etc.

func (*StorageNodeMetadataDescriptor) Descriptor 

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

func (*StorageNodeMetadataDescriptor) Equal 

func (this *StorageNodeMetadataDescriptor) Equal(that interface{}) bool

func (StorageNodeMetadataDescriptor) FindLogStream 

func (snmd StorageNodeMetadataDescriptor) FindLogStream(logStreamID types.LogStreamID) (LogStreamReplicaMetadataDescriptor, bool)

func (*StorageNodeMetadataDescriptor) GetClusterID 

func (m *StorageNodeMetadataDescriptor) GetClusterID() github_com_kakao_varlog_pkg_types.ClusterID

func (*StorageNodeMetadataDescriptor) GetLogStream 

func (snmd *StorageNodeMetadataDescriptor) GetLogStream(logStreamID types.LogStreamID) (LogStreamReplicaMetadataDescriptor, bool)

func (*StorageNodeMetadataDescriptor) GetLogStreamReplicas 

func (m *StorageNodeMetadataDescriptor) GetLogStreamReplicas() []LogStreamReplicaMetadataDescriptor

func (*StorageNodeMetadataDescriptor) GetStartTime 

func (m *StorageNodeMetadataDescriptor) GetStartTime() time.Time

func (*StorageNodeMetadataDescriptor) GetStatus 

func (m *StorageNodeMetadataDescriptor) GetStatus() varlogpb.StorageNodeStatus

func (*StorageNodeMetadataDescriptor) GetStorages 

func (m *StorageNodeMetadataDescriptor) GetStorages() []varlogpb.StorageDescriptor

func (*StorageNodeMetadataDescriptor) Marshal 

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

func (*StorageNodeMetadataDescriptor) MarshalTo 

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

func (*StorageNodeMetadataDescriptor) MarshalToSizedBuffer 

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

func (*StorageNodeMetadataDescriptor) ProtoMessage 

func (*StorageNodeMetadataDescriptor) ProtoMessage()

func (*StorageNodeMetadataDescriptor) ProtoSize 

func (m *StorageNodeMetadataDescriptor) ProtoSize() (n int)

func (*StorageNodeMetadataDescriptor) Reset 

func (m *StorageNodeMetadataDescriptor) Reset()

func (*StorageNodeMetadataDescriptor) String 

func (m *StorageNodeMetadataDescriptor) String() string

func (*StorageNodeMetadataDescriptor) ToStorageNodeDescriptor 

func (snmd *StorageNodeMetadataDescriptor) ToStorageNodeDescriptor() *varlogpb.StorageNodeDescriptor

func (*StorageNodeMetadataDescriptor) Unmarshal 

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

func (*StorageNodeMetadataDescriptor) XXX_DiscardUnknown 

func (m *StorageNodeMetadataDescriptor) XXX_DiscardUnknown()

func (*StorageNodeMetadataDescriptor) XXX_Marshal 

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

func (*StorageNodeMetadataDescriptor) XXX_Merge 

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

func (*StorageNodeMetadataDescriptor) XXX_Size 

func (m *StorageNodeMetadataDescriptor) XXX_Size() int

func (*StorageNodeMetadataDescriptor) XXX_Unmarshal 

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

type SubscribeRequest 

type SubscribeRequest struct {
	GLSNBegin   github_com_kakao_varlog_pkg_types.GLSN        `` /* 137-byte string literal not displayed */
	GLSNEnd     github_com_kakao_varlog_pkg_types.GLSN        `` /* 131-byte string literal not displayed */
	TopicID     github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
}

SubscribeRequest has GLSN which indicates an inclusive starting position from which a client wants to receive.

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) GetGLSNBegin 

func (m *SubscribeRequest) GetGLSNBegin() github_com_kakao_varlog_pkg_types.GLSN

func (*SubscribeRequest) GetGLSNEnd 

func (m *SubscribeRequest) GetGLSNEnd() github_com_kakao_varlog_pkg_types.GLSN

func (*SubscribeRequest) GetLogStreamID 

func (m *SubscribeRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*SubscribeRequest) GetTopicID 

func (m *SubscribeRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*SubscribeRequest) Marshal 

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

func (*SubscribeRequest) MarshalTo 

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

func (*SubscribeRequest) MarshalToSizedBuffer 

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

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoSize 

func (m *SubscribeRequest) ProtoSize() (n int)

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) Unmarshal 

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

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

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

func (*SubscribeRequest) XXX_Merge 

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

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

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

type SubscribeResponse 

type SubscribeResponse struct {
	GLSN    github_com_kakao_varlog_pkg_types.GLSN `protobuf:"varint,1,opt,name=glsn,proto3,casttype=github.com/kakao/varlog/pkg/types.GLSN" json:"glsn,omitempty"`
	LLSN    github_com_kakao_varlog_pkg_types.LLSN `protobuf:"varint,2,opt,name=llsn,proto3,casttype=github.com/kakao/varlog/pkg/types.LLSN" json:"llsn,omitempty"`
	Payload []byte                                 `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
}

SubscribeResponse comprises the contents of the log entry and its GLSN.

func (*SubscribeResponse) Descriptor 

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

func (*SubscribeResponse) GetGLSN 

func (m *SubscribeResponse) GetGLSN() github_com_kakao_varlog_pkg_types.GLSN

func (*SubscribeResponse) GetLLSN 

func (m *SubscribeResponse) GetLLSN() github_com_kakao_varlog_pkg_types.LLSN

func (*SubscribeResponse) GetPayload 

func (m *SubscribeResponse) GetPayload() []byte

func (*SubscribeResponse) Marshal 

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

func (*SubscribeResponse) MarshalTo 

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

func (*SubscribeResponse) MarshalToSizedBuffer 

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

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoSize 

func (m *SubscribeResponse) ProtoSize() (n int)

func (*SubscribeResponse) Reset 

func (m *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (m *SubscribeResponse) String() string

func (*SubscribeResponse) Unmarshal 

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

func (*SubscribeResponse) XXX_DiscardUnknown 

func (m *SubscribeResponse) XXX_DiscardUnknown()

func (*SubscribeResponse) XXX_Marshal 

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

func (*SubscribeResponse) XXX_Merge 

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

func (*SubscribeResponse) XXX_Size 

func (m *SubscribeResponse) XXX_Size() int

func (*SubscribeResponse) XXX_Unmarshal 

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

type SubscribeToRequest 

type SubscribeToRequest struct {
	TopicID     github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
	LLSNBegin   github_com_kakao_varlog_pkg_types.LLSN        `` /* 137-byte string literal not displayed */
	LLSNEnd     github_com_kakao_varlog_pkg_types.LLSN        `` /* 131-byte string literal not displayed */
}

func (*SubscribeToRequest) Descriptor 

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

func (*SubscribeToRequest) GetLLSNBegin 

func (m *SubscribeToRequest) GetLLSNBegin() github_com_kakao_varlog_pkg_types.LLSN

func (*SubscribeToRequest) GetLLSNEnd 

func (m *SubscribeToRequest) GetLLSNEnd() github_com_kakao_varlog_pkg_types.LLSN

func (*SubscribeToRequest) GetLogStreamID 

func (m *SubscribeToRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*SubscribeToRequest) GetTopicID 

func (m *SubscribeToRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*SubscribeToRequest) Marshal 

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

func (*SubscribeToRequest) MarshalTo 

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

func (*SubscribeToRequest) MarshalToSizedBuffer 

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

func (*SubscribeToRequest) ProtoMessage 

func (*SubscribeToRequest) ProtoMessage()

func (*SubscribeToRequest) ProtoSize 

func (m *SubscribeToRequest) ProtoSize() (n int)

func (*SubscribeToRequest) Reset 

func (m *SubscribeToRequest) Reset()

func (*SubscribeToRequest) String 

func (m *SubscribeToRequest) String() string

func (*SubscribeToRequest) Unmarshal 

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

func (*SubscribeToRequest) XXX_DiscardUnknown 

func (m *SubscribeToRequest) XXX_DiscardUnknown()

func (*SubscribeToRequest) XXX_Marshal 

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

func (*SubscribeToRequest) XXX_Merge 

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

func (*SubscribeToRequest) XXX_Size 

func (m *SubscribeToRequest) XXX_Size() int

func (*SubscribeToRequest) XXX_Unmarshal 

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

type SubscribeToResponse 

type SubscribeToResponse struct {
	LogEntry varlogpb.LogEntry `protobuf:"bytes,1,opt,name=log_entry,json=logEntry,proto3" json:"log_entry"`
}

func (*SubscribeToResponse) Descriptor 

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

func (*SubscribeToResponse) GetLogEntry 

func (m *SubscribeToResponse) GetLogEntry() varlogpb.LogEntry

func (*SubscribeToResponse) Marshal 

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

func (*SubscribeToResponse) MarshalTo 

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

func (*SubscribeToResponse) MarshalToSizedBuffer 

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

func (*SubscribeToResponse) ProtoMessage 

func (*SubscribeToResponse) ProtoMessage()

func (*SubscribeToResponse) ProtoSize 

func (m *SubscribeToResponse) ProtoSize() (n int)

func (*SubscribeToResponse) Reset 

func (m *SubscribeToResponse) Reset()

func (*SubscribeToResponse) String 

func (m *SubscribeToResponse) String() string

func (*SubscribeToResponse) Unmarshal 

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

func (*SubscribeToResponse) XXX_DiscardUnknown 

func (m *SubscribeToResponse) XXX_DiscardUnknown()

func (*SubscribeToResponse) XXX_Marshal 

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

func (*SubscribeToResponse) XXX_Merge 

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

func (*SubscribeToResponse) XXX_Size 

func (m *SubscribeToResponse) XXX_Size() int

func (*SubscribeToResponse) XXX_Unmarshal 

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

type SyncInitRequest 

type SyncInitRequest struct {
	ClusterID   github_com_kakao_varlog_pkg_types.ClusterID `` /* 142-byte string literal not displayed */
	Source      varlogpb.LogStreamReplica                   `protobuf:"bytes,2,opt,name=source,proto3" json:"source"`
	Destination varlogpb.LogStreamReplica                   `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination"`
	Range       SyncRange                                   `protobuf:"bytes,4,opt,name=range,proto3" json:"range"`
}

func (*SyncInitRequest) Descriptor 

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

func (*SyncInitRequest) GetClusterID 

func (m *SyncInitRequest) GetClusterID() github_com_kakao_varlog_pkg_types.ClusterID

func (*SyncInitRequest) GetDestination 

func (m *SyncInitRequest) GetDestination() varlogpb.LogStreamReplica

func (*SyncInitRequest) GetRange 

func (m *SyncInitRequest) GetRange() SyncRange

func (*SyncInitRequest) GetSource 

func (m *SyncInitRequest) GetSource() varlogpb.LogStreamReplica

func (*SyncInitRequest) Marshal 

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

func (*SyncInitRequest) MarshalTo 

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

func (*SyncInitRequest) MarshalToSizedBuffer 

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

func (*SyncInitRequest) ProtoMessage 

func (*SyncInitRequest) ProtoMessage()

func (*SyncInitRequest) ProtoSize 

func (m *SyncInitRequest) ProtoSize() (n int)

func (*SyncInitRequest) Reset 

func (m *SyncInitRequest) Reset()

func (*SyncInitRequest) String 

func (m *SyncInitRequest) String() string

func (*SyncInitRequest) Unmarshal 

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

func (*SyncInitRequest) XXX_DiscardUnknown 

func (m *SyncInitRequest) XXX_DiscardUnknown()

func (*SyncInitRequest) XXX_Marshal 

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

func (*SyncInitRequest) XXX_Merge 

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

func (*SyncInitRequest) XXX_Size 

func (m *SyncInitRequest) XXX_Size() int

func (*SyncInitRequest) XXX_Unmarshal 

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

type SyncInitResponse 

type SyncInitResponse struct {
	Range SyncRange `protobuf:"bytes,1,opt,name=range,proto3" json:"range"`
}

func (*SyncInitResponse) Descriptor 

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

func (*SyncInitResponse) GetRange 

func (m *SyncInitResponse) GetRange() SyncRange

func (*SyncInitResponse) Marshal 

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

func (*SyncInitResponse) MarshalTo 

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

func (*SyncInitResponse) MarshalToSizedBuffer 

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

func (*SyncInitResponse) ProtoMessage 

func (*SyncInitResponse) ProtoMessage()

func (*SyncInitResponse) ProtoSize 

func (m *SyncInitResponse) ProtoSize() (n int)

func (*SyncInitResponse) Reset 

func (m *SyncInitResponse) Reset()

func (*SyncInitResponse) String 

func (m *SyncInitResponse) String() string

func (*SyncInitResponse) Unmarshal 

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

func (*SyncInitResponse) XXX_DiscardUnknown 

func (m *SyncInitResponse) XXX_DiscardUnknown()

func (*SyncInitResponse) XXX_Marshal 

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

func (*SyncInitResponse) XXX_Merge 

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

func (*SyncInitResponse) XXX_Size 

func (m *SyncInitResponse) XXX_Size() int

func (*SyncInitResponse) XXX_Unmarshal 

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

type SyncPayload 

type SyncPayload struct {
	CommitContext *varlogpb.CommitContext `protobuf:"bytes,1,opt,name=commit_context,json=commitContext,proto3" json:"commit_context,omitempty"`
	LogEntry      *varlogpb.LogEntry      `protobuf:"bytes,2,opt,name=log_entry,json=logEntry,proto3" json:"log_entry,omitempty"`
}

func (*SyncPayload) Descriptor 

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

func (*SyncPayload) GetCommitContext 

func (m *SyncPayload) GetCommitContext() *varlogpb.CommitContext

func (*SyncPayload) GetLogEntry 

func (m *SyncPayload) GetLogEntry() *varlogpb.LogEntry

func (*SyncPayload) GetValue 

func (this *SyncPayload) GetValue() interface{}

func (*SyncPayload) Marshal 

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

func (*SyncPayload) MarshalTo 

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

func (*SyncPayload) MarshalToSizedBuffer 

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

func (*SyncPayload) ProtoMessage 

func (*SyncPayload) ProtoMessage()

func (*SyncPayload) ProtoSize 

func (m *SyncPayload) ProtoSize() (n int)

func (*SyncPayload) Reset 

func (m *SyncPayload) Reset()

func (*SyncPayload) SetValue 

func (this *SyncPayload) SetValue(value interface{}) bool

func (*SyncPayload) String 

func (m *SyncPayload) String() string

func (*SyncPayload) Unmarshal 

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

func (*SyncPayload) XXX_DiscardUnknown 

func (m *SyncPayload) XXX_DiscardUnknown()

func (*SyncPayload) XXX_Marshal 

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

func (*SyncPayload) XXX_Merge 

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

func (*SyncPayload) XXX_Size 

func (m *SyncPayload) XXX_Size() int

func (*SyncPayload) XXX_Unmarshal 

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

type SyncPosition 

type SyncPosition struct {
	LLSN github_com_kakao_varlog_pkg_types.LLSN `protobuf:"varint,1,opt,name=llsn,proto3,casttype=github.com/kakao/varlog/pkg/types.LLSN" json:"llsn,omitempty"`
	GLSN github_com_kakao_varlog_pkg_types.GLSN `protobuf:"varint,2,opt,name=glsn,proto3,casttype=github.com/kakao/varlog/pkg/types.GLSN" json:"glsn,omitempty"`
}

func InvalidSyncPosition 

func InvalidSyncPosition() SyncPosition

func (*SyncPosition) Descriptor 

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

func (*SyncPosition) Equal 

func (this *SyncPosition) Equal(that interface{}) bool

func (*SyncPosition) GetGLSN 

func (m *SyncPosition) GetGLSN() github_com_kakao_varlog_pkg_types.GLSN

func (*SyncPosition) GetLLSN 

func (m *SyncPosition) GetLLSN() github_com_kakao_varlog_pkg_types.LLSN

func (SyncPosition) Invalid 

func (sp SyncPosition) Invalid() bool

func (SyncPosition) LessThan 

func (sp SyncPosition) LessThan(other SyncPosition) bool

func (*SyncPosition) Marshal 

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

func (*SyncPosition) MarshalTo 

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

func (*SyncPosition) MarshalToSizedBuffer 

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

func (*SyncPosition) ProtoMessage 

func (*SyncPosition) ProtoMessage()

func (*SyncPosition) ProtoSize 

func (m *SyncPosition) ProtoSize() (n int)

func (*SyncPosition) Reset 

func (m *SyncPosition) Reset()

func (*SyncPosition) String 

func (m *SyncPosition) String() string

func (*SyncPosition) Unmarshal 

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

func (*SyncPosition) XXX_DiscardUnknown 

func (m *SyncPosition) XXX_DiscardUnknown()

func (*SyncPosition) XXX_Marshal 

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

func (*SyncPosition) XXX_Merge 

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

func (*SyncPosition) XXX_Size 

func (m *SyncPosition) XXX_Size() int

func (*SyncPosition) XXX_Unmarshal 

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

type SyncRange 

type SyncRange struct {
	FirstLLSN github_com_kakao_varlog_pkg_types.LLSN `` /* 137-byte string literal not displayed */
	LastLLSN  github_com_kakao_varlog_pkg_types.LLSN `` /* 134-byte string literal not displayed */
}

func InvalidSyncRange 

func InvalidSyncRange() SyncRange

func (*SyncRange) Descriptor 

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

func (*SyncRange) GetFirstLLSN 

func (m *SyncRange) GetFirstLLSN() github_com_kakao_varlog_pkg_types.LLSN

func (*SyncRange) GetLastLLSN 

func (m *SyncRange) GetLastLLSN() github_com_kakao_varlog_pkg_types.LLSN

func (SyncRange) Invalid 

func (sr SyncRange) Invalid() bool

func (*SyncRange) Marshal 

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

func (*SyncRange) MarshalTo 

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

func (*SyncRange) MarshalToSizedBuffer 

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

func (*SyncRange) ProtoMessage 

func (*SyncRange) ProtoMessage()

func (*SyncRange) ProtoSize 

func (m *SyncRange) ProtoSize() (n int)

func (*SyncRange) Reset 

func (m *SyncRange) Reset()

func (*SyncRange) String 

func (m *SyncRange) String() string

func (*SyncRange) Unmarshal 

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

func (*SyncRange) XXX_DiscardUnknown 

func (m *SyncRange) XXX_DiscardUnknown()

func (*SyncRange) XXX_Marshal 

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

func (*SyncRange) XXX_Merge 

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

func (*SyncRange) XXX_Size 

func (m *SyncRange) XXX_Size() int

func (*SyncRange) XXX_Unmarshal 

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

type SyncReplicateRequest 

type SyncReplicateRequest struct {
	ClusterID   github_com_kakao_varlog_pkg_types.ClusterID `` /* 142-byte string literal not displayed */
	Source      varlogpb.LogStreamReplica                   `protobuf:"bytes,2,opt,name=source,proto3" json:"source"`
	Destination varlogpb.LogStreamReplica                   `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination"`
	Payload     SyncPayload                                 `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload"`
}

func (*SyncReplicateRequest) Descriptor 

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

func (*SyncReplicateRequest) GetClusterID 

func (m *SyncReplicateRequest) GetClusterID() github_com_kakao_varlog_pkg_types.ClusterID

func (*SyncReplicateRequest) GetDestination 

func (m *SyncReplicateRequest) GetDestination() varlogpb.LogStreamReplica

func (*SyncReplicateRequest) GetPayload 

func (m *SyncReplicateRequest) GetPayload() SyncPayload

func (*SyncReplicateRequest) GetSource 

func (m *SyncReplicateRequest) GetSource() varlogpb.LogStreamReplica

func (*SyncReplicateRequest) Marshal 

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

func (*SyncReplicateRequest) MarshalTo 

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

func (*SyncReplicateRequest) MarshalToSizedBuffer 

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

func (*SyncReplicateRequest) ProtoMessage 

func (*SyncReplicateRequest) ProtoMessage()

func (*SyncReplicateRequest) ProtoSize 

func (m *SyncReplicateRequest) ProtoSize() (n int)

func (*SyncReplicateRequest) Reset 

func (m *SyncReplicateRequest) Reset()

func (*SyncReplicateRequest) String 

func (m *SyncReplicateRequest) String() string

func (*SyncReplicateRequest) Unmarshal 

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

func (*SyncReplicateRequest) XXX_DiscardUnknown 

func (m *SyncReplicateRequest) XXX_DiscardUnknown()

func (*SyncReplicateRequest) XXX_Marshal 

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

func (*SyncReplicateRequest) XXX_Merge 

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

func (*SyncReplicateRequest) XXX_Size 

func (m *SyncReplicateRequest) XXX_Size() int

func (*SyncReplicateRequest) XXX_Unmarshal 

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

type SyncReplicateResponse 

type SyncReplicateResponse struct {
	Status *SyncStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
}

func (*SyncReplicateResponse) Descriptor 

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

func (*SyncReplicateResponse) GetStatus 

func (m *SyncReplicateResponse) GetStatus() *SyncStatus

func (*SyncReplicateResponse) Marshal 

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

func (*SyncReplicateResponse) MarshalTo 

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

func (*SyncReplicateResponse) MarshalToSizedBuffer 

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

func (*SyncReplicateResponse) ProtoMessage 

func (*SyncReplicateResponse) ProtoMessage()

func (*SyncReplicateResponse) ProtoSize 

func (m *SyncReplicateResponse) ProtoSize() (n int)

func (*SyncReplicateResponse) Reset 

func (m *SyncReplicateResponse) Reset()

func (*SyncReplicateResponse) String 

func (m *SyncReplicateResponse) String() string

func (*SyncReplicateResponse) Unmarshal 

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

func (*SyncReplicateResponse) XXX_DiscardUnknown 

func (m *SyncReplicateResponse) XXX_DiscardUnknown()

func (*SyncReplicateResponse) XXX_Marshal 

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

func (*SyncReplicateResponse) XXX_Merge 

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

func (*SyncReplicateResponse) XXX_Size 

func (m *SyncReplicateResponse) XXX_Size() int

func (*SyncReplicateResponse) XXX_Unmarshal 

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

type SyncRequest 

type SyncRequest struct {
	ClusterID     github_com_kakao_varlog_pkg_types.ClusterID     `` /* 142-byte string literal not displayed */
	StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	TopicID       github_com_kakao_varlog_pkg_types.TopicID       `` /* 134-byte string literal not displayed */
	LogStreamID   github_com_kakao_varlog_pkg_types.LogStreamID   `` /* 152-byte string literal not displayed */
	Backup        *SyncRequest_BackupNode                         `protobuf:"bytes,5,opt,name=backup,proto3" json:"backup,omitempty"`
}

func (*SyncRequest) Descriptor 

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

func (*SyncRequest) GetBackup 

func (m *SyncRequest) GetBackup() *SyncRequest_BackupNode

func (*SyncRequest) GetClusterID 

func (m *SyncRequest) GetClusterID() github_com_kakao_varlog_pkg_types.ClusterID

func (*SyncRequest) GetLogStreamID 

func (m *SyncRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*SyncRequest) GetStorageNodeID 

func (m *SyncRequest) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID

func (*SyncRequest) GetTopicID 

func (m *SyncRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*SyncRequest) Marshal 

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

func (*SyncRequest) MarshalTo 

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

func (*SyncRequest) MarshalToSizedBuffer 

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

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) ProtoSize 

func (m *SyncRequest) ProtoSize() (n int)

func (*SyncRequest) Reset 

func (m *SyncRequest) Reset()

func (*SyncRequest) String 

func (m *SyncRequest) String() string

func (*SyncRequest) Unmarshal 

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

func (*SyncRequest) XXX_DiscardUnknown 

func (m *SyncRequest) XXX_DiscardUnknown()

func (*SyncRequest) XXX_Marshal 

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

func (*SyncRequest) XXX_Merge 

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

func (*SyncRequest) XXX_Size 

func (m *SyncRequest) XXX_Size() int

func (*SyncRequest) XXX_Unmarshal 

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

type SyncRequest_BackupNode 

type SyncRequest_BackupNode struct {
	StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	Address       string                                          `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
}

FIXME: Use Replica instead of BackupNode

func (*SyncRequest_BackupNode) Descriptor 

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

func (*SyncRequest_BackupNode) GetAddress 

func (m *SyncRequest_BackupNode) GetAddress() string

func (*SyncRequest_BackupNode) GetStorageNodeID 

func (m *SyncRequest_BackupNode) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID

func (*SyncRequest_BackupNode) Marshal 

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

func (*SyncRequest_BackupNode) MarshalTo 

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

func (*SyncRequest_BackupNode) MarshalToSizedBuffer 

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

func (*SyncRequest_BackupNode) ProtoMessage 

func (*SyncRequest_BackupNode) ProtoMessage()

func (*SyncRequest_BackupNode) ProtoSize 

func (m *SyncRequest_BackupNode) ProtoSize() (n int)

func (*SyncRequest_BackupNode) Reset 

func (m *SyncRequest_BackupNode) Reset()

func (*SyncRequest_BackupNode) String 

func (m *SyncRequest_BackupNode) String() string

func (*SyncRequest_BackupNode) Unmarshal 

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

func (*SyncRequest_BackupNode) XXX_DiscardUnknown 

func (m *SyncRequest_BackupNode) XXX_DiscardUnknown()

func (*SyncRequest_BackupNode) XXX_Marshal 

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

func (*SyncRequest_BackupNode) XXX_Merge 

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

func (*SyncRequest_BackupNode) XXX_Size 

func (m *SyncRequest_BackupNode) XXX_Size() int

func (*SyncRequest_BackupNode) XXX_Unmarshal 

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

type SyncResponse 

type SyncResponse struct {
	Status *SyncStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
}

func (*SyncResponse) Descriptor 

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

func (*SyncResponse) GetStatus 

func (m *SyncResponse) GetStatus() *SyncStatus

func (*SyncResponse) Marshal 

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

func (*SyncResponse) MarshalTo 

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

func (*SyncResponse) MarshalToSizedBuffer 

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

func (*SyncResponse) ProtoMessage 

func (*SyncResponse) ProtoMessage()

func (*SyncResponse) ProtoSize 

func (m *SyncResponse) ProtoSize() (n int)

func (*SyncResponse) Reset 

func (m *SyncResponse) Reset()

func (*SyncResponse) String 

func (m *SyncResponse) String() string

func (*SyncResponse) Unmarshal 

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

func (*SyncResponse) XXX_DiscardUnknown 

func (m *SyncResponse) XXX_DiscardUnknown()

func (*SyncResponse) XXX_Marshal 

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

func (*SyncResponse) XXX_Merge 

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

func (*SyncResponse) XXX_Size 

func (m *SyncResponse) XXX_Size() int

func (*SyncResponse) XXX_Unmarshal 

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

type SyncState 

type SyncState int32
const (
	SyncStateError      SyncState = 0
	SyncStateInProgress SyncState = 1
	SyncStateComplete   SyncState = 2
)

func (SyncState) EnumDescriptor 

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

func (SyncState) String 

func (x SyncState) String() string

type SyncStatus 

type SyncStatus struct {
	State   SyncState    `protobuf:"varint,1,opt,name=state,proto3,enum=varlog.snpb.SyncState" json:"state,omitempty"`
	First   SyncPosition `protobuf:"bytes,2,opt,name=first,proto3" json:"first"`
	Last    SyncPosition `protobuf:"bytes,3,opt,name=last,proto3" json:"last"`
	Current SyncPosition `protobuf:"bytes,4,opt,name=current,proto3" json:"current"`
}

func (*SyncStatus) Descriptor 

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

func (*SyncStatus) GetCurrent 

func (m *SyncStatus) GetCurrent() SyncPosition

func (*SyncStatus) GetFirst 

func (m *SyncStatus) GetFirst() SyncPosition

func (*SyncStatus) GetLast 

func (m *SyncStatus) GetLast() SyncPosition

func (*SyncStatus) GetState 

func (m *SyncStatus) GetState() SyncState

func (*SyncStatus) Marshal 

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

func (*SyncStatus) MarshalTo 

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

func (*SyncStatus) MarshalToSizedBuffer 

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

func (*SyncStatus) ProtoMessage 

func (*SyncStatus) ProtoMessage()

func (*SyncStatus) ProtoSize 

func (m *SyncStatus) ProtoSize() (n int)

func (*SyncStatus) Reset 

func (m *SyncStatus) Reset()

func (*SyncStatus) String 

func (m *SyncStatus) String() string

func (*SyncStatus) Unmarshal 

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

func (*SyncStatus) XXX_DiscardUnknown 

func (m *SyncStatus) XXX_DiscardUnknown()

func (*SyncStatus) XXX_Marshal 

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

func (*SyncStatus) XXX_Merge 

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

func (*SyncStatus) XXX_Size 

func (m *SyncStatus) XXX_Size() int

func (*SyncStatus) XXX_Unmarshal 

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

type TrimDeprecatedRequest 

type TrimDeprecatedRequest struct {
	TopicID github_com_kakao_varlog_pkg_types.TopicID `` /* 134-byte string literal not displayed */
	GLSN    github_com_kakao_varlog_pkg_types.GLSN    `protobuf:"varint,2,opt,name=glsn,proto3,casttype=github.com/kakao/varlog/pkg/types.GLSN" json:"glsn,omitempty"`
}

TrimRequest contains inclusive GLSN until which a client wants to delete. If async field is true, the trim operation returns immediately and the storage node removes its log entry in the background.

func (*TrimDeprecatedRequest) Descriptor 

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

func (*TrimDeprecatedRequest) GetGLSN 

func (m *TrimDeprecatedRequest) GetGLSN() github_com_kakao_varlog_pkg_types.GLSN

func (*TrimDeprecatedRequest) GetTopicID 

func (m *TrimDeprecatedRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*TrimDeprecatedRequest) Marshal 

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

func (*TrimDeprecatedRequest) MarshalTo 

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

func (*TrimDeprecatedRequest) MarshalToSizedBuffer 

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

func (*TrimDeprecatedRequest) ProtoMessage 

func (*TrimDeprecatedRequest) ProtoMessage()

func (*TrimDeprecatedRequest) ProtoSize 

func (m *TrimDeprecatedRequest) ProtoSize() (n int)

func (*TrimDeprecatedRequest) Reset 

func (m *TrimDeprecatedRequest) Reset()

func (*TrimDeprecatedRequest) String 

func (m *TrimDeprecatedRequest) String() string

func (*TrimDeprecatedRequest) Unmarshal 

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

func (*TrimDeprecatedRequest) XXX_DiscardUnknown 

func (m *TrimDeprecatedRequest) XXX_DiscardUnknown()

func (*TrimDeprecatedRequest) XXX_Marshal 

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

func (*TrimDeprecatedRequest) XXX_Merge 

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

func (*TrimDeprecatedRequest) XXX_Size 

func (m *TrimDeprecatedRequest) XXX_Size() int

func (*TrimDeprecatedRequest) XXX_Unmarshal 

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

type TrimRequest 

type TrimRequest struct {
	TopicID  github_com_kakao_varlog_pkg_types.TopicID `` /* 134-byte string literal not displayed */
	LastGLSN github_com_kakao_varlog_pkg_types.GLSN    `` /* 134-byte string literal not displayed */
}

func (*TrimRequest) Descriptor 

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

func (*TrimRequest) GetLastGLSN 

func (m *TrimRequest) GetLastGLSN() github_com_kakao_varlog_pkg_types.GLSN

func (*TrimRequest) GetTopicID 

func (m *TrimRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*TrimRequest) Marshal 

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

func (*TrimRequest) MarshalTo 

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

func (*TrimRequest) MarshalToSizedBuffer 

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

func (*TrimRequest) ProtoMessage 

func (*TrimRequest) ProtoMessage()

func (*TrimRequest) ProtoSize 

func (m *TrimRequest) ProtoSize() (n int)

func (*TrimRequest) Reset 

func (m *TrimRequest) Reset()

func (*TrimRequest) String 

func (m *TrimRequest) String() string

func (*TrimRequest) Unmarshal 

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

func (*TrimRequest) XXX_DiscardUnknown 

func (m *TrimRequest) XXX_DiscardUnknown()

func (*TrimRequest) XXX_Marshal 

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

func (*TrimRequest) XXX_Merge 

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

func (*TrimRequest) XXX_Size 

func (m *TrimRequest) XXX_Size() int

func (*TrimRequest) XXX_Unmarshal 

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

type TrimResponse 

type TrimResponse struct {
	Results map[github_com_kakao_varlog_pkg_types.LogStreamID]string `` /* 210-byte string literal not displayed */
}

func (*TrimResponse) Descriptor 

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

func (*TrimResponse) GetResults 

func (m *TrimResponse) GetResults() map[github_com_kakao_varlog_pkg_types.LogStreamID]string

func (*TrimResponse) Marshal 

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

func (*TrimResponse) MarshalTo 

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

func (*TrimResponse) MarshalToSizedBuffer 

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

func (*TrimResponse) ProtoMessage 

func (*TrimResponse) ProtoMessage()

func (*TrimResponse) ProtoSize 

func (m *TrimResponse) ProtoSize() (n int)

func (*TrimResponse) Reset 

func (m *TrimResponse) Reset()

func (*TrimResponse) String 

func (m *TrimResponse) String() string

func (*TrimResponse) Unmarshal 

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

func (*TrimResponse) XXX_DiscardUnknown 

func (m *TrimResponse) XXX_DiscardUnknown()

func (*TrimResponse) XXX_Marshal 

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

func (*TrimResponse) XXX_Merge 

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

func (*TrimResponse) XXX_Size 

func (m *TrimResponse) XXX_Size() int

func (*TrimResponse) XXX_Unmarshal 

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

type UnimplementedLogIOServer 

type UnimplementedLogIOServer struct {
}

UnimplementedLogIOServer can be embedded to have forward compatible implementations.

func (*UnimplementedLogIOServer) Append 

func (*UnimplementedLogIOServer) Append(ctx context.Context, req *AppendRequest) (*AppendResponse, error)

func (*UnimplementedLogIOServer) LogStreamMetadata 

func (*UnimplementedLogIOServer) LogStreamMetadata(ctx context.Context, req *LogStreamMetadataRequest) (*LogStreamMetadataResponse, error)

func (*UnimplementedLogIOServer) LogStreamReplicaMetadata added in v0.4.1 

func (*UnimplementedLogIOServer) LogStreamReplicaMetadata(ctx context.Context, req *LogStreamReplicaMetadataRequest) (*LogStreamReplicaMetadataResponse, error)

func (*UnimplementedLogIOServer) Read 

func (*UnimplementedLogIOServer) Read(ctx context.Context, req *ReadRequest) (*ReadResponse, error)

func (*UnimplementedLogIOServer) Subscribe 

func (*UnimplementedLogIOServer) Subscribe(req *SubscribeRequest, srv LogIO_SubscribeServer) error

func (*UnimplementedLogIOServer) SubscribeTo 

func (*UnimplementedLogIOServer) SubscribeTo(req *SubscribeToRequest, srv LogIO_SubscribeToServer) error

func (*UnimplementedLogIOServer) TrimDeprecated 

func (*UnimplementedLogIOServer) TrimDeprecated(ctx context.Context, req *TrimDeprecatedRequest) (*types.Empty, error)

type UnimplementedLogStreamReporterServer 

type UnimplementedLogStreamReporterServer struct {
}

UnimplementedLogStreamReporterServer can be embedded to have forward compatible implementations.

func (*UnimplementedLogStreamReporterServer) Commit 

func (*UnimplementedLogStreamReporterServer) Commit(srv LogStreamReporter_CommitServer) error

func (*UnimplementedLogStreamReporterServer) CommitBatch added in v0.7.0 

func (*UnimplementedLogStreamReporterServer) CommitBatch(srv LogStreamReporter_CommitBatchServer) error

func (*UnimplementedLogStreamReporterServer) GetReport 

func (*UnimplementedLogStreamReporterServer) GetReport(srv LogStreamReporter_GetReportServer) error

type UnimplementedManagementServer 

type UnimplementedManagementServer struct {
}

UnimplementedManagementServer can be embedded to have forward compatible implementations.

func (*UnimplementedManagementServer) AddLogStreamReplica 

func (*UnimplementedManagementServer) AddLogStreamReplica(ctx context.Context, req *AddLogStreamReplicaRequest) (*AddLogStreamReplicaResponse, error)

func (*UnimplementedManagementServer) GetMetadata 

func (*UnimplementedManagementServer) GetMetadata(ctx context.Context, req *GetMetadataRequest) (*GetMetadataResponse, error)

func (*UnimplementedManagementServer) RemoveLogStream 

func (*UnimplementedManagementServer) RemoveLogStream(ctx context.Context, req *RemoveLogStreamRequest) (*types.Empty, error)

func (*UnimplementedManagementServer) Seal 

func (*UnimplementedManagementServer) Seal(ctx context.Context, req *SealRequest) (*SealResponse, error)

func (*UnimplementedManagementServer) Sync 

func (*UnimplementedManagementServer) Sync(ctx context.Context, req *SyncRequest) (*SyncResponse, error)

func (*UnimplementedManagementServer) Trim 

func (*UnimplementedManagementServer) Trim(ctx context.Context, req *TrimRequest) (*TrimResponse, error)

func (*UnimplementedManagementServer) Unseal 

func (*UnimplementedManagementServer) Unseal(ctx context.Context, req *UnsealRequest) (*types.Empty, error)

type UnimplementedReplicatorServer 

type UnimplementedReplicatorServer struct {
}

UnimplementedReplicatorServer can be embedded to have forward compatible implementations.

func (*UnimplementedReplicatorServer) Replicate 

func (*UnimplementedReplicatorServer) Replicate(srv Replicator_ReplicateServer) error

func (*UnimplementedReplicatorServer) SyncInit 

func (*UnimplementedReplicatorServer) SyncInit(ctx context.Context, req *SyncInitRequest) (*SyncInitResponse, error)

func (*UnimplementedReplicatorServer) SyncReplicate 

func (*UnimplementedReplicatorServer) SyncReplicate(ctx context.Context, req *SyncReplicateRequest) (*SyncReplicateResponse, error)

type UnsealRequest 

type UnsealRequest struct {
	ClusterID     github_com_kakao_varlog_pkg_types.ClusterID     `` /* 142-byte string literal not displayed */
	StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	TopicID       github_com_kakao_varlog_pkg_types.TopicID       `` /* 134-byte string literal not displayed */
	LogStreamID   github_com_kakao_varlog_pkg_types.LogStreamID   `` /* 152-byte string literal not displayed */
	Replicas      []varlogpb.LogStreamReplica                     `protobuf:"bytes,5,rep,name=replicas,proto3" json:"replicas"`
}

func (*UnsealRequest) Descriptor 

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

func (*UnsealRequest) GetClusterID 

func (m *UnsealRequest) GetClusterID() github_com_kakao_varlog_pkg_types.ClusterID

func (*UnsealRequest) GetLogStreamID 

func (m *UnsealRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

func (*UnsealRequest) GetReplicas 

func (m *UnsealRequest) GetReplicas() []varlogpb.LogStreamReplica

func (*UnsealRequest) GetStorageNodeID 

func (m *UnsealRequest) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID

func (*UnsealRequest) GetTopicID 

func (m *UnsealRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

func (*UnsealRequest) Marshal 

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

func (*UnsealRequest) MarshalTo 

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

func (*UnsealRequest) MarshalToSizedBuffer 

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

func (*UnsealRequest) ProtoMessage 

func (*UnsealRequest) ProtoMessage()

func (*UnsealRequest) ProtoSize 

func (m *UnsealRequest) ProtoSize() (n int)

func (*UnsealRequest) Reset 

func (m *UnsealRequest) Reset()

func (*UnsealRequest) String 

func (m *UnsealRequest) String() string

func (*UnsealRequest) Unmarshal 

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

func (*UnsealRequest) XXX_DiscardUnknown 

func (m *UnsealRequest) XXX_DiscardUnknown()

func (*UnsealRequest) XXX_Marshal 

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

func (*UnsealRequest) XXX_Merge 

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

func (*UnsealRequest) XXX_Size 

func (m *UnsealRequest) XXX_Size() int

func (*UnsealRequest) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

Path Synopsis
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

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.