varlogpb

package

Go to main page

Versions in this module

v0

v0.20.0

Mar 5, 2024

v0.19.2

Feb 14, 2024

v0.19.1

Feb 1, 2024

v0.19.0

Jan 2, 2024

v0.18.1

Oct 17, 2023

v0.18.0

Oct 10, 2023

v0.17.0

Oct 10, 2023

v0.16.0

Oct 4, 2023

Changes in this version

type LogStreamDescriptor

+ func (lsd LogStreamDescriptor) Validate() error

type ReplicaDescriptor

+ func (rd ReplicaDescriptor) Validate() error

v0.15.0

Aug 7, 2023

v0.14.1

Jun 20, 2023

v0.14.0

Jun 19, 2023

v0.13.0

Jun 1, 2023

v0.12.0

Apr 6, 2023

v0.11.0

Feb 21, 2023

v0.10.0

Jan 4, 2023

v0.9.2

Dec 16, 2022

v0.9.1

Dec 16, 2022

v0.9.0

Dec 14, 2022

v0.8.1

Dec 7, 2022

v0.8.0

Dec 7, 2022

v0.7.1

Nov 23, 2022

v0.7.0

Nov 23, 2022

Changes in this version

type LogSequenceNumber

+ func (lsn LogSequenceNumber) Invalid() bool

v0.6.0

Oct 12, 2022

v0.5.0

Oct 7, 2022

v0.4.1

Sep 13, 2022

v0.4.0

Sep 13, 2022

Changes in this version

type ReplicaDescriptor

+ DataPath string

+ StorageNodePath string

+ func (m *ReplicaDescriptor) GetDataPath() string

+ func (m *ReplicaDescriptor) GetStorageNodePath() string

v0.3.1

Sep 6, 2022

v0.3.0

Sep 4, 2022

v0.2.3

Aug 29, 2022

v0.2.2

Aug 29, 2022

v0.2.1

Aug 29, 2022

v0.2.0

Aug 25, 2022

v0.1.0

Aug 25, 2022

v0.0.3

Aug 25, 2022

v0.0.2

Aug 17, 2022

v0.0.1

Aug 14, 2022

Changes in this version

+ var ErrIntOverflowMetadata = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthMetadata = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupMetadata = fmt.Errorf("proto: unexpected end of group")

+ var LogStreamStatus_name = map[int32]string

+ var LogStreamStatus_value = map[string]int32

+ var StorageNodeStatus_name = map[int32]string

+ var StorageNodeStatus_value = map[string]int32

+ var TopicStatus_name = map[int32]string

+ var TopicStatus_value = map[string]int32

+ func EqualReplicas(xs []LogStreamReplica, ys []LogStreamReplica) bool

+ func ValidReplicas(replicas []LogStreamReplica) error

+ type CommitContext struct

+ CommittedGLSNBegin github_com_kakao_varlog_pkg_types.GLSN

+ CommittedGLSNEnd github_com_kakao_varlog_pkg_types.GLSN

+ CommittedLLSNBegin github_com_kakao_varlog_pkg_types.LLSN

+ HighWatermark github_com_kakao_varlog_pkg_types.GLSN

+ Version github_com_kakao_varlog_pkg_types.Version

+ func (*CommitContext) Descriptor() ([]byte, []int)

+ func (*CommitContext) ProtoMessage()

+ func (m *CommitContext) GetCommittedGLSNBegin() github_com_kakao_varlog_pkg_types.GLSN

+ func (m *CommitContext) GetCommittedGLSNEnd() github_com_kakao_varlog_pkg_types.GLSN

+ func (m *CommitContext) GetCommittedLLSNBegin() github_com_kakao_varlog_pkg_types.LLSN

+ func (m *CommitContext) GetHighWatermark() github_com_kakao_varlog_pkg_types.GLSN

+ func (m *CommitContext) GetVersion() github_com_kakao_varlog_pkg_types.Version

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

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

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

+ func (m *CommitContext) ProtoSize() (n int)

