mrpb

package
v0.25.0 Latest Latest
Warning

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

 Go to latest Published: Feb 21, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 (
	ErrInvalidLengthMetadataRepository        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetadataRepository          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMetadataRepository = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthRaftEntry        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaftEntry          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRaftEntry = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthRaftMetadataRepository        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaftMetadataRepository          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRaftMetadataRepository = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterManagementServer 

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

func RegisterMetadataRepositoryServiceServer 

func RegisterMetadataRepositoryServiceServer(s *grpc.Server, srv MetadataRepositoryServiceServer)

Types

type AddPeer 

type AddPeer struct {
	NodeID    github_com_kakao_varlog_pkg_types.NodeID `` /* 130-byte string literal not displayed */
	Url       string                                   `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	IsLearner bool                                     `protobuf:"varint,3,opt,name=is_learner,json=isLearner,proto3" json:"is_learner,omitempty"`
}

func (*AddPeer) Descriptor 

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

func (*AddPeer) GetIsLearner 

func (m *AddPeer) GetIsLearner() bool

func (*AddPeer) GetNodeID 

func (m *AddPeer) GetNodeID() github_com_kakao_varlog_pkg_types.NodeID

func (*AddPeer) GetUrl 

func (m *AddPeer) GetUrl() string

func (*AddPeer) Marshal 

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

func (*AddPeer) MarshalTo 

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

func (*AddPeer) MarshalToSizedBuffer 

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

func (*AddPeer) ProtoMessage 

func (*AddPeer) ProtoMessage()

func (*AddPeer) ProtoSize 

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

func (*AddPeer) Reset 

func (m *AddPeer) Reset()

func (*AddPeer) String 

func (m *AddPeer) String() string

func (*AddPeer) Unmarshal 

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

func (*AddPeer) XXX_DiscardUnknown 

func (m *AddPeer) XXX_DiscardUnknown()

func (*AddPeer) XXX_Marshal 

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

func (*AddPeer) XXX_Merge 

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

func (*AddPeer) XXX_Size 

func (m *AddPeer) XXX_Size() int

func (*AddPeer) XXX_Unmarshal 

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

type AddPeerRequest 

type AddPeerRequest struct {
	PeerInfo `protobuf:"bytes,1,opt,name=peer,proto3,embedded=peer" json:"peer"`
}

AddPeerRequest is a request message for the AddPeer RPC.

func (*AddPeerRequest) Descriptor 

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

func (*AddPeerRequest) Marshal 

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

func (*AddPeerRequest) MarshalTo 

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

func (*AddPeerRequest) MarshalToSizedBuffer 

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

func (*AddPeerRequest) ProtoMessage 

func (*AddPeerRequest) ProtoMessage()

func (*AddPeerRequest) ProtoSize 

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

func (*AddPeerRequest) Reset 

func (m *AddPeerRequest) Reset()

func (*AddPeerRequest) String 

func (m *AddPeerRequest) String() string

func (*AddPeerRequest) Unmarshal 

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

func (*AddPeerRequest) XXX_DiscardUnknown 

func (m *AddPeerRequest) XXX_DiscardUnknown()

func (*AddPeerRequest) XXX_Marshal 

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

func (*AddPeerRequest) XXX_Merge 

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

func (*AddPeerRequest) XXX_Size 

func (m *AddPeerRequest) XXX_Size() int

func (*AddPeerRequest) XXX_Unmarshal 

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

type ClusterInfo 

type ClusterInfo struct {
	ClusterID         github_com_kakao_varlog_pkg_types.ClusterID                      `` /* 131-byte string literal not displayed */
	NodeID            github_com_kakao_varlog_pkg_types.NodeID                         `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3,casttype=github.com/kakao/varlog/pkg/types.NodeID" json:"nodeId"`
	Leader            github_com_kakao_varlog_pkg_types.NodeID                         `protobuf:"varint,3,opt,name=leader,proto3,casttype=github.com/kakao/varlog/pkg/types.NodeID" json:"leader,omitempty"`
	ReplicationFactor int32                                                            `protobuf:"varint,4,opt,name=replication_factor,json=replicationFactor,proto3" json:"replicationFactor"`
	Members           map[github_com_kakao_varlog_pkg_types.NodeID]*ClusterInfo_Member `` /* 205-byte string literal not displayed */
	// applied_index is the AppliedIndex of RAFT that is updated by changing
	// configuration of members. For example, AddPeer and RemovePeer result in
	// increasing applied_index.
	AppliedIndex uint64 `protobuf:"varint,6,opt,name=applied_index,json=appliedIndex,proto3" json:"appliedIndex"`
}

ClusterInfo is a metadata representing the Raft cluster.

func (*ClusterInfo) Descriptor 

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

func (*ClusterInfo) ForEachMember 

func (ci *ClusterInfo) ForEachMember(f func(types.NodeID, *ClusterInfo_Member) bool)

func (*ClusterInfo) GetAppliedIndex 

func (m *ClusterInfo) GetAppliedIndex() uint64

func (*ClusterInfo) GetClusterID 

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

func (*ClusterInfo) GetLeader 

func (m *ClusterInfo) GetLeader() github_com_kakao_varlog_pkg_types.NodeID

func (*ClusterInfo) GetMembers 

func (m *ClusterInfo) GetMembers() map[github_com_kakao_varlog_pkg_types.NodeID]*ClusterInfo_Member

func (*ClusterInfo) GetNodeID 

func (m *ClusterInfo) GetNodeID() github_com_kakao_varlog_pkg_types.NodeID

func (*ClusterInfo) GetReplicationFactor 

func (m *ClusterInfo) GetReplicationFactor() int32

func (*ClusterInfo) Marshal 

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

func (*ClusterInfo) MarshalTo 

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

func (*ClusterInfo) MarshalToSizedBuffer 

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

func (*ClusterInfo) NewerThan 

func (ci *ClusterInfo) NewerThan(other *ClusterInfo) bool

func (*ClusterInfo) ProtoMessage 

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) ProtoSize 

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

func (*ClusterInfo) Reset 

func (m *ClusterInfo) Reset()

func (*ClusterInfo) String 

func (m *ClusterInfo) String() string

func (*ClusterInfo) Unmarshal 

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

func (*ClusterInfo) XXX_DiscardUnknown 

func (m *ClusterInfo) XXX_DiscardUnknown()

func (*ClusterInfo) XXX_Marshal 

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

func (*ClusterInfo) XXX_Merge 

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

func (*ClusterInfo) XXX_Size 

func (m *ClusterInfo) XXX_Size() int

func (*ClusterInfo) XXX_Unmarshal 

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

type ClusterInfo_Member 

type ClusterInfo_Member struct {
	Peer     string `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"`
	Endpoint string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Learner  bool   `protobuf:"varint,3,opt,name=learner,proto3" json:"learner,omitempty"`
}

func (*ClusterInfo_Member) Descriptor 

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

func (*ClusterInfo_Member) GetEndpoint 

func (m *ClusterInfo_Member) GetEndpoint() string

func (*ClusterInfo_Member) GetLearner 

func (m *ClusterInfo_Member) GetLearner() bool

func (*ClusterInfo_Member) GetPeer 

func (m *ClusterInfo_Member) GetPeer() string

func (*ClusterInfo_Member) Marshal 

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

func (*ClusterInfo_Member) MarshalTo 

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

func (*ClusterInfo_Member) MarshalToSizedBuffer 

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

func (*ClusterInfo_Member) ProtoMessage 

func (*ClusterInfo_Member) ProtoMessage()

func (*ClusterInfo_Member) ProtoSize 

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

func (*ClusterInfo_Member) Reset 

func (m *ClusterInfo_Member) Reset()

func (*ClusterInfo_Member) String 

func (m *ClusterInfo_Member) String() string

func (*ClusterInfo_Member) Unmarshal 

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

func (*ClusterInfo_Member) XXX_DiscardUnknown 

func (m *ClusterInfo_Member) XXX_DiscardUnknown()

func (*ClusterInfo_Member) XXX_Marshal 

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

func (*ClusterInfo_Member) XXX_Merge 

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

func (*ClusterInfo_Member) XXX_Size 

func (m *ClusterInfo_Member) XXX_Size() int

func (*ClusterInfo_Member) XXX_Unmarshal 

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

type Commit 

type Commit struct {
	NodeID      github_com_kakao_varlog_pkg_types.NodeID `` /* 130-byte string literal not displayed */
	CreatedTime time.Time                                `protobuf:"bytes,2,opt,name=created_time,json=createdTime,proto3,stdtime" json:"created_time"`
}

func (*Commit) Descriptor 

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

func (*Commit) GetCreatedTime 

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

func (*Commit) GetNodeID 

func (m *Commit) GetNodeID() github_com_kakao_varlog_pkg_types.NodeID

func (*Commit) Marshal 

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

func (*Commit) MarshalTo 

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

func (*Commit) MarshalToSizedBuffer 

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

func (*Commit) ProtoMessage 

func (*Commit) ProtoMessage()

func (*Commit) ProtoSize 

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

func (*Commit) Reset 

func (m *Commit) Reset()

