snpb

package
v0.2.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

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

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

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

Functions

func RegisterLogIOServer

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

func RegisterLogStreamReporterServer

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

func RegisterManagementServer

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

func RegisterReplicatorServer

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

Types

type AddLogStreamReplicaRequest

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

func (*AddLogStreamReplicaRequest) Descriptor

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

func (*AddLogStreamReplicaRequest) GetClusterID

func (*AddLogStreamReplicaRequest) GetLogStreamID

func (*AddLogStreamReplicaRequest) GetStorage

func (*AddLogStreamReplicaRequest) GetStorageNodeID

func (*AddLogStreamReplicaRequest) GetTopicID

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 {
	// TODO (jun): Use LogStreamMetadataDescriptor
	LogStream *varlogpb.LogStreamDescriptor `protobuf:"bytes,1,opt,name=log_stream,json=logStream,proto3" json:"log_stream,omitempty"`
}

func (*AddLogStreamReplicaResponse) Descriptor

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

func (*AddLogStreamReplicaResponse) GetLogStream

func (*AddLogStreamReplicaResponse) Marshal

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

func (*AddLogStreamReplicaResponse) MarshalTo

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

func (*AddLogStreamReplicaResponse) MarshalToSizedBuffer

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

func (*AddLogStreamReplicaResponse) ProtoMessage

func (*AddLogStreamReplicaResponse) ProtoMessage()

func (*AddLogStreamReplicaResponse) ProtoSize

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

func (*AddLogStreamReplicaResponse) Reset

func (m *AddLogStreamReplicaResponse) Reset()

func (*AddLogStreamReplicaResponse) String

func (m *AddLogStreamReplicaResponse) String() string

func (*AddLogStreamReplicaResponse) Unmarshal

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

func (*AddLogStreamReplicaResponse) XXX_DiscardUnknown

func (m *AddLogStreamReplicaResponse) XXX_DiscardUnknown()

func (*AddLogStreamReplicaResponse) XXX_Marshal

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

func (*AddLogStreamReplicaResponse) XXX_Merge

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

func (*AddLogStreamReplicaResponse) XXX_Size

func (m *AddLogStreamReplicaResponse) XXX_Size() int

func (*AddLogStreamReplicaResponse) XXX_Unmarshal

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

type AppendRequest

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

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

func (*AppendRequest) Descriptor

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

func (*AppendRequest) GetBackups

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

func (*AppendRequest) GetLogStreamID

func (*AppendRequest) GetPayload

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