+ func (m *CommitContext) Reset()

+ func (m *CommitContext) String() string

+ func (m *CommitContext) Unmarshal(dAtA []byte) error

+ func (m *CommitContext) XXX_DiscardUnknown()

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

+ func (m *CommitContext) XXX_Merge(src proto.Message)

+ func (m *CommitContext) XXX_Size() int

+ func (m *CommitContext) XXX_Unmarshal(b []byte) error

+ type LogEntry struct

+ Data []byte

+ func InvalidLogEntry() LogEntry

+ func (*LogEntry) Descriptor() ([]byte, []int)

+ func (*LogEntry) ProtoMessage()

+ func (le LogEntry) Invalid() bool

+ func (m *LogEntry) GetData() []byte

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

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

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

+ func (m *LogEntry) ProtoSize() (n int)

+ func (m *LogEntry) Reset()

+ func (m *LogEntry) String() string

+ func (m *LogEntry) Unmarshal(dAtA []byte) error

+ func (m *LogEntry) XXX_DiscardUnknown()

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

+ func (m *LogEntry) XXX_Merge(src proto.Message)

+ func (m *LogEntry) XXX_Size() int

+ func (m *LogEntry) XXX_Unmarshal(b []byte) error

+ func (this *LogEntry) Equal(that interface{}) bool

+ type LogEntryMeta struct

+ GLSN github_com_kakao_varlog_pkg_types.GLSN

+ LLSN github_com_kakao_varlog_pkg_types.LLSN

+ LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

+ func InvalidLogEntryMeta() LogEntryMeta

+ func (*LogEntryMeta) Descriptor() ([]byte, []int)

+ func (*LogEntryMeta) ProtoMessage()

+ func (m *LogEntryMeta) GetGLSN() github_com_kakao_varlog_pkg_types.GLSN

+ func (m *LogEntryMeta) GetLLSN() github_com_kakao_varlog_pkg_types.LLSN

+ func (m *LogEntryMeta) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

+ func (m *LogEntryMeta) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

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

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

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

+ func (m *LogEntryMeta) ProtoSize() (n int)

+ func (m *LogEntryMeta) Reset()

+ func (m *LogEntryMeta) String() string

+ func (m *LogEntryMeta) Unmarshal(dAtA []byte) error

+ func (m *LogEntryMeta) XXX_DiscardUnknown()

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

+ func (m *LogEntryMeta) XXX_Merge(src proto.Message)

+ func (m *LogEntryMeta) XXX_Size() int

+ func (m *LogEntryMeta) XXX_Unmarshal(b []byte) error

+ func (this *LogEntryMeta) Equal(that interface{}) bool

+ type LogSequenceNumber struct

+ GLSN github_com_kakao_varlog_pkg_types.GLSN

+ LLSN github_com_kakao_varlog_pkg_types.LLSN

+ func (*LogSequenceNumber) Descriptor() ([]byte, []int)

+ func (*LogSequenceNumber) ProtoMessage()

+ func (m *LogSequenceNumber) GetGLSN() github_com_kakao_varlog_pkg_types.GLSN

+ func (m *LogSequenceNumber) GetLLSN() github_com_kakao_varlog_pkg_types.LLSN

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

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

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

+ func (m *LogSequenceNumber) ProtoSize() (n int)

+ func (m *LogSequenceNumber) Reset()

+ func (m *LogSequenceNumber) String() string

+ func (m *LogSequenceNumber) Unmarshal(dAtA []byte) error

+ func (m *LogSequenceNumber) XXX_DiscardUnknown()

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

+ func (m *LogSequenceNumber) XXX_Merge(src proto.Message)

+ func (m *LogSequenceNumber) XXX_Size() int

+ func (m *LogSequenceNumber) XXX_Unmarshal(b []byte) error

+ func (this *LogSequenceNumber) Equal(that interface{}) bool

+ type LogStreamDescriptor struct

+ Head LogEntryMeta

+ LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID

+ Replicas []*ReplicaDescriptor