func (*Commit) String 

func (m *Commit) String() string

func (*Commit) Unmarshal 

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

func (*Commit) XXX_DiscardUnknown 

func (m *Commit) XXX_DiscardUnknown()

func (*Commit) XXX_Marshal 

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

func (*Commit) XXX_Merge 

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

func (*Commit) XXX_Size 

func (m *Commit) XXX_Size() int

func (*Commit) XXX_Unmarshal 

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

type Endpoint 

type Endpoint struct {
	NodeID github_com_kakao_varlog_pkg_types.NodeID `` /* 130-byte string literal not displayed */
	Url    string                                   `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
}

func (*Endpoint) Descriptor 

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

func (*Endpoint) GetNodeID 

func (m *Endpoint) GetNodeID() github_com_kakao_varlog_pkg_types.NodeID

func (*Endpoint) GetUrl 

func (m *Endpoint) GetUrl() string

func (*Endpoint) Marshal 

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

func (*Endpoint) MarshalTo 

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

func (*Endpoint) MarshalToSizedBuffer 

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

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoSize 

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

func (*Endpoint) Reset 

func (m *Endpoint) Reset()

func (*Endpoint) String 

func (m *Endpoint) String() string

func (*Endpoint) Unmarshal 

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

func (*Endpoint) XXX_DiscardUnknown 

func (m *Endpoint) XXX_DiscardUnknown()

func (*Endpoint) XXX_Marshal 

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

func (*Endpoint) XXX_Merge 

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

func (*Endpoint) XXX_Size 

func (m *Endpoint) XXX_Size() int

func (*Endpoint) XXX_Unmarshal 

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

type GetClusterInfoRequest 

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

GetClusterInfoRequest is a request message for GetClusterInfo RPC.

func (*GetClusterInfoRequest) Descriptor 

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

func (*GetClusterInfoRequest) GetClusterID 

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

func (*GetClusterInfoRequest) Marshal 

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

func (*GetClusterInfoRequest) MarshalTo 

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

func (*GetClusterInfoRequest) MarshalToSizedBuffer 

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

func (*GetClusterInfoRequest) ProtoMessage 

func (*GetClusterInfoRequest) ProtoMessage()

func (*GetClusterInfoRequest) ProtoSize 

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

func (*GetClusterInfoRequest) Reset 

func (m *GetClusterInfoRequest) Reset()

func (*GetClusterInfoRequest) String 

func (m *GetClusterInfoRequest) String() string

func (*GetClusterInfoRequest) Unmarshal 

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

func (*GetClusterInfoRequest) XXX_DiscardUnknown 

func (m *GetClusterInfoRequest) XXX_DiscardUnknown()

func (*GetClusterInfoRequest) XXX_Marshal 

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

func (*GetClusterInfoRequest) XXX_Merge 

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

func (*GetClusterInfoRequest) XXX_Size 

func (m *GetClusterInfoRequest) XXX_Size() int

func (*GetClusterInfoRequest) XXX_Unmarshal 

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

type GetClusterInfoResponse 

type GetClusterInfoResponse struct {
	ClusterInfo *ClusterInfo `protobuf:"bytes,1,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
}

GetClusterInfoResponse is a response message for GetClusterInfo RPC.

func (*GetClusterInfoResponse) Descriptor 

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

func (*GetClusterInfoResponse) GetClusterInfo 

func (m *GetClusterInfoResponse) GetClusterInfo() *ClusterInfo

func (*GetClusterInfoResponse) Marshal 

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

func (*GetClusterInfoResponse) MarshalTo 

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

func (*GetClusterInfoResponse) MarshalToSizedBuffer 

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

func (*GetClusterInfoResponse) ProtoMessage 

func (*GetClusterInfoResponse) ProtoMessage()

func (*GetClusterInfoResponse) ProtoSize 

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

func (*GetClusterInfoResponse) Reset 

func (m *GetClusterInfoResponse) Reset()

func (*GetClusterInfoResponse) String 

func (m *GetClusterInfoResponse) String() string

func (*GetClusterInfoResponse) Unmarshal 

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

func (*GetClusterInfoResponse) XXX_DiscardUnknown 

func (m *GetClusterInfoResponse) XXX_DiscardUnknown()

func (*GetClusterInfoResponse) XXX_Marshal 

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

func (*GetClusterInfoResponse) XXX_Merge 

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

func (*GetClusterInfoResponse) XXX_Size 

func (m *GetClusterInfoResponse) XXX_Size() int

func (*GetClusterInfoResponse) XXX_Unmarshal 

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

type GetMetadataRequest 

type GetMetadataRequest struct {
}