func (*AppendRequest) GetTopicID

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 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 (*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 (*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 (*GetReportResponse) GetUncommitReports

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

func (*GetReportResponse) Marshal

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

func (*GetReportResponse) MarshalTo

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

func (*GetReportResponse) MarshalToSizedBuffer

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

func (*GetReportResponse) ProtoMessage

func (*GetReportResponse) ProtoMessage()

func (*GetReportResponse) ProtoSize

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

func (*GetReportResponse) Reset

func (m *GetReportResponse) Reset()

func (*GetReportResponse) String

func (m *GetReportResponse) String() string

func (*GetReportResponse) Unmarshal

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

func (*GetReportResponse) XXX_DiscardUnknown

func (m *GetReportResponse) XXX_DiscardUnknown()

func (*GetReportResponse) XXX_Marshal

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

func (*GetReportResponse) XXX_Merge

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

func (*GetReportResponse) XXX_Size

func (m *GetReportResponse) XXX_Size() int

func (*GetReportResponse) XXX_Unmarshal

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

type LogIOClient

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

LogIOClient is the client API for LogIO service.

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

func NewLogIOClient

func NewLogIOClient(cc *grpc.ClientConn) LogIOClient

type LogIOServer

LogIOServer is the server API for LogIO service.

type LogIO_SubscribeClient

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

type LogIO_SubscribeServer

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

type LogIO_SubscribeToClient

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

type LogIO_SubscribeToServer

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

type LogStreamCommitResult

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

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

func (*LogStreamCommitResult) Descriptor

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

func (*LogStreamCommitResult) Equal

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

func (*LogStreamCommitResult) GetCommittedGLSNLength

func (m *LogStreamCommitResult) GetCommittedGLSNLength() uint64

func (*LogStreamCommitResult) GetCommittedGLSNOffset

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

func (*LogStreamCommitResult) GetCommittedLLSNOffset

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

func (*LogStreamCommitResult) GetHighWatermark

func (*LogStreamCommitResult) GetLogStreamID

func (*LogStreamCommitResult) GetTopicID

func (*LogStreamCommitResult) GetVersion

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 (*LogStreamMetadataRequest) GetTopicID

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 int64  `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 (*LogStreamReplicaMetadataDescriptor) GetLocalHighWatermark

func (*LogStreamReplicaMetadataDescriptor) GetLocalLowWatermark

func (*LogStreamReplicaMetadataDescriptor) GetPath

func (*LogStreamReplicaMetadataDescriptor) GetStatus

func (*LogStreamReplicaMetadataDescriptor) GetStorageSizeBytes

func (m *LogStreamReplicaMetadataDescriptor) GetStorageSizeBytes() int64

func (*LogStreamReplicaMetadataDescriptor) GetUpdatedTime

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

func (*LogStreamReplicaMetadataDescriptor) GetVersion

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 (*LogStreamReplicaMetadataDescriptor) String

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 (*LogStreamReplicaMetadataDescriptor) XXX_Size

func (*LogStreamReplicaMetadataDescriptor) XXX_Unmarshal

func (m *LogStreamReplicaMetadataDescriptor) 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)
}

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
}

LogStreamReporterServer is the server API for LogStreamReporter service.

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 (*LogStreamUncommitReport) GetLogStreamID

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 (*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 (*LogStreamUncommitReport) String

func (m *LogStreamUncommitReport) String() string

func (*LogStreamUncommitReport) UncommittedLLSNEnd

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

func (*LogStreamUncommitReport) Unmarshal

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

func (*LogStreamUncommitReport) XXX_DiscardUnknown

func (m *LogStreamUncommitReport) XXX_DiscardUnknown()

func (*LogStreamUncommitReport) XXX_Marshal

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

func (*LogStreamUncommitReport) XXX_Merge

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

func (*LogStreamUncommitReport) XXX_Size

func (m *LogStreamUncommitReport) XXX_Size() int

func (*LogStreamUncommitReport) XXX_Unmarshal

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

type ManagementClient

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

ManagementClient is the client API for Management service.

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

func NewManagementClient

func NewManagementClient(cc *grpc.ClientConn) ManagementClient

type ManagementServer

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

ManagementServer is the server API for Management service.

type ReadRequest

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

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

func (*ReadRequest) Descriptor

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

func (*ReadRequest) GetGLSN

func (*ReadRequest) GetLogStreamID

func (*ReadRequest) GetTopicID

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 (*ReadResponse) GetLLSN

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 (*RemoveLogStreamRequest) GetLogStreamID

func (*RemoveLogStreamRequest) GetStorageNodeID

func (*RemoveLogStreamRequest) GetTopicID

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 (*ReplicateRequest) GetLogStreamID

func (*ReplicateRequest) GetTopicID

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 ReplicationRequest

type ReplicationRequest 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,opt,name=llsn,proto3,casttype=github.com/kakao/varlog/pkg/types.LLSN" json:"llsn,omitempty"`
	CreatedTime int64                                         `protobuf:"varint,4,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	Payload     []byte                                        `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
}

ReplicationRequest contains LLSN (Local Log Sequence Number) that indicates a log position in the local log stream of the primary storage node.

func (*ReplicationRequest) Descriptor

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

func (*ReplicationRequest) GetCreatedTime

func (m *ReplicationRequest) GetCreatedTime() int64

func (*ReplicationRequest) GetLLSN

func (*ReplicationRequest) GetLogStreamID

func (*ReplicationRequest) GetPayload

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

func (*ReplicationRequest) GetTopicID

func (*ReplicationRequest) Marshal

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

func (*ReplicationRequest) MarshalTo

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

func (*ReplicationRequest) MarshalToSizedBuffer

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

func (*ReplicationRequest) ProtoMessage

func (*ReplicationRequest) ProtoMessage()

func (*ReplicationRequest) ProtoSize

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

func (*ReplicationRequest) Reset

func (m *ReplicationRequest) Reset()

func (*ReplicationRequest) String

func (m *ReplicationRequest) String() string

func (*ReplicationRequest) Unmarshal

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

func (*ReplicationRequest) XXX_DiscardUnknown

func (m *ReplicationRequest) XXX_DiscardUnknown()

func (*ReplicationRequest) XXX_Marshal

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

func (*ReplicationRequest) XXX_Merge

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

func (*ReplicationRequest) XXX_Size

func (m *ReplicationRequest) XXX_Size() int

func (*ReplicationRequest) XXX_Unmarshal

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

type ReplicationResponse

type ReplicationResponse 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"`
	CreatedTime int64                                  `protobuf:"varint,2,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
}

ReplicationResponse indicates that a log entry at given LLSN is replicated.

func (*ReplicationResponse) Descriptor

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

func (*ReplicationResponse) GetCreatedTime

func (m *ReplicationResponse) GetCreatedTime() int64

func (*ReplicationResponse) GetLLSN

func (*ReplicationResponse) Marshal

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

func (*ReplicationResponse) MarshalTo

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

func (*ReplicationResponse) MarshalToSizedBuffer

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

func (*ReplicationResponse) ProtoMessage

func (*ReplicationResponse) ProtoMessage()

func (*ReplicationResponse) ProtoSize

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

func (*ReplicationResponse) Reset

func (m *ReplicationResponse) Reset()

func (*ReplicationResponse) String

func (m *ReplicationResponse) String() string

func (*ReplicationResponse) Unmarshal

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

func (*ReplicationResponse) XXX_DiscardUnknown

func (m *ReplicationResponse) XXX_DiscardUnknown()

func (*ReplicationResponse) XXX_Marshal

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

func (*ReplicationResponse) XXX_Merge

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

func (*ReplicationResponse) XXX_Size

func (m *ReplicationResponse) XXX_Size() int

func (*ReplicationResponse) XXX_Unmarshal

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

type ReplicatorClient

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

ReplicatorClient is the client API for Replicator service.

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

func NewReplicatorClient

func NewReplicatorClient(cc *grpc.ClientConn) ReplicatorClient

type ReplicatorServer

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_ReplicateDeprecatedClient

type Replicator_ReplicateDeprecatedClient interface {
	Send(*ReplicationRequest) error
	Recv() (*ReplicationResponse, error)
	grpc.ClientStream
}

type Replicator_ReplicateDeprecatedServer

type Replicator_ReplicateDeprecatedServer interface {
	Send(*ReplicationResponse) error
	Recv() (*ReplicationRequest, error)
	grpc.ServerStream
}

type Replicator_ReplicateServer

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

type SealRequest

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

func (*SealRequest) Descriptor

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

func (*SealRequest) GetClusterID

func (*SealRequest) GetLastCommittedGLSN

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

func (*SealRequest) GetLogStreamID

func (*SealRequest) GetStorageNodeID

func (*SealRequest) GetTopicID

func (*SealRequest) Marshal

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

func (*SealRequest) MarshalTo

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

func (*SealRequest) MarshalToSizedBuffer

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

func (*SealRequest) ProtoMessage

func (*SealRequest) ProtoMessage()

func (*SealRequest) ProtoSize

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

func (*SealRequest) Reset

func (m *SealRequest) Reset()

func (*SealRequest) String

func (m *SealRequest) String() string

func (*SealRequest) Unmarshal

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

func (*SealRequest) XXX_DiscardUnknown

func (m *SealRequest) XXX_DiscardUnknown()

func (*SealRequest) XXX_Marshal

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

func (*SealRequest) XXX_Merge

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

func (*SealRequest) XXX_Size

func (m *SealRequest) XXX_Size() int

func (*SealRequest) XXX_Unmarshal

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

type SealResponse

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

func (*SealResponse) Descriptor

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

func (*SealResponse) GetLastCommittedGLSN

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

func (*SealResponse) GetStatus

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

func (*SealResponse) Marshal

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

func (*SealResponse) MarshalTo

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

func (*SealResponse) MarshalToSizedBuffer

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

func (*SealResponse) ProtoMessage

func (*SealResponse) ProtoMessage()

func (*SealResponse) ProtoSize

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

func (*SealResponse) Reset

func (m *SealResponse) Reset()

func (*SealResponse) String

func (m *SealResponse) String() string

func (*SealResponse) Unmarshal

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

func (*SealResponse) XXX_DiscardUnknown

func (m *SealResponse) XXX_DiscardUnknown()

func (*SealResponse) XXX_Marshal

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

func (*SealResponse) XXX_Merge

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

func (*SealResponse) XXX_Size

func (m *SealResponse) XXX_Size() int

func (*SealResponse) XXX_Unmarshal

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

type StorageNodeMetadataDescriptor

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

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

func (*StorageNodeMetadataDescriptor) Descriptor

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

func (*StorageNodeMetadataDescriptor) Equal

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

func (StorageNodeMetadataDescriptor) FindLogStream

func (*StorageNodeMetadataDescriptor) GetClusterID

func (*StorageNodeMetadataDescriptor) GetLogStream

func (*StorageNodeMetadataDescriptor) GetLogStreamReplicas

func (*StorageNodeMetadataDescriptor) GetStartTime

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

func (*StorageNodeMetadataDescriptor) GetStatus

func (*StorageNodeMetadataDescriptor) GetStorages

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 (*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 (*SubscribeRequest) GetGLSNEnd

func (*SubscribeRequest) GetLogStreamID

func (*SubscribeRequest) GetTopicID

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 (*SubscribeResponse) GetLLSN

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 (*SubscribeToRequest) GetLLSNEnd

func (*SubscribeToRequest) GetLogStreamID

func (*SubscribeToRequest) GetTopicID

func (*SubscribeToRequest) Marshal

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

func (*SubscribeToRequest) MarshalTo

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

func (*SubscribeToRequest) MarshalToSizedBuffer

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

func (*SubscribeToRequest) ProtoMessage

func (*SubscribeToRequest) ProtoMessage()

func (*SubscribeToRequest) ProtoSize

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

func (*SubscribeToRequest) Reset

func (m *SubscribeToRequest) Reset()

func (*SubscribeToRequest) String

func (m *SubscribeToRequest) String() string

func (*SubscribeToRequest) Unmarshal

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

func (*SubscribeToRequest) XXX_DiscardUnknown

func (m *SubscribeToRequest) XXX_DiscardUnknown()

func (*SubscribeToRequest) XXX_Marshal

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

func (*SubscribeToRequest) XXX_Merge

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

func (*SubscribeToRequest) XXX_Size

func (m *SubscribeToRequest) XXX_Size() int

func (*SubscribeToRequest) XXX_Unmarshal

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

type SubscribeToResponse

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

func (*SubscribeToResponse) Descriptor

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

func (*SubscribeToResponse) GetLogEntry

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

func (*SubscribeToResponse) Marshal

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

func (*SubscribeToResponse) MarshalTo

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

func (*SubscribeToResponse) MarshalToSizedBuffer

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

func (*SubscribeToResponse) ProtoMessage

func (*SubscribeToResponse) ProtoMessage()

func (*SubscribeToResponse) ProtoSize

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

func (*SubscribeToResponse) Reset

func (m *SubscribeToResponse) Reset()

func (*SubscribeToResponse) String

func (m *SubscribeToResponse) String() string

func (*SubscribeToResponse) Unmarshal

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

func (*SubscribeToResponse) XXX_DiscardUnknown

func (m *SubscribeToResponse) XXX_DiscardUnknown()

func (*SubscribeToResponse) XXX_Marshal

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

func (*SubscribeToResponse) XXX_Merge

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

func (*SubscribeToResponse) XXX_Size

func (m *SubscribeToResponse) XXX_Size() int

func (*SubscribeToResponse) XXX_Unmarshal

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

type SyncInitRequest

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

func (*SyncInitRequest) Descriptor

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

func (*SyncInitRequest) GetClusterID

func (*SyncInitRequest) GetDestination

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

func (*SyncInitRequest) GetRange

func (m *SyncInitRequest) GetRange() SyncRange

func (*SyncInitRequest) GetSource

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

func (*SyncInitRequest) Marshal

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

func (*SyncInitRequest) MarshalTo

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

func (*SyncInitRequest) MarshalToSizedBuffer

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

func (*SyncInitRequest) ProtoMessage

func (*SyncInitRequest) ProtoMessage()

func (*SyncInitRequest) ProtoSize

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

func (*SyncInitRequest) Reset

func (m *SyncInitRequest) Reset()

func (*SyncInitRequest) String

func (m *SyncInitRequest) String() string

func (*SyncInitRequest) Unmarshal

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

func (*SyncInitRequest) XXX_DiscardUnknown

func (m *SyncInitRequest) XXX_DiscardUnknown()

func (*SyncInitRequest) XXX_Marshal

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

func (*SyncInitRequest) XXX_Merge

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

func (*SyncInitRequest) XXX_Size

func (m *SyncInitRequest) XXX_Size() int

func (*SyncInitRequest) XXX_Unmarshal

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

type SyncInitResponse

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

func (*SyncInitResponse) Descriptor

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

func (*SyncInitResponse) GetRange

func (m *SyncInitResponse) GetRange() SyncRange

func (*SyncInitResponse) Marshal

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

func (*SyncInitResponse) MarshalTo

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

func (*SyncInitResponse) MarshalToSizedBuffer

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

func (*SyncInitResponse) ProtoMessage

func (*SyncInitResponse) ProtoMessage()

func (*SyncInitResponse) ProtoSize

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

func (*SyncInitResponse) Reset

func (m *SyncInitResponse) Reset()

func (*SyncInitResponse) String

func (m *SyncInitResponse) String() string

func (*SyncInitResponse) Unmarshal

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

func (*SyncInitResponse) XXX_DiscardUnknown

func (m *SyncInitResponse) XXX_DiscardUnknown()

func (*SyncInitResponse) XXX_Marshal

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

func (*SyncInitResponse) XXX_Merge

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

func (*SyncInitResponse) XXX_Size

func (m *SyncInitResponse) XXX_Size() int

func (*SyncInitResponse) XXX_Unmarshal

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

type SyncPayload

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

func (*SyncPayload) Descriptor

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

func (*SyncPayload) GetCommitContext

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

func (*SyncPayload) GetLogEntry

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

func (*SyncPayload) GetValue

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

func (*SyncPayload) Marshal

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

func (*SyncPayload) MarshalTo

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

func (*SyncPayload) MarshalToSizedBuffer

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

func (*SyncPayload) ProtoMessage

func (*SyncPayload) ProtoMessage()

func (*SyncPayload) ProtoSize

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

func (*SyncPayload) Reset

func (m *SyncPayload) Reset()

func (*SyncPayload) SetValue

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

func (*SyncPayload) String

func (m *SyncPayload) String() string

func (*SyncPayload) Unmarshal

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

func (*SyncPayload) XXX_DiscardUnknown

func (m *SyncPayload) XXX_DiscardUnknown()

func (*SyncPayload) XXX_Marshal

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

func (*SyncPayload) XXX_Merge

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

func (*SyncPayload) XXX_Size

func (m *SyncPayload) XXX_Size() int

func (*SyncPayload) XXX_Unmarshal

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

type SyncPosition

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

func InvalidSyncPosition

func InvalidSyncPosition() SyncPosition

func (*SyncPosition) Descriptor

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

func (*SyncPosition) Equal

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

func (*SyncPosition) GetGLSN

func (*SyncPosition) GetLLSN

func (SyncPosition) Invalid

func (sp SyncPosition) Invalid() bool

func (SyncPosition) LessThan

func (sp SyncPosition) LessThan(other SyncPosition) bool

func (*SyncPosition) Marshal

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

func (*SyncPosition) MarshalTo

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

func (*SyncPosition) MarshalToSizedBuffer

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

func (*SyncPosition) ProtoMessage

func (*SyncPosition) ProtoMessage()

func (*SyncPosition) ProtoSize

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

func (*SyncPosition) Reset

func (m *SyncPosition) Reset()

func (*SyncPosition) String

func (m *SyncPosition) String() string

func (*SyncPosition) Unmarshal

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

func (*SyncPosition) XXX_DiscardUnknown

func (m *SyncPosition) XXX_DiscardUnknown()

func (*SyncPosition) XXX_Marshal

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

func (*SyncPosition) XXX_Merge

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

func (*SyncPosition) XXX_Size

func (m *SyncPosition) XXX_Size() int

func (*SyncPosition) XXX_Unmarshal

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

type SyncRange

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

func InvalidSyncRange

func InvalidSyncRange() SyncRange

func (*SyncRange) Descriptor

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

func (*SyncRange) GetFirstLLSN

func (*SyncRange) GetLastLLSN

func (SyncRange) Invalid

func (sr SyncRange) Invalid() bool

func (*SyncRange) Marshal

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

func (*SyncRange) MarshalTo

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

func (*SyncRange) MarshalToSizedBuffer

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

func (*SyncRange) ProtoMessage

func (*SyncRange) ProtoMessage()

func (*SyncRange) ProtoSize

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

func (*SyncRange) Reset

func (m *SyncRange) Reset()

func (*SyncRange) String

func (m *SyncRange) String() string

func (*SyncRange) Unmarshal

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

func (*SyncRange) XXX_DiscardUnknown

func (m *SyncRange) XXX_DiscardUnknown()

func (*SyncRange) XXX_Marshal

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

func (*SyncRange) XXX_Merge

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

func (*SyncRange) XXX_Size

func (m *SyncRange) XXX_Size() int

func (*SyncRange) XXX_Unmarshal

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

type SyncReplicateRequest

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

func (*SyncReplicateRequest) Descriptor

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

func (*SyncReplicateRequest) GetClusterID

func (*SyncReplicateRequest) GetDestination

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

func (*SyncReplicateRequest) GetPayload

func (m *SyncReplicateRequest) GetPayload() SyncPayload

func (*SyncReplicateRequest) GetSource

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 (*SyncRequest) GetLogStreamID

func (*SyncRequest) GetStorageNodeID

func (*SyncRequest) GetTopicID

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 (*SyncRequest_BackupNode) Marshal

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

func (*SyncRequest_BackupNode) MarshalTo

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

func (*SyncRequest_BackupNode) MarshalToSizedBuffer

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

func (*SyncRequest_BackupNode) ProtoMessage

func (*SyncRequest_BackupNode) ProtoMessage()

func (*SyncRequest_BackupNode) ProtoSize

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

func (*SyncRequest_BackupNode) Reset

func (m *SyncRequest_BackupNode) Reset()

func (*SyncRequest_BackupNode) String

func (m *SyncRequest_BackupNode) String() string

func (*SyncRequest_BackupNode) Unmarshal

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

func (*SyncRequest_BackupNode) XXX_DiscardUnknown

func (m *SyncRequest_BackupNode) XXX_DiscardUnknown()

func (*SyncRequest_BackupNode) XXX_Marshal

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

func (*SyncRequest_BackupNode) XXX_Merge

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

func (*SyncRequest_BackupNode) XXX_Size

func (m *SyncRequest_BackupNode) XXX_Size() int

func (*SyncRequest_BackupNode) XXX_Unmarshal

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

type SyncResponse

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

func (*SyncResponse) Descriptor

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

func (*SyncResponse) GetStatus

func (m *SyncResponse) GetStatus() *SyncStatus

func (*SyncResponse) Marshal

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

func (*SyncResponse) MarshalTo

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

func (*SyncResponse) MarshalToSizedBuffer

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

func (*SyncResponse) ProtoMessage

func (*SyncResponse) ProtoMessage()

func (*SyncResponse) ProtoSize

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

func (*SyncResponse) Reset

func (m *SyncResponse) Reset()

func (*SyncResponse) String

func (m *SyncResponse) String() string

func (*SyncResponse) Unmarshal

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

func (*SyncResponse) XXX_DiscardUnknown

func (m *SyncResponse) XXX_DiscardUnknown()

func (*SyncResponse) XXX_Marshal

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

func (*SyncResponse) XXX_Merge

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

func (*SyncResponse) XXX_Size

func (m *SyncResponse) XXX_Size() int

func (*SyncResponse) XXX_Unmarshal

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

type SyncState

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

func (SyncState) EnumDescriptor

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

func (SyncState) String

func (x SyncState) String() string

type SyncStatus

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

func (*SyncStatus) Descriptor

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

func (*SyncStatus) GetCurrent

func (m *SyncStatus) GetCurrent() SyncPosition

func (*SyncStatus) GetFirst

func (m *SyncStatus) GetFirst() SyncPosition

func (*SyncStatus) GetLast

func (m *SyncStatus) GetLast() SyncPosition

func (*SyncStatus) GetState

func (m *SyncStatus) GetState() SyncState

func (*SyncStatus) Marshal

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

func (*SyncStatus) MarshalTo

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

func (*SyncStatus) MarshalToSizedBuffer

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

func (*SyncStatus) ProtoMessage

func (*SyncStatus) ProtoMessage()

func (*SyncStatus) ProtoSize

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

func (*SyncStatus) Reset

func (m *SyncStatus) Reset()

func (*SyncStatus) String

func (m *SyncStatus) String() string

func (*SyncStatus) Unmarshal

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

func (*SyncStatus) XXX_DiscardUnknown

func (m *SyncStatus) XXX_DiscardUnknown()

func (*SyncStatus) XXX_Marshal

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

func (*SyncStatus) XXX_Merge

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

func (*SyncStatus) XXX_Size

func (m *SyncStatus) XXX_Size() int

func (*SyncStatus) XXX_Unmarshal

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

type TrimDeprecatedRequest

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

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

func (*TrimDeprecatedRequest) Descriptor

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

func (*TrimDeprecatedRequest) GetGLSN

func (*TrimDeprecatedRequest) GetTopicID

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 (*TrimRequest) GetTopicID

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 (*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) LogStreamMetadata

func (*UnimplementedLogIOServer) Read

func (*UnimplementedLogIOServer) Subscribe

func (*UnimplementedLogIOServer) SubscribeTo

func (*UnimplementedLogIOServer) TrimDeprecated

type UnimplementedLogStreamReporterServer

type UnimplementedLogStreamReporterServer struct {
}

UnimplementedLogStreamReporterServer can be embedded to have forward compatible implementations.

func (*UnimplementedLogStreamReporterServer) Commit

func (*UnimplementedLogStreamReporterServer) GetReport

type UnimplementedManagementServer

type UnimplementedManagementServer struct {
}

UnimplementedManagementServer can be embedded to have forward compatible implementations.

func (*UnimplementedManagementServer) AddLogStreamReplica

func (*UnimplementedManagementServer) GetMetadata

func (*UnimplementedManagementServer) RemoveLogStream

func (*UnimplementedManagementServer) Seal

func (*UnimplementedManagementServer) Sync

func (*UnimplementedManagementServer) Trim

func (*UnimplementedManagementServer) Unseal

type UnimplementedReplicatorServer

type UnimplementedReplicatorServer struct {
}

UnimplementedReplicatorServer can be embedded to have forward compatible implementations.

func (*UnimplementedReplicatorServer) Replicate

func (*UnimplementedReplicatorServer) ReplicateDeprecated

func (*UnimplementedReplicatorServer) SyncInit

func (*UnimplementedReplicatorServer) SyncReplicate

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 (*UnsealRequest) GetLogStreamID

func (*UnsealRequest) GetReplicas

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

func (*UnsealRequest) GetStorageNodeID

func (*UnsealRequest) GetTopicID

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

Directories

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

Jump to

Keyboard shortcuts

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