+ Status LogStreamStatus

+ Tail LogEntryMeta

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

+ func (*LogStreamDescriptor) Descriptor() ([]byte, []int)

+ func (*LogStreamDescriptor) ProtoMessage()

+ func (l *LogStreamDescriptor) IsReplica(snID types.StorageNodeID) bool

+ func (l *LogStreamDescriptor) Valid() bool

+ func (m *LogStreamDescriptor) GetHead() LogEntryMeta

+ func (m *LogStreamDescriptor) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

+ func (m *LogStreamDescriptor) GetReplicas() []*ReplicaDescriptor

+ func (m *LogStreamDescriptor) GetStatus() LogStreamStatus

+ func (m *LogStreamDescriptor) GetTail() LogEntryMeta

+ func (m *LogStreamDescriptor) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

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

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

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

+ func (m *LogStreamDescriptor) ProtoSize() (n int)

+ func (m *LogStreamDescriptor) Reset()

+ func (m *LogStreamDescriptor) String() string

+ func (m *LogStreamDescriptor) Unmarshal(dAtA []byte) error

+ func (m *LogStreamDescriptor) XXX_DiscardUnknown()

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

+ func (m *LogStreamDescriptor) XXX_Merge(src proto.Message)

+ func (m *LogStreamDescriptor) XXX_Size() int

+ func (m *LogStreamDescriptor) XXX_Unmarshal(b []byte) error

+ func (this *LogStreamDescriptor) Equal(that interface{}) bool

+ type LogStreamReplica struct

+ func (*LogStreamReplica) Descriptor() ([]byte, []int)

+ func (*LogStreamReplica) ProtoMessage()

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

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

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

+ func (m *LogStreamReplica) ProtoSize() (n int)

+ func (m *LogStreamReplica) Reset()

+ func (m *LogStreamReplica) String() string

+ func (m *LogStreamReplica) Unmarshal(dAtA []byte) error

+ func (m *LogStreamReplica) XXX_DiscardUnknown()

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

+ func (m *LogStreamReplica) XXX_Merge(src proto.Message)

+ func (m *LogStreamReplica) XXX_Size() int

+ func (m *LogStreamReplica) XXX_Unmarshal(b []byte) error

+ func (this *LogStreamReplica) Equal(that interface{}) bool

+ type LogStreamStatus int32

+ const LogStreamStatusDeleted

+ const LogStreamStatusRunning

+ const LogStreamStatusSealed

+ const LogStreamStatusSealing

+ const LogStreamStatusUnsealing

+ func (LogStreamStatus) EnumDescriptor() ([]byte, []int)

+ func (lss *LogStreamStatus) UnmarshalJSON(b []byte) error

+ func (lss LogStreamStatus) MarshalJSON() ([]byte, error)

+ func (s LogStreamStatus) Deleted() bool

+ func (s LogStreamStatus) Running() bool

+ func (s LogStreamStatus) Sealed() bool

+ func (x LogStreamStatus) String() string

+ type MetadataDescriptor struct

+ AppliedIndex uint64

+ LogStreams []*LogStreamDescriptor

+ StorageNodes []*StorageNodeDescriptor

+ Topics []*TopicDescriptor

+ func (*MetadataDescriptor) Descriptor() ([]byte, []int)

+ func (*MetadataDescriptor) ProtoMessage()

+ func (m *MetadataDescriptor) DeleteLogStream(id types.LogStreamID) error

+ func (m *MetadataDescriptor) DeleteStorageNode(id types.StorageNodeID) error

+ func (m *MetadataDescriptor) DeleteTopic(id types.TopicID) error

+ func (m *MetadataDescriptor) GetAppliedIndex() uint64

+ func (m *MetadataDescriptor) GetLogStream(id types.LogStreamID) *LogStreamDescriptor

+ func (m *MetadataDescriptor) GetLogStreams() []*LogStreamDescriptor

+ func (m *MetadataDescriptor) GetReplicasByStorageNodeID(id types.StorageNodeID) []*ReplicaDescriptor