func (*GetMetadataRequest) Descriptor 

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

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 {
	Metadata *varlogpb.MetadataDescriptor `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
}

func (*GetMetadataResponse) Descriptor 

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

func (*GetMetadataResponse) GetMetadata 

func (m *GetMetadataResponse) GetMetadata() *varlogpb.MetadataDescriptor

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 LogStreamCommitResults 

type LogStreamCommitResults struct {
	Version       github_com_kakao_varlog_pkg_types.Version `protobuf:"varint,1,opt,name=version,proto3,casttype=github.com/kakao/varlog/pkg/types.Version" json:"version,omitempty"`
	CommitResults []snpb.LogStreamCommitResult              `protobuf:"bytes,3,rep,name=commit_results,json=commitResults,proto3" json:"commit_results"`
}

func (*LogStreamCommitResults) Descriptor 

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

func (*LogStreamCommitResults) Equal 

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

func (*LogStreamCommitResults) GetCommitResults 

func (m *LogStreamCommitResults) GetCommitResults() []snpb.LogStreamCommitResult

func (*LogStreamCommitResults) GetVersion 

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

func (*LogStreamCommitResults) LastHighWatermark 

func (crs *LogStreamCommitResults) LastHighWatermark(topicID types.TopicID, hintPos int) (types.GLSN, int)

return HighWatermark of the topic TODO:: lookup last logStream of the topic

func (*LogStreamCommitResults) LookupCommitResult 

func (crs *LogStreamCommitResults) LookupCommitResult(topicID types.TopicID, lsID types.LogStreamID, hintPos int) (snpb.LogStreamCommitResult, int, bool)

func (*LogStreamCommitResults) Marshal 

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

func (*LogStreamCommitResults) MarshalTo 

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

func (*LogStreamCommitResults) MarshalToSizedBuffer 

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

func (*LogStreamCommitResults) ProtoMessage 

func (*LogStreamCommitResults) ProtoMessage()

func (*LogStreamCommitResults) ProtoSize 

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

func (*LogStreamCommitResults) Reset 

func (m *LogStreamCommitResults) Reset()

func (*LogStreamCommitResults) String 

func (m *LogStreamCommitResults) String() string

func (*LogStreamCommitResults) Unmarshal 

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

func (*LogStreamCommitResults) XXX_DiscardUnknown 

func (m *LogStreamCommitResults) XXX_DiscardUnknown()

func (*LogStreamCommitResults) XXX_Marshal 

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

func (*LogStreamCommitResults) XXX_Merge 

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

func (*LogStreamCommitResults) XXX_Size 

func (m *LogStreamCommitResults) XXX_Size() int

func (*LogStreamCommitResults) XXX_Unmarshal 

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

type LogStreamRequest 

type LogStreamRequest struct {
	LogStream *varlogpb.LogStreamDescriptor `protobuf:"bytes,1,opt,name=log_stream,json=logStream,proto3" json:"log_stream,omitempty"`
}

func (*LogStreamRequest) Descriptor 

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

func (*LogStreamRequest) GetLogStream 

func (m *LogStreamRequest) GetLogStream() *varlogpb.LogStreamDescriptor

func (*LogStreamRequest) Marshal 

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

func (*LogStreamRequest) MarshalTo 

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

func (*LogStreamRequest) MarshalToSizedBuffer 

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

func (*LogStreamRequest) ProtoMessage 

func (*LogStreamRequest) ProtoMessage()

func (*LogStreamRequest) ProtoSize 

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

func (*LogStreamRequest) Reset 

func (m *LogStreamRequest) Reset()

func (*LogStreamRequest) String 

func (m *LogStreamRequest) String() string

func (*LogStreamRequest) Unmarshal 

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

func (*LogStreamRequest) XXX_DiscardUnknown 

func (m *LogStreamRequest) XXX_DiscardUnknown()

func (*LogStreamRequest) XXX_Marshal 

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

func (*LogStreamRequest) XXX_Merge 

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

func (*LogStreamRequest) XXX_Size 

func (m *LogStreamRequest) XXX_Size() int

func (*LogStreamRequest) XXX_Unmarshal 

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

type LogStreamUncommitReports 

type LogStreamUncommitReports struct {
	Replicas map[github_com_kakao_varlog_pkg_types.StorageNodeID]snpb.LogStreamUncommitReport `` /* 204-byte string literal not displayed */
	Status   varlogpb.LogStreamStatus                                                         `protobuf:"varint,2,opt,name=status,proto3,enum=varlog.varlogpb.LogStreamStatus" json:"status,omitempty"`
}

func (*LogStreamUncommitReports) Deleted 

func (l *LogStreamUncommitReports) Deleted() bool

func (*LogStreamUncommitReports) Descriptor 

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

func (*LogStreamUncommitReports) Equal 

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

func (*LogStreamUncommitReports) GetReplicas 

func (m *LogStreamUncommitReports) GetReplicas() map[github_com_kakao_varlog_pkg_types.StorageNodeID]snpb.LogStreamUncommitReport

func (*LogStreamUncommitReports) GetStatus 

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

func (*LogStreamUncommitReports) Marshal 

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

func (*LogStreamUncommitReports) MarshalTo 

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

func (*LogStreamUncommitReports) MarshalToSizedBuffer 

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

func (*LogStreamUncommitReports) ProtoMessage 

func (*LogStreamUncommitReports) ProtoMessage()

func (*LogStreamUncommitReports) ProtoSize 

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

func (*LogStreamUncommitReports) Reset 

func (m *LogStreamUncommitReports) Reset()

func (*LogStreamUncommitReports) String 

func (m *LogStreamUncommitReports) String() string

func (*LogStreamUncommitReports) Unmarshal 

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

func (*LogStreamUncommitReports) XXX_DiscardUnknown 

func (m *LogStreamUncommitReports) XXX_DiscardUnknown()

func (*LogStreamUncommitReports) XXX_Marshal 

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

func (*LogStreamUncommitReports) XXX_Merge 

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

func (*LogStreamUncommitReports) XXX_Size 

func (m *LogStreamUncommitReports) XXX_Size() int

func (*LogStreamUncommitReports) XXX_Unmarshal 

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

type ManagementClient 

type ManagementClient interface {
	// AddPeer adds a new node to the Raft cluster.
	//
	// It takes an AddPeerRequest as an argument and checks the validity of the
	// given Node ID. If the Node ID is invalid, it returns a gRPC status code
	// "InvalidArgument". If the node is already a member or learner, it returns a
	// gRPC status code "AlreadyExists". Upon successful execution, this operation
	// returns an instance of google.protobuf.Empty.
	//
	// Note that users can cancel this operation, but cancellation does not
	// guarantee that the addition of a new peer will not be handled.
	//
	// TODO: Implement a check for the cluster ID.
	AddPeer(ctx context.Context, in *AddPeerRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// RemovePeer removes a specific node from a Raft cluster.
	//
	// It takes a RemovePeerRequest as an argument and checks the validity of the
	// Node ID. If the Node ID is invalid, it returns a gRPC status code
	// "InvalidArgument". If the node is neither a member nor a learner in the
	// cluster, it returns a gRPC status code "NotFound". Upon successful
	// execution, this operation returns an instance of google.protobuf.Empty.
	//
	// Note that although users can cancel this operation, cancellation does not
	// guarantee that the node will not be removed.
	//
	// TODO: Implement a check for the cluster ID.
	RemovePeer(ctx context.Context, in *RemovePeerRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// GetClusterInfo is a remote procedure used to retrieve information about the
	// Raft cluster, specifically the ClusterInfo. If the current node is not a
	// member of the cluster, it will fail and return the gRPC status code
	// "codes.Unavailable".
	//
	// TODO: Check if the cluster ID is the same as the current node's. If they
	// are not the same, return a proper gRPC status code.
	//
	// TODO: Define ClusterInfo, which should contain the Raft cluster metadata.
	// Some fields will be removed due to unmatched semantics.
	GetClusterInfo(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*GetClusterInfoResponse, 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 {
	// AddPeer adds a new node to the Raft cluster.
	//
	// It takes an AddPeerRequest as an argument and checks the validity of the
	// given Node ID. If the Node ID is invalid, it returns a gRPC status code
	// "InvalidArgument". If the node is already a member or learner, it returns a
	// gRPC status code "AlreadyExists". Upon successful execution, this operation
	// returns an instance of google.protobuf.Empty.
	//
	// Note that users can cancel this operation, but cancellation does not
	// guarantee that the addition of a new peer will not be handled.
	//
	// TODO: Implement a check for the cluster ID.
	AddPeer(context.Context, *AddPeerRequest) (*types.Empty, error)
	// RemovePeer removes a specific node from a Raft cluster.
	//
	// It takes a RemovePeerRequest as an argument and checks the validity of the
	// Node ID. If the Node ID is invalid, it returns a gRPC status code
	// "InvalidArgument". If the node is neither a member nor a learner in the
	// cluster, it returns a gRPC status code "NotFound". Upon successful
	// execution, this operation returns an instance of google.protobuf.Empty.
	//
	// Note that although users can cancel this operation, cancellation does not
	// guarantee that the node will not be removed.
	//
	// TODO: Implement a check for the cluster ID.
	RemovePeer(context.Context, *RemovePeerRequest) (*types.Empty, error)
	// GetClusterInfo is a remote procedure used to retrieve information about the
	// Raft cluster, specifically the ClusterInfo. If the current node is not a
	// member of the cluster, it will fail and return the gRPC status code
	// "codes.Unavailable".
	//
	// TODO: Check if the cluster ID is the same as the current node's. If they
	// are not the same, return a proper gRPC status code.
	//
	// TODO: Define ClusterInfo, which should contain the Raft cluster metadata.
	// Some fields will be removed due to unmatched semantics.
	GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
}

ManagementServer is the server API for Management service.

type MetadataRepositoryDescriptor 

type MetadataRepositoryDescriptor struct {
	Metadata  *varlogpb.MetadataDescriptor                        `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	LogStream *MetadataRepositoryDescriptor_LogStreamDescriptor   `protobuf:"bytes,2,opt,name=log_stream,json=logStream,proto3" json:"log_stream,omitempty"`
	PeersMap  MetadataRepositoryDescriptor_PeerDescriptorMap      `protobuf:"bytes,3,opt,name=peers_map,json=peersMap,proto3" json:"peers_map"`
	Endpoints map[github_com_kakao_varlog_pkg_types.NodeID]string `` /* 209-byte string literal not displayed */
}

func (*MetadataRepositoryDescriptor) Descriptor 

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

func (*MetadataRepositoryDescriptor) GetEndpoints 

func (m *MetadataRepositoryDescriptor) GetEndpoints() map[github_com_kakao_varlog_pkg_types.NodeID]string

func (*MetadataRepositoryDescriptor) GetFirstCommitResults 

func (s *MetadataRepositoryDescriptor) GetFirstCommitResults() *LogStreamCommitResults

func (*MetadataRepositoryDescriptor) GetLastCommitResults 

func (s *MetadataRepositoryDescriptor) GetLastCommitResults() *LogStreamCommitResults

func (*MetadataRepositoryDescriptor) GetLogStream 

func (m *MetadataRepositoryDescriptor) GetLogStream() *MetadataRepositoryDescriptor_LogStreamDescriptor

func (*MetadataRepositoryDescriptor) GetMetadata 

func (m *MetadataRepositoryDescriptor) GetMetadata() *varlogpb.MetadataDescriptor

func (*MetadataRepositoryDescriptor) GetPeersMap 

func (m *MetadataRepositoryDescriptor) GetPeersMap() MetadataRepositoryDescriptor_PeerDescriptorMap

func (*MetadataRepositoryDescriptor) LookupCommitResults 

func (s *MetadataRepositoryDescriptor) LookupCommitResults(ver types.Version) *LogStreamCommitResults

func (*MetadataRepositoryDescriptor) Marshal 

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

func (*MetadataRepositoryDescriptor) MarshalTo 

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

func (*MetadataRepositoryDescriptor) MarshalToSizedBuffer 

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

func (*MetadataRepositoryDescriptor) ProtoMessage 

func (*MetadataRepositoryDescriptor) ProtoMessage()

func (*MetadataRepositoryDescriptor) ProtoSize 

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

func (*MetadataRepositoryDescriptor) Reset 

func (m *MetadataRepositoryDescriptor) Reset()

func (*MetadataRepositoryDescriptor) String 

func (m *MetadataRepositoryDescriptor) String() string

func (*MetadataRepositoryDescriptor) Unmarshal 

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

func (*MetadataRepositoryDescriptor) XXX_DiscardUnknown 

func (m *MetadataRepositoryDescriptor) XXX_DiscardUnknown()

func (*MetadataRepositoryDescriptor) XXX_Marshal 

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

func (*MetadataRepositoryDescriptor) XXX_Merge 

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

func (*MetadataRepositoryDescriptor) XXX_Size 

func (m *MetadataRepositoryDescriptor) XXX_Size() int

func (*MetadataRepositoryDescriptor) XXX_Unmarshal 

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

type MetadataRepositoryDescriptor_LogStreamDescriptor 

type MetadataRepositoryDescriptor_LogStreamDescriptor struct {
	TrimVersion     github_com_kakao_varlog_pkg_types.Version                                   `` /* 146-byte string literal not displayed */
	CommitHistory   []*LogStreamCommitResults                                                   `protobuf:"bytes,2,rep,name=commit_history,json=commitHistory,proto3" json:"commit_history,omitempty"`
	UncommitReports map[github_com_kakao_varlog_pkg_types.LogStreamID]*LogStreamUncommitReports `` /* 249-byte string literal not displayed */
}

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) Descriptor 

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

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) GetCommitHistory 

