snpb

package
v0.19.1 Latest Latest
Warning

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

 Go to latest Published: Feb 1, 2024 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",
	3: "START",
}
View Source 
var SyncState_value = map[string]int32{
	"ERROR":       0,
	"IN_PROGRESS": 1,
	"COMPLETE":    2,
	"START":       3,
}

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)

func ValidateTopicLogStream added in v0.11.0 

func ValidateTopicLogStream(iface interface {
	GetTopicID() types.TopicID
	GetLogStreamID() types.LogStreamID
}) error

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

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) 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 stores a list of log entries to the end of the log stream
	// specified by AppendRequest. The log entries are appended partially; that
	// is, some of the log entries could not be stored due to failures.
	//
	// It returns the following gRPC errors:
	// - InvalidArgument: AppendRequest has invalid fields; for instance, TopicID
	// is invalid.
	// - NotFound: The log stream replica specified by the AppendRequest does not
	// exist in the storage node. Note that it does not mean that the log stream
	// does not exist in the cluster.
	// - FailedPrecondition: The log stream may be sealed; thus, clients cannot
	// write the log entry. Clients should unseal the log stream to append a log
	// entry to the log stream.
	// - Unavailable: The storage node is shutting down, or the log stream replica
	// is not primary.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	//
	// FIXME: Partial failures are not specified by the gRPC error codes.
	Append(ctx context.Context, opts ...grpc.CallOption) (LogIO_AppendClient, error)
	// Read reads a log entry from the log stream specified by ReadRequest.
	// Deprecated: Use Subscribe or SubscribeTo.
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	// Subscribe reads a range of log entries specified by SubscribeRequest.
	//
	// It returns the following gRPC errors:
	// - NotFound: The log stream replica specified by the SubscribeRequest does
	// not exist in the storage node. Note that it does not mean that the log
	// stream does not exist in the cluster.
	// - Unavailable: The storage node is shutting down.
	// - InvalidArgument: The range is invalid; for example, the beginning of the
	// range is greater than or equal to the end.
	// - OutOfRange: The parts or whole range are already trimmed.
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (LogIO_SubscribeClient, error)
	// SubscribeTo is similar to Subscribe except that it specifies the range with
	// LLSN.
	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 returns metadata of the log stream replica
	// specified by the LogStreamReplicaMetadataRequest.
	LogStreamReplicaMetadata(ctx context.Context, in *LogStreamReplicaMetadataRequest, opts ...grpc.CallOption) (*LogStreamReplicaMetadataResponse, 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 stores a list of log entries to the end of the log stream
	// specified by AppendRequest. The log entries are appended partially; that
	// is, some of the log entries could not be stored due to failures.
	//
	// It returns the following gRPC errors:
	// - InvalidArgument: AppendRequest has invalid fields; for instance, TopicID
	// is invalid.
	// - NotFound: The log stream replica specified by the AppendRequest does not
	// exist in the storage node. Note that it does not mean that the log stream
	// does not exist in the cluster.
	// - FailedPrecondition: The log stream may be sealed; thus, clients cannot
	// write the log entry. Clients should unseal the log stream to append a log
	// entry to the log stream.
	// - Unavailable: The storage node is shutting down, or the log stream replica
	// is not primary.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	//
	// FIXME: Partial failures are not specified by the gRPC error codes.
	Append(LogIO_AppendServer) error
	// Read reads a log entry from the log stream specified by ReadRequest.
	// Deprecated: Use Subscribe or SubscribeTo.
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	// Subscribe reads a range of log entries specified by SubscribeRequest.
	//
	// It returns the following gRPC errors:
	// - NotFound: The log stream replica specified by the SubscribeRequest does
	// not exist in the storage node. Note that it does not mean that the log
	// stream does not exist in the cluster.
	// - Unavailable: The storage node is shutting down.
	// - InvalidArgument: The range is invalid; for example, the beginning of the
	// range is greater than or equal to the end.
	// - OutOfRange: The parts or whole range are already trimmed.
	Subscribe(*SubscribeRequest, LogIO_SubscribeServer) error
	// SubscribeTo is similar to Subscribe except that it specifies the range with
	// LLSN.
	SubscribeTo(*SubscribeToRequest, LogIO_SubscribeToServer) error
	TrimDeprecated(context.Context, *TrimDeprecatedRequest) (*types.Empty, error)
	// LogStreamReplicaMetadata returns metadata of the log stream replica
	// specified by the LogStreamReplicaMetadataRequest.
	LogStreamReplicaMetadata(context.Context, *LogStreamReplicaMetadataRequest) (*LogStreamReplicaMetadataResponse, error)
}