+ func (m *MetadataDescriptor) GetStorageNode(id types.StorageNodeID) *StorageNodeDescriptor

+ func (m *MetadataDescriptor) GetStorageNodes() []*StorageNodeDescriptor

+ func (m *MetadataDescriptor) GetTopic(id types.TopicID) *TopicDescriptor

+ func (m *MetadataDescriptor) GetTopics() []*TopicDescriptor

+ func (m *MetadataDescriptor) HaveLogStream(id types.LogStreamID) (*LogStreamDescriptor, error)

+ func (m *MetadataDescriptor) HaveStorageNode(id types.StorageNodeID) (*StorageNodeDescriptor, error)

+ func (m *MetadataDescriptor) HaveTopic(id types.TopicID) (*TopicDescriptor, error)

+ func (m *MetadataDescriptor) InsertLogStream(ls *LogStreamDescriptor) error

+ func (m *MetadataDescriptor) InsertStorageNode(sn *StorageNodeDescriptor) error

+ func (m *MetadataDescriptor) InsertTopic(topic *TopicDescriptor) error

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

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

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

+ func (m *MetadataDescriptor) Must() *MetadataDescriptor

+ func (m *MetadataDescriptor) MustHaveLogStream(id types.LogStreamID) (*LogStreamDescriptor, error)

+ func (m *MetadataDescriptor) MustHaveStorageNode(id types.StorageNodeID) (*StorageNodeDescriptor, error)

+ func (m *MetadataDescriptor) MustHaveTopic(id types.TopicID) (*TopicDescriptor, error)

+ func (m *MetadataDescriptor) MustNotHaveLogStream(id types.LogStreamID) error

+ func (m *MetadataDescriptor) MustNotHaveStorageNode(id types.StorageNodeID) error

+ func (m *MetadataDescriptor) MustNotHaveTopic(id types.TopicID) error

+ func (m *MetadataDescriptor) NotHaveLogStream(id types.LogStreamID) error

+ func (m *MetadataDescriptor) NotHaveStorageNode(id types.StorageNodeID) error

+ func (m *MetadataDescriptor) NotHaveTopic(id types.TopicID) error

+ func (m *MetadataDescriptor) ProtoSize() (n int)

+ func (m *MetadataDescriptor) Reset()

+ func (m *MetadataDescriptor) String() string

+ func (m *MetadataDescriptor) Unmarshal(dAtA []byte) error

+ func (m *MetadataDescriptor) UpdateLogStream(ls *LogStreamDescriptor) error

+ func (m *MetadataDescriptor) UpdateStorageNode(sn *StorageNodeDescriptor) error

+ func (m *MetadataDescriptor) UpdateTopic(topic *TopicDescriptor) error

+ func (m *MetadataDescriptor) UpsertLogStream(ls *LogStreamDescriptor) error

+ func (m *MetadataDescriptor) UpsertStorageNode(sn *StorageNodeDescriptor) error

+ func (m *MetadataDescriptor) UpsertTopic(topic *TopicDescriptor) error

+ func (m *MetadataDescriptor) XXX_DiscardUnknown()

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

+ func (m *MetadataDescriptor) XXX_Merge(src proto.Message)

+ func (m *MetadataDescriptor) XXX_Size() int

+ func (m *MetadataDescriptor) XXX_Unmarshal(b []byte) error

+ func (this *MetadataDescriptor) Equal(that interface{}) bool

+ type MetadataRepositoryNode struct

+ Leader bool

+ Learner bool

+ NodeID github_com_kakao_varlog_pkg_types.NodeID

+ RPCAddr string

+ RaftURL string

+ func (*MetadataRepositoryNode) Descriptor() ([]byte, []int)

+ func (*MetadataRepositoryNode) ProtoMessage()

+ func (m *MetadataRepositoryNode) GetLeader() bool

+ func (m *MetadataRepositoryNode) GetLearner() bool

+ func (m *MetadataRepositoryNode) GetNodeID() github_com_kakao_varlog_pkg_types.NodeID