func (m *MetadataRepositoryDescriptor_LogStreamDescriptor) GetCommitHistory() []*LogStreamCommitResults

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) GetTrimVersion 

func (m *MetadataRepositoryDescriptor_LogStreamDescriptor) GetTrimVersion() github_com_kakao_varlog_pkg_types.Version

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) GetUncommitReports 

func (m *MetadataRepositoryDescriptor_LogStreamDescriptor) GetUncommitReports() map[github_com_kakao_varlog_pkg_types.LogStreamID]*LogStreamUncommitReports

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) Marshal 

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

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) MarshalTo 

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

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) MarshalToSizedBuffer 

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

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) ProtoMessage 

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) ProtoMessage()

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) ProtoSize 

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

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) Reset 

func (m *MetadataRepositoryDescriptor_LogStreamDescriptor) Reset()

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) String 

func (m *MetadataRepositoryDescriptor_LogStreamDescriptor) String() string

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) Unmarshal 

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

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) XXX_DiscardUnknown 

func (m *MetadataRepositoryDescriptor_LogStreamDescriptor) XXX_DiscardUnknown()

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) XXX_Marshal 

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

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) XXX_Merge 

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

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) XXX_Size 

func (m *MetadataRepositoryDescriptor_LogStreamDescriptor) XXX_Size() int

func (*MetadataRepositoryDescriptor_LogStreamDescriptor) XXX_Unmarshal 

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

type MetadataRepositoryDescriptor_PeerDescriptor 

type MetadataRepositoryDescriptor_PeerDescriptor struct {
	URL       string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	IsLearner bool   `protobuf:"varint,2,opt,name=is_learner,json=isLearner,proto3" json:"is_learner,omitempty"`
}

func (*MetadataRepositoryDescriptor_PeerDescriptor) Descriptor 

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

func (*MetadataRepositoryDescriptor_PeerDescriptor) GetIsLearner 

func (m *MetadataRepositoryDescriptor_PeerDescriptor) GetIsLearner() bool

func (*MetadataRepositoryDescriptor_PeerDescriptor) GetURL 

func (m *MetadataRepositoryDescriptor_PeerDescriptor) GetURL() string

func (*MetadataRepositoryDescriptor_PeerDescriptor) Marshal 

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

func (*MetadataRepositoryDescriptor_PeerDescriptor) MarshalTo 

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

func (*MetadataRepositoryDescriptor_PeerDescriptor) MarshalToSizedBuffer 

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

func (*MetadataRepositoryDescriptor_PeerDescriptor) ProtoMessage 

func (*MetadataRepositoryDescriptor_PeerDescriptor) ProtoMessage()

func (*MetadataRepositoryDescriptor_PeerDescriptor) ProtoSize 

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

func (*MetadataRepositoryDescriptor_PeerDescriptor) Reset 

func (m *MetadataRepositoryDescriptor_PeerDescriptor) Reset()

func (*MetadataRepositoryDescriptor_PeerDescriptor) String 

func (m *MetadataRepositoryDescriptor_PeerDescriptor) String() string

func (*MetadataRepositoryDescriptor_PeerDescriptor) Unmarshal 

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

func (*MetadataRepositoryDescriptor_PeerDescriptor) XXX_DiscardUnknown 

func (m *MetadataRepositoryDescriptor_PeerDescriptor) XXX_DiscardUnknown()

func (*MetadataRepositoryDescriptor_PeerDescriptor) XXX_Marshal 

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

func (*MetadataRepositoryDescriptor_PeerDescriptor) XXX_Merge 

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

func (*MetadataRepositoryDescriptor_PeerDescriptor) XXX_Size 

func (m *MetadataRepositoryDescriptor_PeerDescriptor) XXX_Size() int

func (*MetadataRepositoryDescriptor_PeerDescriptor) XXX_Unmarshal 

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

type MetadataRepositoryDescriptor_PeerDescriptorMap 

type MetadataRepositoryDescriptor_PeerDescriptorMap struct {
	Peers map[github_com_kakao_varlog_pkg_types.NodeID]*MetadataRepositoryDescriptor_PeerDescriptor `` /* 201-byte string literal not displayed */
	// applied_index is the AppliedIndex of RAFT that is updated by changing
	// configuration of members. For example, AddPeer and RemovePeer result
	// in increasing applied_index.
	AppliedIndex uint64 `protobuf:"varint,2,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
}

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) Descriptor 

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

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) GetAppliedIndex 

func (m *MetadataRepositoryDescriptor_PeerDescriptorMap) GetAppliedIndex() uint64

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) GetPeers 

func (m *MetadataRepositoryDescriptor_PeerDescriptorMap) GetPeers() map[github_com_kakao_varlog_pkg_types.NodeID]*MetadataRepositoryDescriptor_PeerDescriptor

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) Marshal 

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

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) MarshalTo 

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

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) MarshalToSizedBuffer 

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

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) ProtoMessage 

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) ProtoMessage()

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) ProtoSize 

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

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) Reset 

func (m *MetadataRepositoryDescriptor_PeerDescriptorMap) Reset()

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) String 

func (m *MetadataRepositoryDescriptor_PeerDescriptorMap) String() string

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) Unmarshal 

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

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) XXX_DiscardUnknown 

func (m *MetadataRepositoryDescriptor_PeerDescriptorMap) XXX_DiscardUnknown()

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) XXX_Marshal 

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

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) XXX_Merge 

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

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) XXX_Size 

func (m *MetadataRepositoryDescriptor_PeerDescriptorMap) XXX_Size() int

func (*MetadataRepositoryDescriptor_PeerDescriptorMap) XXX_Unmarshal 

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

type MetadataRepositoryServiceClient 

type MetadataRepositoryServiceClient interface {
	RegisterStorageNode(ctx context.Context, in *StorageNodeRequest, opts ...grpc.CallOption) (*types.Empty, error)
	UnregisterStorageNode(ctx context.Context, in *StorageNodeRequest, opts ...grpc.CallOption) (*types.Empty, error)
	RegisterTopic(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*types.Empty, error)
	UnregisterTopic(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*types.Empty, error)
	RegisterLogStream(ctx context.Context, in *LogStreamRequest, opts ...grpc.CallOption) (*types.Empty, error)
	UnregisterLogStream(ctx context.Context, in *LogStreamRequest, opts ...grpc.CallOption) (*types.Empty, error)
	UpdateLogStream(ctx context.Context, in *LogStreamRequest, opts ...grpc.CallOption) (*types.Empty, error)
	GetMetadata(ctx context.Context, in *GetMetadataRequest, opts ...grpc.CallOption) (*GetMetadataResponse, error)
	Seal(ctx context.Context, in *SealRequest, opts ...grpc.CallOption) (*SealResponse, error)
	Unseal(ctx context.Context, in *UnsealRequest, opts ...grpc.CallOption) (*UnsealResponse, error)
}

MetadataRepositoryServiceClient is the client API for MetadataRepositoryService service.

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

func NewMetadataRepositoryServiceClient 

func NewMetadataRepositoryServiceClient(cc *grpc.ClientConn) MetadataRepositoryServiceClient

type MetadataRepositoryServiceServer 

type MetadataRepositoryServiceServer interface {
	RegisterStorageNode(context.Context, *StorageNodeRequest) (*types.Empty, error)
	UnregisterStorageNode(context.Context, *StorageNodeRequest) (*types.Empty, error)
	RegisterTopic(context.Context, *TopicRequest) (*types.Empty, error)
	UnregisterTopic(context.Context, *TopicRequest) (*types.Empty, error)
	RegisterLogStream(context.Context, *LogStreamRequest) (*types.Empty, error)
	UnregisterLogStream(context.Context, *LogStreamRequest) (*types.Empty, error)
	UpdateLogStream(context.Context, *LogStreamRequest) (*types.Empty, error)
	GetMetadata(context.Context, *GetMetadataRequest) (*GetMetadataResponse, error)
	Seal(context.Context, *SealRequest) (*SealResponse, error)
	Unseal(context.Context, *UnsealRequest) (*UnsealResponse, error)
}

MetadataRepositoryServiceServer is the server API for MetadataRepositoryService service.

type PeerInfo added in v0.23.0 

type PeerInfo struct {
	// ClusterID is the identifier of the Varlog cluster.
	ClusterID github_com_kakao_varlog_pkg_types.ClusterID `` /* 142-byte string literal not displayed */
	// NodeID is the identifier of the metadata repository node.
	NodeID github_com_kakao_varlog_pkg_types.NodeID `` /* 130-byte string literal not displayed */
	// URL is the RAFT endpoint of the metadata repository node.
	// It should be in the format of "http://<IP>:<Port>".
	URL string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
}

PeerInfo represents information about a RAFT peer.

func (*PeerInfo) Descriptor added in v0.23.0 

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

func (*PeerInfo) GetClusterID added in v0.23.0 

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

func (*PeerInfo) GetNodeID added in v0.23.0 

func (m *PeerInfo) GetNodeID() github_com_kakao_varlog_pkg_types.NodeID

func (*PeerInfo) GetURL added in v0.23.0 

func (m *PeerInfo) GetURL() string

func (*PeerInfo) Marshal added in v0.23.0 

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

func (*PeerInfo) MarshalTo added in v0.23.0 

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

func (*PeerInfo) MarshalToSizedBuffer added in v0.23.0 

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

func (*PeerInfo) ProtoMessage added in v0.23.0 

func (*PeerInfo) ProtoMessage()

func (*PeerInfo) ProtoSize added in v0.23.0 

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

func (*PeerInfo) Reset added in v0.23.0 

func (m *PeerInfo) Reset()

func (*PeerInfo) String added in v0.23.0 

func (m *PeerInfo) String() string

func (*PeerInfo) Unmarshal added in v0.23.0 

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

func (*PeerInfo) XXX_DiscardUnknown added in v0.23.0 

func (m *PeerInfo) XXX_DiscardUnknown()

func (*PeerInfo) XXX_Marshal added in v0.23.0 

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

func (*PeerInfo) XXX_Merge added in v0.23.0 

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

func (*PeerInfo) XXX_Size added in v0.23.0 

func (m *PeerInfo) XXX_Size() int

func (*PeerInfo) XXX_Unmarshal added in v0.23.0 

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

type RaftEntry 

type RaftEntry struct {
	NodeIndex    uint64            `protobuf:"varint,1,opt,name=node_index,json=nodeIndex,proto3" json:"node_index,omitempty"`
	RequestIndex uint64            `protobuf:"varint,2,opt,name=request_index,json=requestIndex,proto3" json:"request_index,omitempty"`
	AppliedIndex uint64            `protobuf:"varint,3,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	Request      RaftEntry_Request `protobuf:"bytes,4,opt,name=request,proto3" json:"request"`
}