LogIOServer is the server API for LogIO service.

type LogIO_AppendClient added in v0.14.0 

type LogIO_AppendClient interface {
	Send(*AppendRequest) error
	Recv() (*AppendResponse, error)
	grpc.ClientStream
}

type LogIO_AppendServer added in v0.14.0 

type LogIO_AppendServer interface {
	Send(*AppendResponse) error
	Recv() (*AppendRequest, error)
	grpc.ServerStream
}

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 is the identifier for the log stream.
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
	// TopicID is the identifier for the topic to which the log stream belongs.
	TopicID github_com_kakao_varlog_pkg_types.TopicID `` /* 134-byte string literal not displayed */
	// CommittedLLSNOffset is the starting LLSN of the commit range.
	CommittedLLSNOffset github_com_kakao_varlog_pkg_types.LLSN `` /* 169-byte string literal not displayed */
	// CommittedGLSNOffset is the starting GLSN of the commit range.
	// If there is no log entry to be committed, the CommittedGLSNOffset should be
	// next to the last committed GLSN.
	CommittedGLSNOffset github_com_kakao_varlog_pkg_types.GLSN `` /* 169-byte string literal not displayed */
	// CommittedGLSNLength is the length of the commit range.
	CommittedGLSNLength uint64 `protobuf:"varint,5,opt,name=committed_glsn_length,json=committedGlsnLength,proto3" json:"committed_glsn_length,omitempty"`
	// Version is a unique number for the commit issued by the metadata
	// repository.
	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 is the maximum GLSN across all log streams of the topic in a
	// specific commit version.
	HighWatermark github_com_kakao_varlog_pkg_types.GLSN `` /* 149-byte string literal not displayed */
}

LogStreamCommitResult has information about commit for a log stream, and it tells the log stream how many log entries can be committed. Even if the log stream can't commit anything, CommittedLLSNOffset and CommittedGLSNOffset should be valid.

Here are examples for clarity. Assume that there are two log streams in a topic. 

// LogStream 1 has not committed any log entries, and LogStream 2 has
// committed ten.
LogStreamCommitResult{
    TopicID: 1,
    LogStreamID: 1,
    Version: 1,
    HighWatermark: 10,
    CommittedLLSNOffset: 1,
    CommittedGLSNOffset: 1,
    CommittedGLSNLength: 0,
}
LogStreamCommitResult{
    TopicID: 1,
    LogStreamID: 2,
    Version: 1,
    HighWatermark: 10,
    CommittedLLSNOffset: 1,
    CommittedGLSNOffset: 1,
    CommittedGLSNLength: 10,
}

// LogStream 1 has not committed any log entries again, and LogStream 2 has
// committed ten.
// Note that the CommittedGLSNOffset of LogStream 1 is one even though the
// GLSN 1 has already been issued to other log entries in LogStream 2.
LogStreamCommitResult{
    TopicID: 1,
    LogStreamID: 1,
    Version 2,
    HighWatermark: 20,
    CommittedLLSNOffset: 1,
    CommittedGLSNOffset: 1,
    CommittedGLSNLength: 0,
}
LogStreamCommitResult{
    TopicID: 1,
    LogStreamID: 2,
    Version 2,
    HighWatermark: 20,
    CommittedLLSNOffset: 11,
    CommittedGLSNOffset: 11,
    CommittedGLSNLength: 10,
}

// LogStream 1 has committed ten log entries, and LogStream 2 has committed
// ten.
LogStreamCommitResult{
    TopicID: 1,
    LogStreamID: 1,
    Version 3,
    HighWatermark: 40,
    CommittedLLSNOffset: 1,
    CommittedGLSNOffset: 21,
    CommittedGLSNLength: 10,
}
LogStreamCommitResult{
    TopicID: 1,
    LogStreamID: 2,
    Version 3,
    HighWatermark: 40,
    CommittedLLSNOffset: 21,
    CommittedGLSNOffset: 31,
    CommittedGLSNLength: 10,
}