+ func (m *MetadataRepositoryNode) GetRPCAddr() string

+ func (m *MetadataRepositoryNode) GetRaftURL() string

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

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

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

+ func (m *MetadataRepositoryNode) ProtoSize() (n int)

+ func (m *MetadataRepositoryNode) Reset()

+ func (m *MetadataRepositoryNode) String() string

+ func (m *MetadataRepositoryNode) Unmarshal(dAtA []byte) error

+ func (m *MetadataRepositoryNode) XXX_DiscardUnknown()

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

+ func (m *MetadataRepositoryNode) XXX_Merge(src proto.Message)

+ func (m *MetadataRepositoryNode) XXX_Size() int

+ func (m *MetadataRepositoryNode) XXX_Unmarshal(b []byte) error

+ type ReplicaDescriptor struct

+ Path string

+ StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID

+ func DiffReplicaDescriptorSet(xs []*ReplicaDescriptor, ys []*ReplicaDescriptor) []*ReplicaDescriptor

+ func (*ReplicaDescriptor) Descriptor() ([]byte, []int)

+ func (*ReplicaDescriptor) ProtoMessage()

+ func (m *ReplicaDescriptor) GetPath() string

+ func (m *ReplicaDescriptor) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID

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

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

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

+ func (m *ReplicaDescriptor) ProtoSize() (n int)

+ func (m *ReplicaDescriptor) Reset()

+ func (m *ReplicaDescriptor) String() string

+ func (m *ReplicaDescriptor) Unmarshal(dAtA []byte) error

+ func (m *ReplicaDescriptor) XXX_DiscardUnknown()

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

+ func (m *ReplicaDescriptor) XXX_Merge(src proto.Message)

+ func (m *ReplicaDescriptor) XXX_Size() int

+ func (m *ReplicaDescriptor) XXX_Unmarshal(b []byte) error

+ func (this *ReplicaDescriptor) Equal(that interface{}) bool

+ type StorageDescriptor struct

+ Path string

+ Total uint64

+ Used uint64

+ func (*StorageDescriptor) Descriptor() ([]byte, []int)

+ func (*StorageDescriptor) ProtoMessage()

+ func (m *StorageDescriptor) GetPath() string

+ func (m *StorageDescriptor) GetTotal() uint64

+ func (m *StorageDescriptor) GetUsed() uint64

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

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

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

+ func (m *StorageDescriptor) ProtoSize() (n int)

+ func (m *StorageDescriptor) Reset()

+ func (m *StorageDescriptor) String() string

+ func (m *StorageDescriptor) Unmarshal(dAtA []byte) error

+ func (m *StorageDescriptor) XXX_DiscardUnknown()

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

+ func (m *StorageDescriptor) XXX_Merge(src proto.Message)

+ func (m *StorageDescriptor) XXX_Size() int

+ func (m *StorageDescriptor) XXX_Unmarshal(b []byte) error

+ func (this *StorageDescriptor) Equal(that interface{}) bool

+ type StorageNode struct

+ Address string

+ StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID

+ func (*StorageNode) Descriptor() ([]byte, []int)

+ func (*StorageNode) ProtoMessage()

+ func (m *StorageNode) GetAddress() string

+ func (m *StorageNode) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID

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

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

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

+ func (m *StorageNode) ProtoSize() (n int)

+ func (m *StorageNode) Reset()

+ func (m *StorageNode) String() string

+ func (m *StorageNode) Unmarshal(dAtA []byte) error

+ func (m *StorageNode) XXX_DiscardUnknown()

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

+ func (m *StorageNode) XXX_Merge(src proto.Message)

+ func (m *StorageNode) XXX_Size() int

+ func (m *StorageNode) XXX_Unmarshal(b []byte) error

+ func (this *StorageNode) Equal(that interface{}) bool

+ type StorageNodeDescriptor struct

+ CreateTime time.Time

+ Paths []string

+ Status StorageNodeStatus