func NewRaftEntry added in v0.15.0 

func NewRaftEntry() *RaftEntry

func (*RaftEntry) Descriptor 

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

func (*RaftEntry) GetAppliedIndex 

func (m *RaftEntry) GetAppliedIndex() uint64

func (*RaftEntry) GetNodeIndex 

func (m *RaftEntry) GetNodeIndex() uint64

func (*RaftEntry) GetRequest 

func (m *RaftEntry) GetRequest() RaftEntry_Request

func (*RaftEntry) GetRequestIndex 

func (m *RaftEntry) GetRequestIndex() uint64

func (*RaftEntry) Marshal 

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

func (*RaftEntry) MarshalTo 

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

func (*RaftEntry) MarshalToSizedBuffer 

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

func (*RaftEntry) ProtoMessage 

func (*RaftEntry) ProtoMessage()

func (*RaftEntry) ProtoSize 

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

func (*RaftEntry) Release added in v0.15.0 

func (re *RaftEntry) Release()

func (*RaftEntry) Reset 

func (m *RaftEntry) Reset()

func (*RaftEntry) String 

func (m *RaftEntry) String() string

func (*RaftEntry) Unmarshal 

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

func (*RaftEntry) XXX_DiscardUnknown 

func (m *RaftEntry) XXX_DiscardUnknown()

func (*RaftEntry) XXX_Marshal 

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

func (*RaftEntry) XXX_Merge 

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

func (*RaftEntry) XXX_Size 

func (m *RaftEntry) XXX_Size() int

func (*RaftEntry) XXX_Unmarshal 

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

type RaftEntry_Request 