// LogStream 1 has committed ten log entries, and LogStream 2 has not.
// Note that the CommittedGLSNOffset of LogStream 2 is next to the last
// committed GLSN of itself, regardless of LogStream 1.
LogStreamCommitResult{
    TopicID: 1,
    LogStreamID: 1,
    Version 4,
    HighWatermark: 50,
    CommittedLLSNOffset: 11,
    CommittedGLSNOffset: 41,
    CommittedGLSNLength: 10,
}
LogStreamCommitResult{
    TopicID: 1,
    LogStreamID: 2,
    Version 4,
    HighWatermark: 50,
    CommittedLLSNOffset: 31,
    CommittedGLSNOffset: 41,
    CommittedGLSNLength: 0,
}

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 the metadata of the storage node. It produces a gRPC
	// Unavailable error if the storage node is shutting down.
	GetMetadata(ctx context.Context, in *GetMetadataRequest, opts ...grpc.CallOption) (*GetMetadataResponse, error)
	// AddLogStreamReplica adds a new log stream replica to a storage node.
	//
	// It returns the following gRPC errors:
	// - Unavailable: The storage node is shutting down.
	// - ResourceExhausted: The number of log stream replicas in the storage node
	// reaches the upper limit.
	// - Canceled: The client canceled the request.
	// DeadlineExceeded: The client's timeout has expired.
	AddLogStreamReplica(ctx context.Context, in *AddLogStreamReplicaRequest, opts ...grpc.CallOption) (*AddLogStreamReplicaResponse, error)
	// RemoveLogStream removes a log stream replica from the storage node.
	//
	// It returns the following gRPC errors:
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	//
	// TODO: It should be renamed to RemoveLogStreamReplica to represent its
	// purpose precisely.
	RemoveLogStream(ctx context.Context, in *RemoveLogStreamRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// Seal changes the status of the log stream replica to LogStreamStatusSealing
	// or LogStreamStatusSealed.
	//
	// It returns the following gRPC errors:
	// - InvalidArgument: SealRequest has invalid fields; for instance, TopicID
	// is invalid.
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	Seal(ctx context.Context, in *SealRequest, opts ...grpc.CallOption) (*SealResponse, error)
	// Unseal changes the status of the log stream replica to
	// LogStreamStatusRunning.
	//
	// It returns the following gRPC errors:
	// - InvalidArgument: UnsealRequest has invalid fields; for instance, TopicID
	// is invalid.
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	Unseal(ctx context.Context, in *UnsealRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// Sync duplicates log entries from the source log stream replica to the
	// destination log stream replica.
	//
	// It returns the following gRPC errors:
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error)
	// Trim removes prefix log entries from each log stream replica in the topic.
	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 the metadata of the storage node. It produces a gRPC
	// Unavailable error if the storage node is shutting down.
	GetMetadata(context.Context, *GetMetadataRequest) (*GetMetadataResponse, error)
	// AddLogStreamReplica adds a new log stream replica to a storage node.
	//
	// It returns the following gRPC errors:
	// - Unavailable: The storage node is shutting down.
	// - ResourceExhausted: The number of log stream replicas in the storage node
	// reaches the upper limit.
	// - Canceled: The client canceled the request.
	// DeadlineExceeded: The client's timeout has expired.
	AddLogStreamReplica(context.Context, *AddLogStreamReplicaRequest) (*AddLogStreamReplicaResponse, error)
	// RemoveLogStream removes a log stream replica from the storage node.
	//
	// It returns the following gRPC errors:
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	//
	// TODO: It should be renamed to RemoveLogStreamReplica to represent its
	// purpose precisely.
	RemoveLogStream(context.Context, *RemoveLogStreamRequest) (*types.Empty, error)
	// Seal changes the status of the log stream replica to LogStreamStatusSealing
	// or LogStreamStatusSealed.
	//
	// It returns the following gRPC errors:
	// - InvalidArgument: SealRequest has invalid fields; for instance, TopicID
	// is invalid.
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	Seal(context.Context, *SealRequest) (*SealResponse, error)
	// Unseal changes the status of the log stream replica to
	// LogStreamStatusRunning.
	//
	// It returns the following gRPC errors:
	// - InvalidArgument: UnsealRequest has invalid fields; for instance, TopicID
	// is invalid.
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	Unseal(context.Context, *UnsealRequest) (*types.Empty, error)
	// Sync duplicates log entries from the source log stream replica to the
	// destination log stream replica.
	//
	// It returns the following gRPC errors:
	// - Unavailable: The storage node is shutting down.
	// - NotFound: The log stream replica does not exist.
	// - Canceled: The client canceled the request.
	// - DeadlineExceeded: The client's timeout has expired.
	Sync(context.Context, *SyncRequest) (*SyncResponse, error)
	// Trim removes prefix log entries from each log stream replica in the topic.
	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 tells the source replica's log entries range to the destination
	// replica. According to the range sent by the request of SyncInit, the
	// destination replica can decide whether it is necessary to copy log entries
	// from the source and even delete stale ones.
	//
	// To be a source replica, the status of the log stream replica must be
	// SEALED, which indicates that the log stream replica has all the log entries
	// that the metadata repository has committed. To be a destination replica,
	// the status of the log stream replica must be SEALING which means that the
	// log stream replica does not have all log entries yet.
	//
	// To represent log entry ranges, each request and response of SyncInit embeds
	// a field of type SyncRange. The source replica sends a range of overall log
	// entries to the destination replica; that is, the FirstLLSN of SyncRange is
	// the local low watermark, and the LastLLSN of it is the local high
	// watermark. There are several cases in the destination replica:
	//
	// - The destination replica already has log entries and the commit context,
	// which are the same as the source replica: No synchronization is necessary.
	// The destination replica should reply with a SyncInitResponse having the
	// FirstLLSN and the LastLLSN as InvalidLLSNs.
	// - The destination replica's local high watermark is equal to the LastLLSN.
	// However, it does not have the corresponding commit context that contains
	// the last log entry: It means that only copying the commit context from the
	// source to the destination is necessary. The destination should reply with a
	// SyncInitResponse having a larger FirstLLSN than the LastLLSN.
	// - The destination replica's local high watermark is lower than the LastLLSN
	// of SyncInitRequest: Some log entries should be cloned from the source to
	// the destination. The destination replica should reply with a
	// SyncInitResponse denoting the missing range.
	//
	// A destination replica sometimes should remove log entries according to the
	// SyncRange in the request, usually when the source replica has trimmed the
	// log entries.
	//
	// When a source replica has no log entries due to Trim, the source replica
	// can invoke SyncInit with InvalidLLSNs for FirstLLSN and LastLLSN of
	// SyncRange. Destination replica should remove their stale log entries and
	// receive a commit context from the source replica.
	//
	// TODO: Use the gRPC error code instead of setting particular values for the
	// SyncRange to avoid ambiguity.
	SyncInit(ctx context.Context, in *SyncInitRequest, opts ...grpc.CallOption) (*SyncInitResponse, error)
	// SyncReplicate
	//
	// Deprecated: Use SyncReplicateStream
	SyncReplicate(ctx context.Context, in *SyncReplicateRequest, opts ...grpc.CallOption) (*SyncReplicateResponse, error)
	// SyncReplicateStream copies log entries between replicas in a log stream.
	SyncReplicateStream(ctx context.Context, opts ...grpc.CallOption) (Replicator_SyncReplicateStreamClient, 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 tells the source replica's log entries range to the destination
	// replica. According to the range sent by the request of SyncInit, the
	// destination replica can decide whether it is necessary to copy log entries
	// from the source and even delete stale ones.
	//
	// To be a source replica, the status of the log stream replica must be
	// SEALED, which indicates that the log stream replica has all the log entries
	// that the metadata repository has committed. To be a destination replica,
	// the status of the log stream replica must be SEALING which means that the
	// log stream replica does not have all log entries yet.
	//
	// To represent log entry ranges, each request and response of SyncInit embeds
	// a field of type SyncRange. The source replica sends a range of overall log
	// entries to the destination replica; that is, the FirstLLSN of SyncRange is
	// the local low watermark, and the LastLLSN of it is the local high
	// watermark. There are several cases in the destination replica:
	//
	// - The destination replica already has log entries and the commit context,
	// which are the same as the source replica: No synchronization is necessary.
	// The destination replica should reply with a SyncInitResponse having the
	// FirstLLSN and the LastLLSN as InvalidLLSNs.
	// - The destination replica's local high watermark is equal to the LastLLSN.
	// However, it does not have the corresponding commit context that contains
	// the last log entry: It means that only copying the commit context from the
	// source to the destination is necessary. The destination should reply with a
	// SyncInitResponse having a larger FirstLLSN than the LastLLSN.
	// - The destination replica's local high watermark is lower than the LastLLSN
	// of SyncInitRequest: Some log entries should be cloned from the source to
	// the destination. The destination replica should reply with a
	// SyncInitResponse denoting the missing range.
	//
	// A destination replica sometimes should remove log entries according to the
	// SyncRange in the request, usually when the source replica has trimmed the
	// log entries.
	//
	// When a source replica has no log entries due to Trim, the source replica
	// can invoke SyncInit with InvalidLLSNs for FirstLLSN and LastLLSN of
	// SyncRange. Destination replica should remove their stale log entries and
	// receive a commit context from the source replica.
	//
	// TODO: Use the gRPC error code instead of setting particular values for the
	// SyncRange to avoid ambiguity.
	SyncInit(context.Context, *SyncInitRequest) (*SyncInitResponse, error)
	// SyncReplicate
	//
	// Deprecated: Use SyncReplicateStream
	SyncReplicate(context.Context, *SyncReplicateRequest) (*SyncReplicateResponse, error)
	// SyncReplicateStream copies log entries between replicas in a log stream.
	SyncReplicateStream(Replicator_SyncReplicateStreamServer) 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 Replicator_SyncReplicateStreamClient added in v0.8.0 

type Replicator_SyncReplicateStreamClient interface {
	Send(*SyncReplicateRequest) error
	CloseAndRecv() (*SyncReplicateResponse, error)
	grpc.ClientStream
}

type Replicator_SyncReplicateStreamServer added in v0.8.0 

type Replicator_SyncReplicateStreamServer interface {
	SendAndClose(*SyncReplicateResponse) error
	Recv() (*SyncReplicateRequest, 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"`
	// LogStreamReplicas are the list of metadata for log stream replicas.
	LogStreamReplicas []LogStreamReplicaMetadataDescriptor `protobuf:"bytes,4,rep,name=log_stream_replicas,json=logStreamReplicas,proto3" json:"logStreamReplicas"`
	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 is the identifier of the cluster.
	ClusterID github_com_kakao_varlog_pkg_types.ClusterID `` /* 142-byte string literal not displayed */
	// Source is metadata for source log stream replica.
	Source varlogpb.LogStreamReplica `protobuf:"bytes,2,opt,name=source,proto3" json:"source"`
	// Destination is metadata for destination log stream replica.
	Destination varlogpb.LogStreamReplica `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination"`
	// Range is the boundaries of log entries that can be copied from source to
	// destination.
	Range SyncRange `protobuf:"bytes,4,opt,name=range,proto3" json:"range"`
	// LastCommittedLLSN is the LLSN to which the last log entry was committed in
	// the source replica.
	LastCommittedLLSN github_com_kakao_varlog_pkg_types.LLSN `` /* 163-byte string literal not displayed */
}

SyncInitRequest represents a range of synchronization from source to destination. The field Range indicates the first and the last log sequence numbers the source can send to the destination. The field CommitContext indicates the last commit sent from the metadata repository to the source.

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) GetLastCommittedLLSN added in v0.12.0 

func (m *SyncInitRequest) GetLastCommittedLLSN() github_com_kakao_varlog_pkg_types.LLSN

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

SyncInitResponse represents a range of log entries necessary for the destination. If all fields of Range that are FirstLLSN and LastLLSN are InvalidLLSN, the destination does not need any log entry, but only the commit context.

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 is the inclusive lower LLSN of SyncRange.
	FirstLLSN github_com_kakao_varlog_pkg_types.LLSN `` /* 137-byte string literal not displayed */
	// LastLLSN is the inclusive upper LLSN of SyncRange.
	LastLLSN github_com_kakao_varlog_pkg_types.LLSN `` /* 134-byte string literal not displayed */
}

SyncRange indicates a range of synchronization. In request, it represents the boundary of copiable log entries; conversely, in response, it means the border of necessary log entries.

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) Validate added in v0.12.0 

func (sr SyncRange) Validate() 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

SyncState indicates the state of the synchronization process. 

const (
	// SyncStateError means that the synchronization job fails.
	SyncStateError SyncState = 0
	// SyncStateInProgress means that the synchronization job is still in
	// progress.
	SyncStateInProgress SyncState = 1
	// SyncStateComplete means that the synchronization job is done successfully.
	SyncStateComplete SyncState = 2
	// SyncStateStart means that the synchronization job starts.
	SyncStateStart SyncState = 3
)

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(srv LogIO_AppendServer) 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)

func (*UnimplementedReplicatorServer) SyncReplicateStream added in v0.8.0 

func (*UnimplementedReplicatorServer) SyncReplicateStream(srv Replicator_SyncReplicateStreamServer) 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
Code generated by MockGen.
 Code generated by MockGen.

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.