+ func (*StorageNodeDescriptor) Descriptor() ([]byte, []int)

+ func (*StorageNodeDescriptor) ProtoMessage()

+ func (m *StorageNodeDescriptor) GetCreateTime() time.Time

+ func (m *StorageNodeDescriptor) GetPaths() []string

+ func (m *StorageNodeDescriptor) GetStatus() StorageNodeStatus

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

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

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

+ func (m *StorageNodeDescriptor) ProtoSize() (n int)

+ func (m *StorageNodeDescriptor) Reset()

+ func (m *StorageNodeDescriptor) String() string

+ func (m *StorageNodeDescriptor) Unmarshal(dAtA []byte) error

+ func (m *StorageNodeDescriptor) XXX_DiscardUnknown()

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

+ func (m *StorageNodeDescriptor) XXX_Merge(src proto.Message)

+ func (m *StorageNodeDescriptor) XXX_Size() int

+ func (m *StorageNodeDescriptor) XXX_Unmarshal(b []byte) error

+ func (snd *StorageNodeDescriptor) Valid() bool

+ func (this *StorageNodeDescriptor) Equal(that interface{}) bool

+ type StorageNodeStatus int32

+ const StorageNodeStatusDeleted

+ const StorageNodeStatusRunning

+ func (StorageNodeStatus) EnumDescriptor() ([]byte, []int)

+ func (s StorageNodeStatus) Deleted() bool

+ func (s StorageNodeStatus) Running() bool

+ func (x StorageNodeStatus) String() string

+ type TopicDescriptor struct

+ LogStreams []github_com_kakao_varlog_pkg_types.LogStreamID

+ Status TopicStatus

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

+ func (*TopicDescriptor) Descriptor() ([]byte, []int)

+ func (*TopicDescriptor) ProtoMessage()

+ func (m *TopicDescriptor) GetLogStreams() []github_com_kakao_varlog_pkg_types.LogStreamID

+ func (m *TopicDescriptor) GetStatus() TopicStatus

+ func (m *TopicDescriptor) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

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

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

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

+ func (m *TopicDescriptor) ProtoSize() (n int)

+ func (m *TopicDescriptor) Reset()

+ func (m *TopicDescriptor) String() string

+ func (m *TopicDescriptor) Unmarshal(dAtA []byte) error

+ func (m *TopicDescriptor) XXX_DiscardUnknown()

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

+ func (m *TopicDescriptor) XXX_Merge(src proto.Message)

+ func (m *TopicDescriptor) XXX_Size() int

+ func (m *TopicDescriptor) XXX_Unmarshal(b []byte) error

+ func (t *TopicDescriptor) HasLogStream(lsID types.LogStreamID) bool

+ func (t *TopicDescriptor) InsertLogStream(lsID types.LogStreamID)

+ func (this *TopicDescriptor) Equal(that interface{}) bool

+ type TopicLogStream struct

+ LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

+ func (*TopicLogStream) Descriptor() ([]byte, []int)

+ func (*TopicLogStream) ProtoMessage()

+ func (m *TopicLogStream) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID

+ func (m *TopicLogStream) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID

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

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

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

+ func (m *TopicLogStream) ProtoSize() (n int)

+ func (m *TopicLogStream) Reset()

+ func (m *TopicLogStream) String() string

+ func (m *TopicLogStream) Unmarshal(dAtA []byte) error

+ func (m *TopicLogStream) XXX_DiscardUnknown()

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

+ func (m *TopicLogStream) XXX_Merge(src proto.Message)

+ func (m *TopicLogStream) XXX_Size() int

+ func (m *TopicLogStream) XXX_Unmarshal(b []byte) error

+ func (this *TopicLogStream) Equal(that interface{}) bool

+ type TopicStatus int32

+ const TopicStatusDeleted

+ const TopicStatusRunning

+ func (TopicStatus) EnumDescriptor() ([]byte, []int)

+ func (s TopicStatus) Deleted() bool

+ func (x TopicStatus) String() string

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