type RaftEntry_Request struct {
	RegisterStorageNode   *RegisterStorageNode   `protobuf:"bytes,1,opt,name=register_storage_node,json=registerStorageNode,proto3" json:"register_storage_node,omitempty"`
	UnregisterStorageNode *UnregisterStorageNode `` /* 126-byte string literal not displayed */
	RegisterLogStream     *RegisterLogStream     `protobuf:"bytes,3,opt,name=register_log_stream,json=registerLogStream,proto3" json:"register_log_stream,omitempty"`
	UnregisterLogStream   *UnregisterLogStream   `protobuf:"bytes,4,opt,name=unregister_log_stream,json=unregisterLogStream,proto3" json:"unregister_log_stream,omitempty"`
	UpdateLogStream       *UpdateLogStream       `protobuf:"bytes,5,opt,name=update_log_stream,json=updateLogStream,proto3" json:"update_log_stream,omitempty"`
	Report                *Reports               `protobuf:"bytes,6,opt,name=report,proto3" json:"report,omitempty"`
	Commit                *Commit                `protobuf:"bytes,7,opt,name=commit,proto3" json:"commit,omitempty"`
	Seal                  *Seal                  `protobuf:"bytes,8,opt,name=seal,proto3" json:"seal,omitempty"`
	Unseal                *Unseal                `protobuf:"bytes,9,opt,name=unseal,proto3" json:"unseal,omitempty"`
	AddPeer               *AddPeer               `protobuf:"bytes,10,opt,name=add_peer,json=addPeer,proto3" json:"add_peer,omitempty"`
	RemovePeer            *RemovePeer            `protobuf:"bytes,11,opt,name=remove_peer,json=removePeer,proto3" json:"remove_peer,omitempty"`
	Endpoint              *Endpoint              `protobuf:"bytes,12,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	RecoverStateMachine   *RecoverStateMachine   `protobuf:"bytes,13,opt,name=recover_state_machine,json=recoverStateMachine,proto3" json:"recover_state_machine,omitempty"`
	RegisterTopic         *RegisterTopic         `protobuf:"bytes,14,opt,name=register_topic,json=registerTopic,proto3" json:"register_topic,omitempty"`
	UnregisterTopic       *UnregisterTopic       `protobuf:"bytes,15,opt,name=unregister_topic,json=unregisterTopic,proto3" json:"unregister_topic,omitempty"`
}

func (*RaftEntry_Request) Descriptor 

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

func (*RaftEntry_Request) GetAddPeer 

func (m *RaftEntry_Request) GetAddPeer() *AddPeer

func (*RaftEntry_Request) GetCommit 

func (m *RaftEntry_Request) GetCommit() *Commit

func (*RaftEntry_Request) GetEndpoint 

func (m *RaftEntry_Request) GetEndpoint() *Endpoint

func (*RaftEntry_Request) GetRecoverStateMachine 

func (m *RaftEntry_Request) GetRecoverStateMachine() *RecoverStateMachine

func (*RaftEntry_Request) GetRegisterLogStream 

func (m *RaftEntry_Request) GetRegisterLogStream() *RegisterLogStream

func (*RaftEntry_Request) GetRegisterStorageNode 

func (m *RaftEntry_Request) GetRegisterStorageNode() *RegisterStorageNode

func (*RaftEntry_Request) GetRegisterTopic 

func (m *RaftEntry_Request) GetRegisterTopic() *RegisterTopic

func (*RaftEntry_Request) GetRemovePeer 

func (m *RaftEntry_Request) GetRemovePeer() *RemovePeer

func (*RaftEntry_Request) GetReport 

func (m *RaftEntry_Request) GetReport() *Reports

func (*RaftEntry_Request) GetSeal 

func (m *RaftEntry_Request) GetSeal() *Seal

func (*RaftEntry_Request) GetUnregisterLogStream 

func (m *RaftEntry_Request) GetUnregisterLogStream() *UnregisterLogStream

func (*RaftEntry_Request) GetUnregisterStorageNode 

func (m *RaftEntry_Request) GetUnregisterStorageNode() *UnregisterStorageNode

func (*RaftEntry_Request) GetUnregisterTopic 

func (m *RaftEntry_Request) GetUnregisterTopic() *UnregisterTopic

func (*RaftEntry_Request) GetUnseal 

func (m *RaftEntry_Request) GetUnseal() *Unseal

func (*RaftEntry_Request) GetUpdateLogStream 

func (m *RaftEntry_Request) GetUpdateLogStream() *UpdateLogStream

func (*RaftEntry_Request) GetValue 

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

func (*RaftEntry_Request) Marshal 

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

func (*RaftEntry_Request) MarshalTo 

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

func (*RaftEntry_Request) MarshalToSizedBuffer 

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

func (*RaftEntry_Request) ProtoMessage 

func (*RaftEntry_Request) ProtoMessage()

func (*RaftEntry_Request) ProtoSize 

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

func (*RaftEntry_Request) Reset 

func (m *RaftEntry_Request) Reset()

func (*RaftEntry_Request) SetValue 

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

func (*RaftEntry_Request) String 

func (m *RaftEntry_Request) String() string

func (*RaftEntry_Request) Unmarshal 

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

func (*RaftEntry_Request) XXX_DiscardUnknown 

func (m *RaftEntry_Request) XXX_DiscardUnknown()

func (*RaftEntry_Request) XXX_Marshal 

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

func (*RaftEntry_Request) XXX_Merge 

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

func (*RaftEntry_Request) XXX_Size 

func (m *RaftEntry_Request) XXX_Size() int

func (*RaftEntry_Request) XXX_Unmarshal 

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

type RecoverStateMachine 

type RecoverStateMachine struct {
	StateMachine *MetadataRepositoryDescriptor `protobuf:"bytes,1,opt,name=state_machine,json=stateMachine,proto3" json:"state_machine,omitempty"`
}

func (*RecoverStateMachine) Descriptor 

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

func (*RecoverStateMachine) GetStateMachine 

func (m *RecoverStateMachine) GetStateMachine() *MetadataRepositoryDescriptor

func (*RecoverStateMachine) Marshal 

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

func (*RecoverStateMachine) MarshalTo 

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

func (*RecoverStateMachine) MarshalToSizedBuffer 

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

func (*RecoverStateMachine) ProtoMessage 

func (*RecoverStateMachine) ProtoMessage()

func (*RecoverStateMachine) ProtoSize 

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

func (*RecoverStateMachine) Reset 

func (m *RecoverStateMachine) Reset()

func (*RecoverStateMachine) String 

func (m *RecoverStateMachine) String() string

func (*RecoverStateMachine) Unmarshal 

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

func (*RecoverStateMachine) XXX_DiscardUnknown 

func (m *RecoverStateMachine) XXX_DiscardUnknown()

func (*RecoverStateMachine) XXX_Marshal 

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

func (*RecoverStateMachine) XXX_Merge 

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

func (*RecoverStateMachine) XXX_Size 

func (m *RecoverStateMachine) XXX_Size() int

func (*RecoverStateMachine) XXX_Unmarshal 

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

type RegisterLogStream 

type RegisterLogStream struct {
	LogStream *varlogpb.LogStreamDescriptor `protobuf:"bytes,1,opt,name=log_stream,json=logStream,proto3" json:"log_stream,omitempty"`
}

func (*RegisterLogStream) Descriptor 

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

func (*RegisterLogStream) GetLogStream 

func (m *RegisterLogStream) GetLogStream() *varlogpb.LogStreamDescriptor

func (*RegisterLogStream) Marshal 

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

func (*RegisterLogStream) MarshalTo 

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

func (*RegisterLogStream) MarshalToSizedBuffer 

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

func (*RegisterLogStream) ProtoMessage 

func (*RegisterLogStream) ProtoMessage()

func (*RegisterLogStream) ProtoSize 

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

func (*RegisterLogStream) Reset 

func (m *RegisterLogStream) Reset()

func (*RegisterLogStream) String 

func (m *RegisterLogStream) String() string

func (*RegisterLogStream) Unmarshal 

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

func (*RegisterLogStream) XXX_DiscardUnknown 

func (m *RegisterLogStream) XXX_DiscardUnknown()

func (*RegisterLogStream) XXX_Marshal 

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

func (*RegisterLogStream) XXX_Merge 

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

func (*RegisterLogStream) XXX_Size 

func (m *RegisterLogStream) XXX_Size() int

func (*RegisterLogStream) XXX_Unmarshal 

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

type RegisterStorageNode 

type RegisterStorageNode struct {
	StorageNode *varlogpb.StorageNodeDescriptor `protobuf:"bytes,1,opt,name=storage_node,json=storageNode,proto3" json:"storage_node,omitempty"`
}

func (*RegisterStorageNode) Descriptor 

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

func (*RegisterStorageNode) GetStorageNode 

func (m *RegisterStorageNode) GetStorageNode() *varlogpb.StorageNodeDescriptor

func (*RegisterStorageNode) Marshal 

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

func (*RegisterStorageNode) MarshalTo 

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

func (*RegisterStorageNode) MarshalToSizedBuffer 

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

func (*RegisterStorageNode) ProtoMessage 

func (*RegisterStorageNode) ProtoMessage()

func (*RegisterStorageNode) ProtoSize 

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

func (*RegisterStorageNode) Reset 

func (m *RegisterStorageNode) Reset()

func (*RegisterStorageNode) String 

func (m *RegisterStorageNode) String() string

func (*RegisterStorageNode) Unmarshal 

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

func (*RegisterStorageNode) XXX_DiscardUnknown 

func (m *RegisterStorageNode) XXX_DiscardUnknown()

func (*RegisterStorageNode) XXX_Marshal 

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

func (*RegisterStorageNode) XXX_Merge 

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

func (*RegisterStorageNode) XXX_Size 

func (m *RegisterStorageNode) XXX_Size() int

func (*RegisterStorageNode) XXX_Unmarshal 

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

type RegisterTopic 

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

func (*RegisterTopic) Descriptor 

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

func (*RegisterTopic) GetTopicID 

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

func (*RegisterTopic) Marshal 

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

func (*RegisterTopic) MarshalTo 

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

func (*RegisterTopic) MarshalToSizedBuffer 

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

func (*RegisterTopic) ProtoMessage 

func (*RegisterTopic) ProtoMessage()

func (*RegisterTopic) ProtoSize 

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

func (*RegisterTopic) Reset 

func (m *RegisterTopic) Reset()

func (*RegisterTopic) String 

func (m *RegisterTopic) String() string

func (*RegisterTopic) Unmarshal 

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

func (*RegisterTopic) XXX_DiscardUnknown 

func (m *RegisterTopic) XXX_DiscardUnknown()

func (*RegisterTopic) XXX_Marshal 

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

func (*RegisterTopic) XXX_Merge 

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

func (*RegisterTopic) XXX_Size 

func (m *RegisterTopic) XXX_Size() int

func (*RegisterTopic) XXX_Unmarshal 

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

type RemovePeer 

type RemovePeer struct {
	NodeID github_com_kakao_varlog_pkg_types.NodeID `` /* 130-byte string literal not displayed */
}

func (*RemovePeer) Descriptor 

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

func (*RemovePeer) GetNodeID 

func (m *RemovePeer) GetNodeID() github_com_kakao_varlog_pkg_types.NodeID

func (*RemovePeer) Marshal 

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

func (*RemovePeer) MarshalTo 

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

func (*RemovePeer) MarshalToSizedBuffer 

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

func (*RemovePeer) ProtoMessage 

func (*RemovePeer) ProtoMessage()

func (*RemovePeer) ProtoSize 

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

func (*RemovePeer) Reset 

func (m *RemovePeer) Reset()

func (*RemovePeer) String 

func (m *RemovePeer) String() string

func (*RemovePeer) Unmarshal 

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

func (*RemovePeer) XXX_DiscardUnknown 

func (m *RemovePeer) XXX_DiscardUnknown()

func (*RemovePeer) XXX_Marshal 

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

func (*RemovePeer) XXX_Merge 

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

func (*RemovePeer) XXX_Size 

func (m *RemovePeer) XXX_Size() int

func (*RemovePeer) XXX_Unmarshal 

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

type RemovePeerRequest 

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

RemovePeerRequest is a request message for RemovePeer RPC.

func (*RemovePeerRequest) Descriptor 

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

func (*RemovePeerRequest) GetClusterID 

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

func (*RemovePeerRequest) GetNodeID 

func (m *RemovePeerRequest) GetNodeID() github_com_kakao_varlog_pkg_types.NodeID

func (*RemovePeerRequest) Marshal 

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

func (*RemovePeerRequest) MarshalTo 

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

func (*RemovePeerRequest) MarshalToSizedBuffer 

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

func (*RemovePeerRequest) ProtoMessage 

func (*RemovePeerRequest) ProtoMessage()

func (*RemovePeerRequest) ProtoSize 

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

func (*RemovePeerRequest) Reset 

func (m *RemovePeerRequest) Reset()

func (*RemovePeerRequest) String 

func (m *RemovePeerRequest) String() string

func (*RemovePeerRequest) Unmarshal 

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

func (*RemovePeerRequest) XXX_DiscardUnknown 

func (m *RemovePeerRequest) XXX_DiscardUnknown()

func (*RemovePeerRequest) XXX_Marshal 

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

func (*RemovePeerRequest) XXX_Merge 

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

func (*RemovePeerRequest) XXX_Size 

func (m *RemovePeerRequest) XXX_Size() int

func (*RemovePeerRequest) XXX_Unmarshal 

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

type Report 

type Report struct {
	StorageNodeID  github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
	UncommitReport []snpb.LogStreamUncommitReport                  `protobuf:"bytes,3,rep,name=uncommit_report,json=uncommitReport,proto3" json:"uncommit_report"`
}

func (*Report) Descriptor 

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

func (*Report) GetStorageNodeID 

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

func (*Report) GetUncommitReport 

func (m *Report) GetUncommitReport() []snpb.LogStreamUncommitReport

func (*Report) Marshal 

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

func (*Report) MarshalTo 

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

func (*Report) MarshalToSizedBuffer 

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

func (*Report) ProtoMessage 

func (*Report) ProtoMessage()

func (*Report) ProtoSize 

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

func (*Report) Reset 

func (m *Report) Reset()

func (*Report) String 

func (m *Report) String() string

func (*Report) Unmarshal 

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

func (*Report) XXX_DiscardUnknown 

func (m *Report) XXX_DiscardUnknown()

func (*Report) XXX_Marshal 

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

func (*Report) XXX_Merge 

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

func (*Report) XXX_Size 

func (m *Report) XXX_Size() int

func (*Report) XXX_Unmarshal 

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

type ReportQueue added in v0.15.0 

type ReportQueue []*Report

func NewReportQueue added in v0.15.0 

func NewReportQueue() ReportQueue

func (*ReportQueue) Release added in v0.15.0 

func (rq *ReportQueue) Release()

type Reports 

type Reports struct {
	NodeID      github_com_kakao_varlog_pkg_types.NodeID `` /* 130-byte string literal not displayed */
	CreatedTime time.Time                                `protobuf:"bytes,2,opt,name=created_time,json=createdTime,proto3,stdtime" json:"created_time"`
	Reports     []*Report                                `protobuf:"bytes,3,rep,name=reports,proto3" json:"reports,omitempty"`
}

func NewReports added in v0.15.0 

func NewReports(nodeID types.NodeID, ts time.Time) *Reports

func (*Reports) Descriptor 

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

func (*Reports) GetCreatedTime 

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

func (*Reports) GetNodeID 

func (m *Reports) GetNodeID() github_com_kakao_varlog_pkg_types.NodeID

func (*Reports) GetReports 

func (m *Reports) GetReports() []*Report

func (*Reports) Marshal 

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

func (*Reports) MarshalTo 

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

func (*Reports) MarshalToSizedBuffer 

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

func (*Reports) ProtoMessage 

func (*Reports) ProtoMessage()

func (*Reports) ProtoSize 

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

func (*Reports) Release added in v0.15.0 

func (rs *Reports) Release()

func (*Reports) Reset 

func (m *Reports) Reset()

func (*Reports) String 

func (m *Reports) String() string

func (*Reports) Unmarshal 

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

func (*Reports) XXX_DiscardUnknown 

func (m *Reports) XXX_DiscardUnknown()

func (*Reports) XXX_Marshal 

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

func (*Reports) XXX_Merge 

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

func (*Reports) XXX_Size 

func (m *Reports) XXX_Size() int

func (*Reports) XXX_Unmarshal 

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

type Seal 

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

func (*Seal) Descriptor 

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

func (*Seal) GetLogStreamID 

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

func (*Seal) Marshal 

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

func (*Seal) MarshalTo 

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

func (*Seal) MarshalToSizedBuffer 

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

func (*Seal) ProtoMessage 

func (*Seal) ProtoMessage()

func (*Seal) ProtoSize 

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

func (*Seal) Reset 

func (m *Seal) Reset()

func (*Seal) String 

func (m *Seal) String() string

func (*Seal) Unmarshal 

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

func (*Seal) XXX_DiscardUnknown 

func (m *Seal) XXX_DiscardUnknown()

func (*Seal) XXX_Marshal 

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

func (*Seal) XXX_Merge 

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

func (*Seal) XXX_Size 

func (m *Seal) XXX_Size() int

func (*Seal) XXX_Unmarshal 

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

type SealRequest 

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

func (*SealRequest) Descriptor 

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

func (*SealRequest) GetClusterID 

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

func (*SealRequest) GetLogStreamID 

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

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 StorageNodeRequest 

type StorageNodeRequest struct {
	StorageNode *varlogpb.StorageNodeDescriptor `protobuf:"bytes,1,opt,name=storage_node,json=storageNode,proto3" json:"storage_node,omitempty"`
}

func (*StorageNodeRequest) Descriptor 

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

func (*StorageNodeRequest) GetStorageNode 

func (m *StorageNodeRequest) GetStorageNode() *varlogpb.StorageNodeDescriptor

func (*StorageNodeRequest) Marshal 

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

func (*StorageNodeRequest) MarshalTo 

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

func (*StorageNodeRequest) MarshalToSizedBuffer 

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

func (*StorageNodeRequest) ProtoMessage 

func (*StorageNodeRequest) ProtoMessage()

func (*StorageNodeRequest) ProtoSize 

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

func (*StorageNodeRequest) Reset 

func (m *StorageNodeRequest) Reset()

func (*StorageNodeRequest) String 

func (m *StorageNodeRequest) String() string

func (*StorageNodeRequest) Unmarshal 

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

func (*StorageNodeRequest) XXX_DiscardUnknown 

func (m *StorageNodeRequest) XXX_DiscardUnknown()

func (*StorageNodeRequest) XXX_Marshal 

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

func (*StorageNodeRequest) XXX_Merge 

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

func (*StorageNodeRequest) XXX_Size 

func (m *StorageNodeRequest) XXX_Size() int

func (*StorageNodeRequest) XXX_Unmarshal 

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

type StorageNodeUncommitReport 

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

func NewStorageNodeUncommitReport added in v0.15.0 

func NewStorageNodeUncommitReport(snid types.StorageNodeID) *StorageNodeUncommitReport

func (*StorageNodeUncommitReport) Descriptor 

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

func (*StorageNodeUncommitReport) GetStorageNodeID 

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

func (*StorageNodeUncommitReport) GetUncommitReports 

func (m *StorageNodeUncommitReport) GetUncommitReports() []snpb.LogStreamUncommitReport

func (*StorageNodeUncommitReport) Len 

func (l *StorageNodeUncommitReport) Len() int

func (*StorageNodeUncommitReport) Less 

func (l *StorageNodeUncommitReport) Less(i, j int) bool

func (*StorageNodeUncommitReport) LookupReport 

func (l *StorageNodeUncommitReport) LookupReport(lsID types.LogStreamID) (snpb.LogStreamUncommitReport, bool)

func (*StorageNodeUncommitReport) Marshal 

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

func (*StorageNodeUncommitReport) MarshalTo 

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

func (*StorageNodeUncommitReport) MarshalToSizedBuffer 

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

func (*StorageNodeUncommitReport) ProtoMessage 

func (*StorageNodeUncommitReport) ProtoMessage()

func (*StorageNodeUncommitReport) ProtoSize 

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

func (*StorageNodeUncommitReport) Release added in v0.13.0 

func (l *StorageNodeUncommitReport) Release()

func (*StorageNodeUncommitReport) Reset 

func (m *StorageNodeUncommitReport) Reset()

func (*StorageNodeUncommitReport) Sort 

func (l *StorageNodeUncommitReport) Sort()

func (*StorageNodeUncommitReport) String 

func (m *StorageNodeUncommitReport) String() string

func (*StorageNodeUncommitReport) Swap 

func (l *StorageNodeUncommitReport) Swap(i, j int)

func (*StorageNodeUncommitReport) Unmarshal 

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

func (*StorageNodeUncommitReport) XXX_DiscardUnknown 

func (m *StorageNodeUncommitReport) XXX_DiscardUnknown()

func (*StorageNodeUncommitReport) XXX_Marshal 

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

func (*StorageNodeUncommitReport) XXX_Merge 

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

func (*StorageNodeUncommitReport) XXX_Size 

func (m *StorageNodeUncommitReport) XXX_Size() int

func (*StorageNodeUncommitReport) XXX_Unmarshal 

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

type TopicRequest 

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

func (*TopicRequest) Descriptor 

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

func (*TopicRequest) GetTopicID 

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

func (*TopicRequest) Marshal 

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

func (*TopicRequest) MarshalTo 

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

func (*TopicRequest) MarshalToSizedBuffer 

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

func (*TopicRequest) ProtoMessage 

func (*TopicRequest) ProtoMessage()

func (*TopicRequest) ProtoSize 

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

func (*TopicRequest) Reset 

func (m *TopicRequest) Reset()

func (*TopicRequest) String 

func (m *TopicRequest) String() string

func (*TopicRequest) Unmarshal 

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

func (*TopicRequest) XXX_DiscardUnknown 

func (m *TopicRequest) XXX_DiscardUnknown()

func (*TopicRequest) XXX_Marshal 

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

func (*TopicRequest) XXX_Merge 

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

func (*TopicRequest) XXX_Size 

func (m *TopicRequest) XXX_Size() int

func (*TopicRequest) XXX_Unmarshal 

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

type UnimplementedManagementServer 

type UnimplementedManagementServer struct {
}

UnimplementedManagementServer can be embedded to have forward compatible implementations.

func (*UnimplementedManagementServer) AddPeer 

func (*UnimplementedManagementServer) AddPeer(ctx context.Context, req *AddPeerRequest) (*types.Empty, error)

func (*UnimplementedManagementServer) GetClusterInfo 

func (*UnimplementedManagementServer) GetClusterInfo(ctx context.Context, req *GetClusterInfoRequest) (*GetClusterInfoResponse, error)

func (*UnimplementedManagementServer) RemovePeer 

func (*UnimplementedManagementServer) RemovePeer(ctx context.Context, req *RemovePeerRequest) (*types.Empty, error)

type UnimplementedMetadataRepositoryServiceServer 

type UnimplementedMetadataRepositoryServiceServer struct {
}

UnimplementedMetadataRepositoryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetadataRepositoryServiceServer) GetMetadata 

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

func (*UnimplementedMetadataRepositoryServiceServer) RegisterLogStream 

func (*UnimplementedMetadataRepositoryServiceServer) RegisterLogStream(ctx context.Context, req *LogStreamRequest) (*types.Empty, error)

func (*UnimplementedMetadataRepositoryServiceServer) RegisterStorageNode 

func (*UnimplementedMetadataRepositoryServiceServer) RegisterStorageNode(ctx context.Context, req *StorageNodeRequest) (*types.Empty, error)

func (*UnimplementedMetadataRepositoryServiceServer) RegisterTopic 

func (*UnimplementedMetadataRepositoryServiceServer) RegisterTopic(ctx context.Context, req *TopicRequest) (*types.Empty, error)

func (*UnimplementedMetadataRepositoryServiceServer) Seal 

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

func (*UnimplementedMetadataRepositoryServiceServer) UnregisterLogStream 

func (*UnimplementedMetadataRepositoryServiceServer) UnregisterLogStream(ctx context.Context, req *LogStreamRequest) (*types.Empty, error)

func (*UnimplementedMetadataRepositoryServiceServer) UnregisterStorageNode 

func (*UnimplementedMetadataRepositoryServiceServer) UnregisterStorageNode(ctx context.Context, req *StorageNodeRequest) (*types.Empty, error)

func (*UnimplementedMetadataRepositoryServiceServer) UnregisterTopic 

func (*UnimplementedMetadataRepositoryServiceServer) UnregisterTopic(ctx context.Context, req *TopicRequest) (*types.Empty, error)

func (*UnimplementedMetadataRepositoryServiceServer) Unseal 

func (*UnimplementedMetadataRepositoryServiceServer) Unseal(ctx context.Context, req *UnsealRequest) (*UnsealResponse, error)

func (*UnimplementedMetadataRepositoryServiceServer) UpdateLogStream 

func (*UnimplementedMetadataRepositoryServiceServer) UpdateLogStream(ctx context.Context, req *LogStreamRequest) (*types.Empty, error)

type UnregisterLogStream 

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

func (*UnregisterLogStream) Descriptor 

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

func (*UnregisterLogStream) GetLogStreamID 

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

func (*UnregisterLogStream) Marshal 

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

func (*UnregisterLogStream) MarshalTo 

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

func (*UnregisterLogStream) MarshalToSizedBuffer 

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

func (*UnregisterLogStream) ProtoMessage 

func (*UnregisterLogStream) ProtoMessage()

func (*UnregisterLogStream) ProtoSize 

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

func (*UnregisterLogStream) Reset 

func (m *UnregisterLogStream) Reset()

func (*UnregisterLogStream) String 

func (m *UnregisterLogStream) String() string

func (*UnregisterLogStream) Unmarshal 

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

func (*UnregisterLogStream) XXX_DiscardUnknown 

func (m *UnregisterLogStream) XXX_DiscardUnknown()

func (*UnregisterLogStream) XXX_Marshal 

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

func (*UnregisterLogStream) XXX_Merge 

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

func (*UnregisterLogStream) XXX_Size 

func (m *UnregisterLogStream) XXX_Size() int

func (*UnregisterLogStream) XXX_Unmarshal 

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

type UnregisterStorageNode 

type UnregisterStorageNode struct {
	StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 160-byte string literal not displayed */
}

func (*UnregisterStorageNode) Descriptor 

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

func (*UnregisterStorageNode) GetStorageNodeID 

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

func (*UnregisterStorageNode) Marshal 

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

func (*UnregisterStorageNode) MarshalTo 

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

func (*UnregisterStorageNode) MarshalToSizedBuffer 

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

func (*UnregisterStorageNode) ProtoMessage 

func (*UnregisterStorageNode) ProtoMessage()

func (*UnregisterStorageNode) ProtoSize 

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

func (*UnregisterStorageNode) Reset 

func (m *UnregisterStorageNode) Reset()

func (*UnregisterStorageNode) String 

func (m *UnregisterStorageNode) String() string

func (*UnregisterStorageNode) Unmarshal 

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

func (*UnregisterStorageNode) XXX_DiscardUnknown 

func (m *UnregisterStorageNode) XXX_DiscardUnknown()

func (*UnregisterStorageNode) XXX_Marshal 

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

func (*UnregisterStorageNode) XXX_Merge 

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

func (*UnregisterStorageNode) XXX_Size 

func (m *UnregisterStorageNode) XXX_Size() int

func (*UnregisterStorageNode) XXX_Unmarshal 

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

type UnregisterTopic 

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

func (*UnregisterTopic) Descriptor 

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

func (*UnregisterTopic) GetTopicID 

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

func (*UnregisterTopic) Marshal 

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

func (*UnregisterTopic) MarshalTo 

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

func (*UnregisterTopic) MarshalToSizedBuffer 

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

func (*UnregisterTopic) ProtoMessage 

func (*UnregisterTopic) ProtoMessage()

func (*UnregisterTopic) ProtoSize 

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

func (*UnregisterTopic) Reset 

func (m *UnregisterTopic) Reset()

func (*UnregisterTopic) String 

func (m *UnregisterTopic) String() string

func (*UnregisterTopic) Unmarshal 

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

func (*UnregisterTopic) XXX_DiscardUnknown 

func (m *UnregisterTopic) XXX_DiscardUnknown()

func (*UnregisterTopic) XXX_Marshal 

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

func (*UnregisterTopic) XXX_Merge 

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

func (*UnregisterTopic) XXX_Size 

func (m *UnregisterTopic) XXX_Size() int

func (*UnregisterTopic) XXX_Unmarshal 

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

type Unseal 

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

func (*Unseal) Descriptor 

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

func (*Unseal) GetLogStreamID 

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

func (*Unseal) Marshal 

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

func (*Unseal) MarshalTo 

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

func (*Unseal) MarshalToSizedBuffer 

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

func (*Unseal) ProtoMessage 

func (*Unseal) ProtoMessage()

func (*Unseal) ProtoSize 

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

func (*Unseal) Reset 

func (m *Unseal) Reset()

func (*Unseal) String 

func (m *Unseal) String() string

func (*Unseal) Unmarshal 

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

func (*Unseal) XXX_DiscardUnknown 

func (m *Unseal) XXX_DiscardUnknown()

func (*Unseal) XXX_Marshal 

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

func (*Unseal) XXX_Merge 

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

func (*Unseal) XXX_Size 

func (m *Unseal) XXX_Size() int

func (*Unseal) XXX_Unmarshal 

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

type UnsealRequest 

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

func (*UnsealRequest) Descriptor 

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

func (*UnsealRequest) GetClusterID 

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

func (*UnsealRequest) GetLogStreamID 

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

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

type UnsealResponse 

type UnsealResponse struct {
	Status varlogpb.LogStreamStatus `protobuf:"varint,1,opt,name=status,proto3,enum=varlog.varlogpb.LogStreamStatus" json:"status,omitempty"`
}

func (*UnsealResponse) Descriptor 

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

func (*UnsealResponse) GetStatus 

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

func (*UnsealResponse) Marshal 

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

func (*UnsealResponse) MarshalTo 

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

func (*UnsealResponse) MarshalToSizedBuffer 

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

func (*UnsealResponse) ProtoMessage 

func (*UnsealResponse) ProtoMessage()

func (*UnsealResponse) ProtoSize 

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

func (*UnsealResponse) Reset 

func (m *UnsealResponse) Reset()

func (*UnsealResponse) String 

func (m *UnsealResponse) String() string

func (*UnsealResponse) Unmarshal 

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

func (*UnsealResponse) XXX_DiscardUnknown 

func (m *UnsealResponse) XXX_DiscardUnknown()

func (*UnsealResponse) XXX_Marshal 

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

func (*UnsealResponse) XXX_Merge 

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

func (*UnsealResponse) XXX_Size 

func (m *UnsealResponse) XXX_Size() int

func (*UnsealResponse) XXX_Unmarshal 

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

type UpdateLogStream 

type UpdateLogStream struct {
	LogStream *varlogpb.LogStreamDescriptor `protobuf:"bytes,1,opt,name=log_stream,json=logStream,proto3" json:"log_stream,omitempty"`
}

func (*UpdateLogStream) Descriptor 

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

func (*UpdateLogStream) GetLogStream 

func (m *UpdateLogStream) GetLogStream() *varlogpb.LogStreamDescriptor

func (*UpdateLogStream) Marshal 

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

func (*UpdateLogStream) MarshalTo 

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

func (*UpdateLogStream) MarshalToSizedBuffer 

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

func (*UpdateLogStream) ProtoMessage 

func (*UpdateLogStream) ProtoMessage()

func (*UpdateLogStream) ProtoSize 

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

func (*UpdateLogStream) Reset 

func (m *UpdateLogStream) Reset()

func (*UpdateLogStream) String 

func (m *UpdateLogStream) String() string

func (*UpdateLogStream) Unmarshal 

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

func (*UpdateLogStream) XXX_DiscardUnknown 

func (m *UpdateLogStream) XXX_DiscardUnknown()

func (*UpdateLogStream) XXX_Marshal 

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

func (*UpdateLogStream) XXX_Merge 

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

func (*UpdateLogStream) XXX_Size 

func (m *UpdateLogStream) XXX_Size() int

func (*UpdateLogStream) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.