vmspb

Documentation

Index

• Variables
• func RegisterClusterManagerServer(s *grpc.Server, srv ClusterManagerServer)
• type AddLogStreamRequest
  • func (*AddLogStreamRequest) Descriptor() ([]byte, []int)
  • func (m *AddLogStreamRequest) GetReplicas() []*varlogpb.ReplicaDescriptor
  • func (m *AddLogStreamRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID
  • func (m *AddLogStreamRequest) Marshal() (dAtA []byte, err error)
  • func (m *AddLogStreamRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *AddLogStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AddLogStreamRequest) ProtoMessage()
  • func (m *AddLogStreamRequest) ProtoSize() (n int)
  • func (m *AddLogStreamRequest) Reset()
  • func (m *AddLogStreamRequest) String() string
  • func (m *AddLogStreamRequest) Unmarshal(dAtA []byte) error
  • func (m *AddLogStreamRequest) XXX_DiscardUnknown()
  • func (m *AddLogStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AddLogStreamRequest) XXX_Merge(src proto.Message)
  • func (m *AddLogStreamRequest) XXX_Size() int
  • func (m *AddLogStreamRequest) XXX_Unmarshal(b []byte) error
• type AddLogStreamResponse
  • func (*AddLogStreamResponse) Descriptor() ([]byte, []int)
  • func (m *AddLogStreamResponse) GetLogStream() *varlogpb.LogStreamDescriptor
  • func (m *AddLogStreamResponse) Marshal() (dAtA []byte, err error)
  • func (m *AddLogStreamResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *AddLogStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AddLogStreamResponse) ProtoMessage()
  • func (m *AddLogStreamResponse) ProtoSize() (n int)
  • func (m *AddLogStreamResponse) Reset()
  • func (m *AddLogStreamResponse) String() string
  • func (m *AddLogStreamResponse) Unmarshal(dAtA []byte) error
  • func (m *AddLogStreamResponse) XXX_DiscardUnknown()
  • func (m *AddLogStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AddLogStreamResponse) XXX_Merge(src proto.Message)
  • func (m *AddLogStreamResponse) XXX_Size() int
  • func (m *AddLogStreamResponse) XXX_Unmarshal(b []byte) error
• type AddMRPeerRequest
  • func (*AddMRPeerRequest) Descriptor() ([]byte, []int)
  • func (m *AddMRPeerRequest) GetRPCAddr() string
  • func (m *AddMRPeerRequest) GetRaftURL() string
  • func (m *AddMRPeerRequest) Marshal() (dAtA []byte, err error)
  • func (m *AddMRPeerRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *AddMRPeerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AddMRPeerRequest) ProtoMessage()
  • func (m *AddMRPeerRequest) ProtoSize() (n int)
  • func (m *AddMRPeerRequest) Reset()
  • func (m *AddMRPeerRequest) String() string
  • func (m *AddMRPeerRequest) Unmarshal(dAtA []byte) error
  • func (m *AddMRPeerRequest) XXX_DiscardUnknown()
  • func (m *AddMRPeerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AddMRPeerRequest) XXX_Merge(src proto.Message)
  • func (m *AddMRPeerRequest) XXX_Size() int
  • func (m *AddMRPeerRequest) XXX_Unmarshal(b []byte) error
• type AddMRPeerResponse
  • func (*AddMRPeerResponse) Descriptor() ([]byte, []int)
  • func (m *AddMRPeerResponse) GetNodeID() github_com_kakao_varlog_pkg_types.NodeID
  • func (m *AddMRPeerResponse) Marshal() (dAtA []byte, err error)
  • func (m *AddMRPeerResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *AddMRPeerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AddMRPeerResponse) ProtoMessage()
  • func (m *AddMRPeerResponse) ProtoSize() (n int)
  • func (m *AddMRPeerResponse) Reset()
  • func (m *AddMRPeerResponse) String() string
  • func (m *AddMRPeerResponse) Unmarshal(dAtA []byte) error
  • func (m *AddMRPeerResponse) XXX_DiscardUnknown()
  • func (m *AddMRPeerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AddMRPeerResponse) XXX_Merge(src proto.Message)
  • func (m *AddMRPeerResponse) XXX_Size() int
  • func (m *AddMRPeerResponse) XXX_Unmarshal(b []byte) error
• type AddMetadataRepositoryNodeRequest
  • func (*AddMetadataRepositoryNodeRequest) Descriptor() ([]byte, []int)
  • func (m *AddMetadataRepositoryNodeRequest) GetRPCAddr() string
  • func (m *AddMetadataRepositoryNodeRequest) GetRaftURL() string
  • func (m *AddMetadataRepositoryNodeRequest) Marshal() (dAtA []byte, err error)
  • func (m *AddMetadataRepositoryNodeRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *AddMetadataRepositoryNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AddMetadataRepositoryNodeRequest) ProtoMessage()
  • func (m *AddMetadataRepositoryNodeRequest) ProtoSize() (n int)
  • func (m *AddMetadataRepositoryNodeRequest) Reset()
  • func (m *AddMetadataRepositoryNodeRequest) String() string
  • func (m *AddMetadataRepositoryNodeRequest) Unmarshal(dAtA []byte) error
  • func (m *AddMetadataRepositoryNodeRequest) XXX_DiscardUnknown()
  • func (m *AddMetadataRepositoryNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AddMetadataRepositoryNodeRequest) XXX_Merge(src proto.Message)
  • func (m *AddMetadataRepositoryNodeRequest) XXX_Size() int
  • func (m *AddMetadataRepositoryNodeRequest) XXX_Unmarshal(b []byte) error
• type AddMetadataRepositoryNodeResponse
  • func (*AddMetadataRepositoryNodeResponse) Descriptor() ([]byte, []int)
  • func (m *AddMetadataRepositoryNodeResponse) GetNode() *varlogpb.MetadataRepositoryNode
  • func (m *AddMetadataRepositoryNodeResponse) Marshal() (dAtA []byte, err error)
  • func (m *AddMetadataRepositoryNodeResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *AddMetadataRepositoryNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AddMetadataRepositoryNodeResponse) ProtoMessage()
  • func (m *AddMetadataRepositoryNodeResponse) ProtoSize() (n int)
  • func (m *AddMetadataRepositoryNodeResponse) Reset()
  • func (m *AddMetadataRepositoryNodeResponse) String() string
  • func (m *AddMetadataRepositoryNodeResponse) Unmarshal(dAtA []byte) error
  • func (m *AddMetadataRepositoryNodeResponse) XXX_DiscardUnknown()
  • func (m *AddMetadataRepositoryNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AddMetadataRepositoryNodeResponse) XXX_Merge(src proto.Message)
  • func (m *AddMetadataRepositoryNodeResponse) XXX_Size() int
  • func (m *AddMetadataRepositoryNodeResponse) XXX_Unmarshal(b []byte) error
• type AddStorageNodeRequest
  • func (*AddStorageNodeRequest) Descriptor() ([]byte, []int)
  • func (m *AddStorageNodeRequest) GetStorageNode() varlogpb.StorageNode
  • func (m *AddStorageNodeRequest) Marshal() (dAtA []byte, err error)
  • func (m *AddStorageNodeRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *AddStorageNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AddStorageNodeRequest) ProtoMessage()
  • func (m *AddStorageNodeRequest) ProtoSize() (n int)
  • func (m *AddStorageNodeRequest) Reset()
  • func (m *AddStorageNodeRequest) String() string
  • func (m *AddStorageNodeRequest) Unmarshal(dAtA []byte) error
  • func (m *AddStorageNodeRequest) XXX_DiscardUnknown()
  • func (m *AddStorageNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AddStorageNodeRequest) XXX_Merge(src proto.Message)
  • func (m *AddStorageNodeRequest) XXX_Size() int
  • func (m *AddStorageNodeRequest) XXX_Unmarshal(b []byte) error
• type AddStorageNodeResponse
  • func (*AddStorageNodeResponse) Descriptor() ([]byte, []int)
  • func (m *AddStorageNodeResponse) GetStorageNode() *StorageNodeMetadata
  • func (m *AddStorageNodeResponse) Marshal() (dAtA []byte, err error)
  • func (m *AddStorageNodeResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *AddStorageNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AddStorageNodeResponse) ProtoMessage()
  • func (m *AddStorageNodeResponse) ProtoSize() (n int)
  • func (m *AddStorageNodeResponse) Reset()
  • func (m *AddStorageNodeResponse) String() string
  • func (m *AddStorageNodeResponse) Unmarshal(dAtA []byte) error
  • func (m *AddStorageNodeResponse) XXX_DiscardUnknown()
  • func (m *AddStorageNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AddStorageNodeResponse) XXX_Merge(src proto.Message)
  • func (m *AddStorageNodeResponse) XXX_Size() int
  • func (m *AddStorageNodeResponse) XXX_Unmarshal(b []byte) error
• type AddTopicRequest
  • func (*AddTopicRequest) Descriptor() ([]byte, []int)
  • func (m *AddTopicRequest) Marshal() (dAtA []byte, err error)
  • func (m *AddTopicRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *AddTopicRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AddTopicRequest) ProtoMessage()
  • func (m *AddTopicRequest) ProtoSize() (n int)
  • func (m *AddTopicRequest) Reset()
  • func (m *AddTopicRequest) String() string
  • func (m *AddTopicRequest) Unmarshal(dAtA []byte) error
  • func (m *AddTopicRequest) XXX_DiscardUnknown()
  • func (m *AddTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AddTopicRequest) XXX_Merge(src proto.Message)
  • func (m *AddTopicRequest) XXX_Size() int
  • func (m *AddTopicRequest) XXX_Unmarshal(b []byte) error
• type AddTopicResponse
  • func (*AddTopicResponse) Descriptor() ([]byte, []int)
  • func (m *AddTopicResponse) GetTopic() *varlogpb.TopicDescriptor
  • func (m *AddTopicResponse) Marshal() (dAtA []byte, err error)
  • func (m *AddTopicResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *AddTopicResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AddTopicResponse) ProtoMessage()
  • func (m *AddTopicResponse) ProtoSize() (n int)
  • func (m *AddTopicResponse) Reset()
  • func (m *AddTopicResponse) String() string
  • func (m *AddTopicResponse) Unmarshal(dAtA []byte) error
  • func (m *AddTopicResponse) XXX_DiscardUnknown()
  • func (m *AddTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AddTopicResponse) XXX_Merge(src proto.Message)
  • func (m *AddTopicResponse) XXX_Size() int
  • func (m *AddTopicResponse) XXX_Unmarshal(b []byte) error
• type ClusterManagerClient
  • func NewClusterManagerClient(cc *grpc.ClientConn) ClusterManagerClient
• type ClusterManagerServer
• type DeleteMetadataRepositoryNodeRequest
  • func (*DeleteMetadataRepositoryNodeRequest) Descriptor() ([]byte, []int)
  • func (m *DeleteMetadataRepositoryNodeRequest) GetNodeID() github_com_kakao_varlog_pkg_types.NodeID
  • func (m *DeleteMetadataRepositoryNodeRequest) Marshal() (dAtA []byte, err error)
  • func (m *DeleteMetadataRepositoryNodeRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *DeleteMetadataRepositoryNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*DeleteMetadataRepositoryNodeRequest) ProtoMessage()
  • func (m *DeleteMetadataRepositoryNodeRequest) ProtoSize() (n int)
  • func (m *DeleteMetadataRepositoryNodeRequest) Reset()
  • func (m *DeleteMetadataRepositoryNodeRequest) String() string
  • func (m *DeleteMetadataRepositoryNodeRequest) Unmarshal(dAtA []byte) error
  • func (m *DeleteMetadataRepositoryNodeRequest) XXX_DiscardUnknown()
  • func (m *DeleteMetadataRepositoryNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DeleteMetadataRepositoryNodeRequest) XXX_Merge(src proto.Message)
  • func (m *DeleteMetadataRepositoryNodeRequest) XXX_Size() int
  • func (m *DeleteMetadataRepositoryNodeRequest) XXX_Unmarshal(b []byte) error
• type DeleteMetadataRepositoryNodeResponse
  • func (*DeleteMetadataRepositoryNodeResponse) Descriptor() ([]byte, []int)
  • func (m *DeleteMetadataRepositoryNodeResponse) Marshal() (dAtA []byte, err error)
  • func (m *DeleteMetadataRepositoryNodeResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *DeleteMetadataRepositoryNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*DeleteMetadataRepositoryNodeResponse) ProtoMessage()
  • func (m *DeleteMetadataRepositoryNodeResponse) ProtoSize() (n int)
  • func (m *DeleteMetadataRepositoryNodeResponse) Reset()
  • func (m *DeleteMetadataRepositoryNodeResponse) String() string
  • func (m *DeleteMetadataRepositoryNodeResponse) Unmarshal(dAtA []byte) error
  • func (m *DeleteMetadataRepositoryNodeResponse) XXX_DiscardUnknown()
  • func (m *DeleteMetadataRepositoryNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DeleteMetadataRepositoryNodeResponse) XXX_Merge(src proto.Message)
  • func (m *DeleteMetadataRepositoryNodeResponse) XXX_Size() int
  • func (m *DeleteMetadataRepositoryNodeResponse) XXX_Unmarshal(b []byte) error
• type DescribeTopicRequest
  • func (*DescribeTopicRequest) Descriptor() ([]byte, []int)
  • func (m *DescribeTopicRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID
  • func (m *DescribeTopicRequest) Marshal() (dAtA []byte, err error)
  • func (m *DescribeTopicRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *DescribeTopicRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*DescribeTopicRequest) ProtoMessage()
  • func (m *DescribeTopicRequest) ProtoSize() (n int)
  • func (m *DescribeTopicRequest) Reset()
  • func (m *DescribeTopicRequest) String() string
  • func (m *DescribeTopicRequest) Unmarshal(dAtA []byte) error
  • func (m *DescribeTopicRequest) XXX_DiscardUnknown()
  • func (m *DescribeTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DescribeTopicRequest) XXX_Merge(src proto.Message)
  • func (m *DescribeTopicRequest) XXX_Size() int
  • func (m *DescribeTopicRequest) XXX_Unmarshal(b []byte) error
• type DescribeTopicResponse
  • func (*DescribeTopicResponse) Descriptor() ([]byte, []int)
  • func (m *DescribeTopicResponse) GetLogStreams() []varlogpb.LogStreamDescriptor
  • func (m *DescribeTopicResponse) GetTopic() varlogpb.TopicDescriptor
  • func (m *DescribeTopicResponse) Marshal() (dAtA []byte, err error)
  • func (m *DescribeTopicResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *DescribeTopicResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*DescribeTopicResponse) ProtoMessage()
  • func (m *DescribeTopicResponse) ProtoSize() (n int)
  • func (m *DescribeTopicResponse) Reset()
  • func (m *DescribeTopicResponse) String() string
  • func (m *DescribeTopicResponse) Unmarshal(dAtA []byte) error
  • func (m *DescribeTopicResponse) XXX_DiscardUnknown()
  • func (m *DescribeTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DescribeTopicResponse) XXX_Merge(src proto.Message)
  • func (m *DescribeTopicResponse) XXX_Size() int
  • func (m *DescribeTopicResponse) XXX_Unmarshal(b []byte) error
• type GetLogStreamRequest
  • func (*GetLogStreamRequest) Descriptor() ([]byte, []int)
  • func (m *GetLogStreamRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID
  • func (m *GetLogStreamRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID
  • func (m *GetLogStreamRequest) Marshal() (dAtA []byte, err error)
  • func (m *GetLogStreamRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetLogStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetLogStreamRequest) ProtoMessage()
  • func (m *GetLogStreamRequest) ProtoSize() (n int)
  • func (m *GetLogStreamRequest) Reset()
  • func (m *GetLogStreamRequest) String() string
  • func (m *GetLogStreamRequest) Unmarshal(dAtA []byte) error
  • func (m *GetLogStreamRequest) XXX_DiscardUnknown()
  • func (m *GetLogStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetLogStreamRequest) XXX_Merge(src proto.Message)
  • func (m *GetLogStreamRequest) XXX_Size() int
  • func (m *GetLogStreamRequest) XXX_Unmarshal(b []byte) error
• type GetLogStreamResponse
  • func (*GetLogStreamResponse) Descriptor() ([]byte, []int)
  • func (m *GetLogStreamResponse) GetLogStream() *varlogpb.LogStreamDescriptor
  • func (m *GetLogStreamResponse) Marshal() (dAtA []byte, err error)
  • func (m *GetLogStreamResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetLogStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetLogStreamResponse) ProtoMessage()
  • func (m *GetLogStreamResponse) ProtoSize() (n int)
  • func (m *GetLogStreamResponse) Reset()
  • func (m *GetLogStreamResponse) String() string
  • func (m *GetLogStreamResponse) Unmarshal(dAtA []byte) error
  • func (m *GetLogStreamResponse) XXX_DiscardUnknown()
  • func (m *GetLogStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetLogStreamResponse) XXX_Merge(src proto.Message)
  • func (m *GetLogStreamResponse) XXX_Size() int
  • func (m *GetLogStreamResponse) XXX_Unmarshal(b []byte) error
• type GetMRMembersResponse
  • func (*GetMRMembersResponse) Descriptor() ([]byte, []int)
  • func (m *GetMRMembersResponse) GetLeader() github_com_kakao_varlog_pkg_types.NodeID
  • func (m *GetMRMembersResponse) GetMembers() map[github_com_kakao_varlog_pkg_types.NodeID]string
  • func (m *GetMRMembersResponse) GetReplicationFactor() int32
  • func (m *GetMRMembersResponse) Marshal() (dAtA []byte, err error)
  • func (m *GetMRMembersResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetMRMembersResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetMRMembersResponse) ProtoMessage()
  • func (m *GetMRMembersResponse) ProtoSize() (n int)
  • func (m *GetMRMembersResponse) Reset()
  • func (m *GetMRMembersResponse) String() string
  • func (m *GetMRMembersResponse) Unmarshal(dAtA []byte) error
  • func (m *GetMRMembersResponse) XXX_DiscardUnknown()
  • func (m *GetMRMembersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetMRMembersResponse) XXX_Merge(src proto.Message)
  • func (m *GetMRMembersResponse) XXX_Size() int
  • func (m *GetMRMembersResponse) XXX_Unmarshal(b []byte) error
• type GetMetadataRepositoryNodeRequest
  • func (*GetMetadataRepositoryNodeRequest) Descriptor() ([]byte, []int)
  • func (m *GetMetadataRepositoryNodeRequest) GetNodeID() github_com_kakao_varlog_pkg_types.NodeID
  • func (m *GetMetadataRepositoryNodeRequest) Marshal() (dAtA []byte, err error)
  • func (m *GetMetadataRepositoryNodeRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetMetadataRepositoryNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetMetadataRepositoryNodeRequest) ProtoMessage()
  • func (m *GetMetadataRepositoryNodeRequest) ProtoSize() (n int)
  • func (m *GetMetadataRepositoryNodeRequest) Reset()
  • func (m *GetMetadataRepositoryNodeRequest) String() string
  • func (m *GetMetadataRepositoryNodeRequest) Unmarshal(dAtA []byte) error
  • func (m *GetMetadataRepositoryNodeRequest) XXX_DiscardUnknown()
  • func (m *GetMetadataRepositoryNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetMetadataRepositoryNodeRequest) XXX_Merge(src proto.Message)
  • func (m *GetMetadataRepositoryNodeRequest) XXX_Size() int
  • func (m *GetMetadataRepositoryNodeRequest) XXX_Unmarshal(b []byte) error
• type GetMetadataRepositoryNodeResponse
  • func (*GetMetadataRepositoryNodeResponse) Descriptor() ([]byte, []int)
  • func (m *GetMetadataRepositoryNodeResponse) GetNode() *varlogpb.MetadataRepositoryNode
  • func (m *GetMetadataRepositoryNodeResponse) Marshal() (dAtA []byte, err error)
  • func (m *GetMetadataRepositoryNodeResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetMetadataRepositoryNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetMetadataRepositoryNodeResponse) ProtoMessage()
  • func (m *GetMetadataRepositoryNodeResponse) ProtoSize() (n int)
  • func (m *GetMetadataRepositoryNodeResponse) Reset()
  • func (m *GetMetadataRepositoryNodeResponse) String() string
  • func (m *GetMetadataRepositoryNodeResponse) Unmarshal(dAtA []byte) error
  • func (m *GetMetadataRepositoryNodeResponse) XXX_DiscardUnknown()
  • func (m *GetMetadataRepositoryNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetMetadataRepositoryNodeResponse) XXX_Merge(src proto.Message)
  • func (m *GetMetadataRepositoryNodeResponse) XXX_Size() int
  • func (m *GetMetadataRepositoryNodeResponse) XXX_Unmarshal(b []byte) error
• type GetStorageNodeRequest
  • func (*GetStorageNodeRequest) Descriptor() ([]byte, []int)
  • func (m *GetStorageNodeRequest) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID
  • func (m *GetStorageNodeRequest) Marshal() (dAtA []byte, err error)
  • func (m *GetStorageNodeRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetStorageNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetStorageNodeRequest) ProtoMessage()
  • func (m *GetStorageNodeRequest) ProtoSize() (n int)
  • func (m *GetStorageNodeRequest) Reset()
  • func (m *GetStorageNodeRequest) String() string
  • func (m *GetStorageNodeRequest) Unmarshal(dAtA []byte) error
  • func (m *GetStorageNodeRequest) XXX_DiscardUnknown()
  • func (m *GetStorageNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetStorageNodeRequest) XXX_Merge(src proto.Message)
  • func (m *GetStorageNodeRequest) XXX_Size() int
  • func (m *GetStorageNodeRequest) XXX_Unmarshal(b []byte) error
• type GetStorageNodeResponse
  • func (*GetStorageNodeResponse) Descriptor() ([]byte, []int)
  • func (m *GetStorageNodeResponse) GetStorageNode() *StorageNodeMetadata
  • func (m *GetStorageNodeResponse) Marshal() (dAtA []byte, err error)
  • func (m *GetStorageNodeResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetStorageNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetStorageNodeResponse) ProtoMessage()
  • func (m *GetStorageNodeResponse) ProtoSize() (n int)
  • func (m *GetStorageNodeResponse) Reset()
  • func (m *GetStorageNodeResponse) String() string
  • func (m *GetStorageNodeResponse) Unmarshal(dAtA []byte) error
  • func (m *GetStorageNodeResponse) XXX_DiscardUnknown()
  • func (m *GetStorageNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetStorageNodeResponse) XXX_Merge(src proto.Message)
  • func (m *GetStorageNodeResponse) XXX_Size() int
  • func (m *GetStorageNodeResponse) XXX_Unmarshal(b []byte) error
• type GetTopicRequest
  • func (*GetTopicRequest) Descriptor() ([]byte, []int)
  • func (m *GetTopicRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID
  • func (m *GetTopicRequest) Marshal() (dAtA []byte, err error)
  • func (m *GetTopicRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetTopicRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetTopicRequest) ProtoMessage()
  • func (m *GetTopicRequest) ProtoSize() (n int)
  • func (m *GetTopicRequest) Reset()
  • func (m *GetTopicRequest) String() string
  • func (m *GetTopicRequest) Unmarshal(dAtA []byte) error
  • func (m *GetTopicRequest) XXX_DiscardUnknown()
  • func (m *GetTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetTopicRequest) XXX_Merge(src proto.Message)
  • func (m *GetTopicRequest) XXX_Size() int
  • func (m *GetTopicRequest) XXX_Unmarshal(b []byte) error
• type GetTopicResponse
  • func (*GetTopicResponse) Descriptor() ([]byte, []int)
  • func (m *GetTopicResponse) GetTopic() *varlogpb.TopicDescriptor
  • func (m *GetTopicResponse) Marshal() (dAtA []byte, err error)
  • func (m *GetTopicResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetTopicResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetTopicResponse) ProtoMessage()
  • func (m *GetTopicResponse) ProtoSize() (n int)
  • func (m *GetTopicResponse) Reset()
  • func (m *GetTopicResponse) String() string
  • func (m *GetTopicResponse) Unmarshal(dAtA []byte) error
  • func (m *GetTopicResponse) XXX_DiscardUnknown()
  • func (m *GetTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetTopicResponse) XXX_Merge(src proto.Message)
  • func (m *GetTopicResponse) XXX_Size() int
  • func (m *GetTopicResponse) XXX_Unmarshal(b []byte) error
• type ListLogStreamsRequest
  • func (*ListLogStreamsRequest) Descriptor() ([]byte, []int)
  • func (m *ListLogStreamsRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID
  • func (m *ListLogStreamsRequest) Marshal() (dAtA []byte, err error)
  • func (m *ListLogStreamsRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *ListLogStreamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ListLogStreamsRequest) ProtoMessage()
  • func (m *ListLogStreamsRequest) ProtoSize() (n int)
  • func (m *ListLogStreamsRequest) Reset()
  • func (m *ListLogStreamsRequest) String() string
  • func (m *ListLogStreamsRequest) Unmarshal(dAtA []byte) error
  • func (m *ListLogStreamsRequest) XXX_DiscardUnknown()
  • func (m *ListLogStreamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ListLogStreamsRequest) XXX_Merge(src proto.Message)
  • func (m *ListLogStreamsRequest) XXX_Size() int
  • func (m *ListLogStreamsRequest) XXX_Unmarshal(b []byte) error
• type ListLogStreamsResponse
  • func (*ListLogStreamsResponse) Descriptor() ([]byte, []int)
  • func (m *ListLogStreamsResponse) GetLogStreams() []varlogpb.LogStreamDescriptor
  • func (m *ListLogStreamsResponse) Marshal() (dAtA []byte, err error)
  • func (m *ListLogStreamsResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *ListLogStreamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ListLogStreamsResponse) ProtoMessage()
  • func (m *ListLogStreamsResponse) ProtoSize() (n int)
  • func (m *ListLogStreamsResponse) Reset()
  • func (m *ListLogStreamsResponse) String() string
  • func (m *ListLogStreamsResponse) Unmarshal(dAtA []byte) error
  • func (m *ListLogStreamsResponse) XXX_DiscardUnknown()
  • func (m *ListLogStreamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ListLogStreamsResponse) XXX_Merge(src proto.Message)
  • func (m *ListLogStreamsResponse) XXX_Size() int
  • func (m *ListLogStreamsResponse) XXX_Unmarshal(b []byte) error
• type ListMetadataRepositoryNodesRequest
  • func (*ListMetadataRepositoryNodesRequest) Descriptor() ([]byte, []int)
  • func (m *ListMetadataRepositoryNodesRequest) Marshal() (dAtA []byte, err error)
  • func (m *ListMetadataRepositoryNodesRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *ListMetadataRepositoryNodesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ListMetadataRepositoryNodesRequest) ProtoMessage()
  • func (m *ListMetadataRepositoryNodesRequest) ProtoSize() (n int)
  • func (m *ListMetadataRepositoryNodesRequest) Reset()
  • func (m *ListMetadataRepositoryNodesRequest) String() string
  • func (m *ListMetadataRepositoryNodesRequest) Unmarshal(dAtA []byte) error
  • func (m *ListMetadataRepositoryNodesRequest) XXX_DiscardUnknown()
  • func (m *ListMetadataRepositoryNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ListMetadataRepositoryNodesRequest) XXX_Merge(src proto.Message)
  • func (m *ListMetadataRepositoryNodesRequest) XXX_Size() int
  • func (m *ListMetadataRepositoryNodesRequest) XXX_Unmarshal(b []byte) error
• type ListMetadataRepositoryNodesResponse
  • func (*ListMetadataRepositoryNodesResponse) Descriptor() ([]byte, []int)
  • func (m *ListMetadataRepositoryNodesResponse) GetNodes() []varlogpb.MetadataRepositoryNode
  • func (m *ListMetadataRepositoryNodesResponse) Marshal() (dAtA []byte, err error)
  • func (m *ListMetadataRepositoryNodesResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *ListMetadataRepositoryNodesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ListMetadataRepositoryNodesResponse) ProtoMessage()
  • func (m *ListMetadataRepositoryNodesResponse) ProtoSize() (n int)
  • func (m *ListMetadataRepositoryNodesResponse) Reset()
  • func (m *ListMetadataRepositoryNodesResponse) String() string
  • func (m *ListMetadataRepositoryNodesResponse) Unmarshal(dAtA []byte) error
  • func (m *ListMetadataRepositoryNodesResponse) XXX_DiscardUnknown()
  • func (m *ListMetadataRepositoryNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ListMetadataRepositoryNodesResponse) XXX_Merge(src proto.Message)
  • func (m *ListMetadataRepositoryNodesResponse) XXX_Size() int
  • func (m *ListMetadataRepositoryNodesResponse) XXX_Unmarshal(b []byte) error
• type ListStorageNodesRequest
  • func (*ListStorageNodesRequest) Descriptor() ([]byte, []int)
  • func (m *ListStorageNodesRequest) Marshal() (dAtA []byte, err error)
  • func (m *ListStorageNodesRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *ListStorageNodesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ListStorageNodesRequest) ProtoMessage()
  • func (m *ListStorageNodesRequest) ProtoSize() (n int)
  • func (m *ListStorageNodesRequest) Reset()
  • func (m *ListStorageNodesRequest) String() string
  • func (m *ListStorageNodesRequest) Unmarshal(dAtA []byte) error
  • func (m *ListStorageNodesRequest) XXX_DiscardUnknown()
  • func (m *ListStorageNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ListStorageNodesRequest) XXX_Merge(src proto.Message)
  • func (m *ListStorageNodesRequest) XXX_Size() int
  • func (m *ListStorageNodesRequest) XXX_Unmarshal(b []byte) error
• type ListStorageNodesResponse
  • func (*ListStorageNodesResponse) Descriptor() ([]byte, []int)
  • func (m *ListStorageNodesResponse) GetStorageNodes() []StorageNodeMetadata
  • func (m *ListStorageNodesResponse) Marshal() (dAtA []byte, err error)
  • func (m *ListStorageNodesResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *ListStorageNodesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ListStorageNodesResponse) ProtoMessage()
  • func (m *ListStorageNodesResponse) ProtoSize() (n int)
  • func (m *ListStorageNodesResponse) Reset()
  • func (m *ListStorageNodesResponse) String() string
  • func (m *ListStorageNodesResponse) Unmarshal(dAtA []byte) error
  • func (m *ListStorageNodesResponse) XXX_DiscardUnknown()
  • func (m *ListStorageNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ListStorageNodesResponse) XXX_Merge(src proto.Message)
  • func (m *ListStorageNodesResponse) XXX_Size() int
  • func (m *ListStorageNodesResponse) XXX_Unmarshal(b []byte) error
• type ListTopicsRequest
  • func (*ListTopicsRequest) Descriptor() ([]byte, []int)
  • func (m *ListTopicsRequest) Marshal() (dAtA []byte, err error)
  • func (m *ListTopicsRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *ListTopicsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ListTopicsRequest) ProtoMessage()
  • func (m *ListTopicsRequest) ProtoSize() (n int)
  • func (m *ListTopicsRequest) Reset()
  • func (m *ListTopicsRequest) String() string
  • func (m *ListTopicsRequest) Unmarshal(dAtA []byte) error
  • func (m *ListTopicsRequest) XXX_DiscardUnknown()
  • func (m *ListTopicsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ListTopicsRequest) XXX_Merge(src proto.Message)
  • func (m *ListTopicsRequest) XXX_Size() int
  • func (m *ListTopicsRequest) XXX_Unmarshal(b []byte) error
• type ListTopicsResponse
  • func (*ListTopicsResponse) Descriptor() ([]byte, []int)
  • func (m *ListTopicsResponse) GetTopics() []varlogpb.TopicDescriptor
  • func (m *ListTopicsResponse) Marshal() (dAtA []byte, err error)
  • func (m *ListTopicsResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *ListTopicsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ListTopicsResponse) ProtoMessage()
  • func (m *ListTopicsResponse) ProtoSize() (n int)
  • func (m *ListTopicsResponse) Reset()
  • func (m *ListTopicsResponse) String() string
  • func (m *ListTopicsResponse) Unmarshal(dAtA []byte) error
  • func (m *ListTopicsResponse) XXX_DiscardUnknown()
  • func (m *ListTopicsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ListTopicsResponse) XXX_Merge(src proto.Message)
  • func (m *ListTopicsResponse) XXX_Size() int
  • func (m *ListTopicsResponse) XXX_Unmarshal(b []byte) error
• type RemoveLogStreamReplicaRequest
  • func (*RemoveLogStreamReplicaRequest) Descriptor() ([]byte, []int)
  • func (m *RemoveLogStreamReplicaRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID
  • func (m *RemoveLogStreamReplicaRequest) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID
  • func (m *RemoveLogStreamReplicaRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID
  • func (m *RemoveLogStreamReplicaRequest) Marshal() (dAtA []byte, err error)
  • func (m *RemoveLogStreamReplicaRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RemoveLogStreamReplicaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RemoveLogStreamReplicaRequest) ProtoMessage()
  • func (m *RemoveLogStreamReplicaRequest) ProtoSize() (n int)
  • func (m *RemoveLogStreamReplicaRequest) Reset()
  • func (m *RemoveLogStreamReplicaRequest) String() string
  • func (m *RemoveLogStreamReplicaRequest) Unmarshal(dAtA []byte) error
  • func (m *RemoveLogStreamReplicaRequest) XXX_DiscardUnknown()
  • func (m *RemoveLogStreamReplicaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RemoveLogStreamReplicaRequest) XXX_Merge(src proto.Message)
  • func (m *RemoveLogStreamReplicaRequest) XXX_Size() int
  • func (m *RemoveLogStreamReplicaRequest) XXX_Unmarshal(b []byte) error
• type RemoveLogStreamReplicaResponse
  • func (*RemoveLogStreamReplicaResponse) Descriptor() ([]byte, []int)
  • func (m *RemoveLogStreamReplicaResponse) Marshal() (dAtA []byte, err error)
  • func (m *RemoveLogStreamReplicaResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RemoveLogStreamReplicaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RemoveLogStreamReplicaResponse) ProtoMessage()
  • func (m *RemoveLogStreamReplicaResponse) ProtoSize() (n int)
  • func (m *RemoveLogStreamReplicaResponse) Reset()
  • func (m *RemoveLogStreamReplicaResponse) String() string
  • func (m *RemoveLogStreamReplicaResponse) Unmarshal(dAtA []byte) error
  • func (m *RemoveLogStreamReplicaResponse) XXX_DiscardUnknown()
  • func (m *RemoveLogStreamReplicaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RemoveLogStreamReplicaResponse) XXX_Merge(src proto.Message)
  • func (m *RemoveLogStreamReplicaResponse) XXX_Size() int
  • func (m *RemoveLogStreamReplicaResponse) XXX_Unmarshal(b []byte) error
• type RemoveMRPeerRequest
  • func (*RemoveMRPeerRequest) Descriptor() ([]byte, []int)
  • func (m *RemoveMRPeerRequest) GetRaftURL() string
  • func (m *RemoveMRPeerRequest) Marshal() (dAtA []byte, err error)
  • func (m *RemoveMRPeerRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RemoveMRPeerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RemoveMRPeerRequest) ProtoMessage()
  • func (m *RemoveMRPeerRequest) ProtoSize() (n int)
  • func (m *RemoveMRPeerRequest) Reset()
  • func (m *RemoveMRPeerRequest) String() string
  • func (m *RemoveMRPeerRequest) Unmarshal(dAtA []byte) error
  • func (m *RemoveMRPeerRequest) XXX_DiscardUnknown()
  • func (m *RemoveMRPeerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RemoveMRPeerRequest) XXX_Merge(src proto.Message)
  • func (m *RemoveMRPeerRequest) XXX_Size() int
  • func (m *RemoveMRPeerRequest) XXX_Unmarshal(b []byte) error
• type RemoveMRPeerResponse
  • func (*RemoveMRPeerResponse) Descriptor() ([]byte, []int)
  • func (m *RemoveMRPeerResponse) Marshal() (dAtA []byte, err error)
  • func (m *RemoveMRPeerResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RemoveMRPeerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RemoveMRPeerResponse) ProtoMessage()
  • func (m *RemoveMRPeerResponse) ProtoSize() (n int)
  • func (m *RemoveMRPeerResponse) Reset()
  • func (m *RemoveMRPeerResponse) String() string
  • func (m *RemoveMRPeerResponse) Unmarshal(dAtA []byte) error
  • func (m *RemoveMRPeerResponse) XXX_DiscardUnknown()
  • func (m *RemoveMRPeerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RemoveMRPeerResponse) XXX_Merge(src proto.Message)
  • func (m *RemoveMRPeerResponse) XXX_Size() int
  • func (m *RemoveMRPeerResponse) XXX_Unmarshal(b []byte) error
• type SealRequest
  • func (*SealRequest) Descriptor() ([]byte, []int)
  • func (m *SealRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID
  • func (m *SealRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID
  • func (m *SealRequest) Marshal() (dAtA []byte, err error)
  • func (m *SealRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *SealRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*SealRequest) ProtoMessage()
  • func (m *SealRequest) ProtoSize() (n int)
  • func (m *SealRequest) Reset()
  • func (m *SealRequest) String() string
  • func (m *SealRequest) Unmarshal(dAtA []byte) error
  • func (m *SealRequest) XXX_DiscardUnknown()
  • func (m *SealRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SealRequest) XXX_Merge(src proto.Message)
  • func (m *SealRequest) XXX_Size() int
  • func (m *SealRequest) XXX_Unmarshal(b []byte) error
• type SealResponse
  • func (*SealResponse) Descriptor() ([]byte, []int)
  • func (m *SealResponse) GetLogStreams() []snpb.LogStreamReplicaMetadataDescriptor
  • func (m *SealResponse) GetSealedGLSN() github_com_kakao_varlog_pkg_types.GLSN
  • func (m *SealResponse) Marshal() (dAtA []byte, err error)
  • func (m *SealResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *SealResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*SealResponse) ProtoMessage()
  • func (m *SealResponse) ProtoSize() (n int)
  • func (m *SealResponse) Reset()
  • func (m *SealResponse) String() string
  • func (m *SealResponse) Unmarshal(dAtA []byte) error
  • func (m *SealResponse) XXX_DiscardUnknown()
  • func (m *SealResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SealResponse) XXX_Merge(src proto.Message)
  • func (m *SealResponse) XXX_Size() int
  • func (m *SealResponse) XXX_Unmarshal(b []byte) error
• type StorageNodeMetadata
  • func (*StorageNodeMetadata) Descriptor() ([]byte, []int)
  • func (this *StorageNodeMetadata) Equal(that interface{}) bool
  • func (m *StorageNodeMetadata) GetCreateTime() time.Time
  • func (m *StorageNodeMetadata) GetLastHeartbeatTime() time.Time
  • func (m *StorageNodeMetadata) Marshal() (dAtA []byte, err error)
  • func (m *StorageNodeMetadata) MarshalTo(dAtA []byte) (int, error)
  • func (m *StorageNodeMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*StorageNodeMetadata) ProtoMessage()
  • func (m *StorageNodeMetadata) ProtoSize() (n int)
  • func (m *StorageNodeMetadata) Reset()
  • func (m *StorageNodeMetadata) String() string
  • func (m *StorageNodeMetadata) Unmarshal(dAtA []byte) error
  • func (m *StorageNodeMetadata) XXX_DiscardUnknown()
  • func (m *StorageNodeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StorageNodeMetadata) XXX_Merge(src proto.Message)
  • func (m *StorageNodeMetadata) XXX_Size() int
  • func (m *StorageNodeMetadata) XXX_Unmarshal(b []byte) error
• type SyncRequest
  • func (*SyncRequest) Descriptor() ([]byte, []int)
  • func (m *SyncRequest) GetDstStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID
  • func (m *SyncRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID
  • func (m *SyncRequest) GetSrcStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID
  • func (m *SyncRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID
  • func (m *SyncRequest) Marshal() (dAtA []byte, err error)
  • func (m *SyncRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *SyncRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*SyncRequest) ProtoMessage()
  • func (m *SyncRequest) ProtoSize() (n int)
  • func (m *SyncRequest) Reset()
  • func (m *SyncRequest) String() string
  • func (m *SyncRequest) Unmarshal(dAtA []byte) error
  • func (m *SyncRequest) XXX_DiscardUnknown()
  • func (m *SyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SyncRequest) XXX_Merge(src proto.Message)
  • func (m *SyncRequest) XXX_Size() int
  • func (m *SyncRequest) XXX_Unmarshal(b []byte) error
• type SyncResponse
  • func (*SyncResponse) Descriptor() ([]byte, []int)
  • func (m *SyncResponse) GetStatus() *snpb.SyncStatus
  • func (m *SyncResponse) Marshal() (dAtA []byte, err error)
  • func (m *SyncResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *SyncResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*SyncResponse) ProtoMessage()
  • func (m *SyncResponse) ProtoSize() (n int)
  • func (m *SyncResponse) Reset()
  • func (m *SyncResponse) String() string
  • func (m *SyncResponse) Unmarshal(dAtA []byte) error
  • func (m *SyncResponse) XXX_DiscardUnknown()
  • func (m *SyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SyncResponse) XXX_Merge(src proto.Message)
  • func (m *SyncResponse) XXX_Size() int
  • func (m *SyncResponse) XXX_Unmarshal(b []byte) error
• type TrimRequest
  • func (*TrimRequest) Descriptor() ([]byte, []int)
  • func (m *TrimRequest) GetLastGLSN() github_com_kakao_varlog_pkg_types.GLSN
  • func (m *TrimRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID
  • func (m *TrimRequest) Marshal() (dAtA []byte, err error)
  • func (m *TrimRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *TrimRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*TrimRequest) ProtoMessage()
  • func (m *TrimRequest) ProtoSize() (n int)
  • func (m *TrimRequest) Reset()
  • func (m *TrimRequest) String() string
  • func (m *TrimRequest) Unmarshal(dAtA []byte) error
  • func (m *TrimRequest) XXX_DiscardUnknown()
  • func (m *TrimRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *TrimRequest) XXX_Merge(src proto.Message)
  • func (m *TrimRequest) XXX_Size() int
  • func (m *TrimRequest) XXX_Unmarshal(b []byte) error
• type TrimResponse
  • func (*TrimResponse) Descriptor() ([]byte, []int)
  • func (m *TrimResponse) GetResults() []TrimResult
  • func (m *TrimResponse) Marshal() (dAtA []byte, err error)
  • func (m *TrimResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *TrimResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*TrimResponse) ProtoMessage()
  • func (m *TrimResponse) ProtoSize() (n int)
  • func (m *TrimResponse) Reset()
  • func (m *TrimResponse) String() string
  • func (m *TrimResponse) Unmarshal(dAtA []byte) error
  • func (m *TrimResponse) XXX_DiscardUnknown()
  • func (m *TrimResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *TrimResponse) XXX_Merge(src proto.Message)
  • func (m *TrimResponse) XXX_Size() int
  • func (m *TrimResponse) XXX_Unmarshal(b []byte) error
• type TrimResult
  • func (*TrimResult) Descriptor() ([]byte, []int)
  • func (m *TrimResult) GetError() string
  • func (m *TrimResult) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID
  • func (m *TrimResult) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID
  • func (m *TrimResult) Marshal() (dAtA []byte, err error)
  • func (m *TrimResult) MarshalTo(dAtA []byte) (int, error)
  • func (m *TrimResult) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*TrimResult) ProtoMessage()
  • func (m *TrimResult) ProtoSize() (n int)
  • func (m *TrimResult) Reset()
  • func (m *TrimResult) String() string
  • func (m *TrimResult) Unmarshal(dAtA []byte) error
  • func (m *TrimResult) XXX_DiscardUnknown()
  • func (m *TrimResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *TrimResult) XXX_Merge(src proto.Message)
  • func (m *TrimResult) XXX_Size() int
  • func (m *TrimResult) XXX_Unmarshal(b []byte) error
• type UnimplementedClusterManagerServer
  • func (*UnimplementedClusterManagerServer) AddLogStream(ctx context.Context, req *AddLogStreamRequest) (*AddLogStreamResponse, error)
  • func (*UnimplementedClusterManagerServer) AddMRPeer(ctx context.Context, req *AddMRPeerRequest) (*AddMRPeerResponse, error)
  • func (*UnimplementedClusterManagerServer) AddMetadataRepositoryNode(ctx context.Context, req *AddMetadataRepositoryNodeRequest) (*AddMetadataRepositoryNodeResponse, error)
  • func (*UnimplementedClusterManagerServer) AddStorageNode(ctx context.Context, req *AddStorageNodeRequest) (*AddStorageNodeResponse, error)
  • func (*UnimplementedClusterManagerServer) AddTopic(ctx context.Context, req *AddTopicRequest) (*AddTopicResponse, error)
  • func (*UnimplementedClusterManagerServer) DeleteMetadataRepositoryNode(ctx context.Context, req *DeleteMetadataRepositoryNodeRequest) (*DeleteMetadataRepositoryNodeResponse, error)
  • func (*UnimplementedClusterManagerServer) DescribeTopic(ctx context.Context, req *DescribeTopicRequest) (*DescribeTopicResponse, error)
  • func (*UnimplementedClusterManagerServer) GetLogStream(ctx context.Context, req *GetLogStreamRequest) (*GetLogStreamResponse, error)
  • func (*UnimplementedClusterManagerServer) GetMRMembers(ctx context.Context, req *types.Empty) (*GetMRMembersResponse, error)
  • func (*UnimplementedClusterManagerServer) GetMetadataRepositoryNode(ctx context.Context, req *GetMetadataRepositoryNodeRequest) (*GetMetadataRepositoryNodeResponse, error)
  • func (*UnimplementedClusterManagerServer) GetStorageNode(ctx context.Context, req *GetStorageNodeRequest) (*GetStorageNodeResponse, error)
  • func (*UnimplementedClusterManagerServer) GetTopic(ctx context.Context, req *GetTopicRequest) (*GetTopicResponse, error)
  • func (*UnimplementedClusterManagerServer) ListLogStreams(ctx context.Context, req *ListLogStreamsRequest) (*ListLogStreamsResponse, error)
  • func (*UnimplementedClusterManagerServer) ListMetadataRepositoryNodes(ctx context.Context, req *ListMetadataRepositoryNodesRequest) (*ListMetadataRepositoryNodesResponse, error)
  • func (*UnimplementedClusterManagerServer) ListStorageNodes(ctx context.Context, req *ListStorageNodesRequest) (*ListStorageNodesResponse, error)
  • func (*UnimplementedClusterManagerServer) ListTopics(ctx context.Context, req *ListTopicsRequest) (*ListTopicsResponse, error)
  • func (*UnimplementedClusterManagerServer) RemoveLogStreamReplica(ctx context.Context, req *RemoveLogStreamReplicaRequest) (*RemoveLogStreamReplicaResponse, error)
  • func (*UnimplementedClusterManagerServer) RemoveMRPeer(ctx context.Context, req *RemoveMRPeerRequest) (*RemoveMRPeerResponse, error)
  • func (*UnimplementedClusterManagerServer) Seal(ctx context.Context, req *SealRequest) (*SealResponse, error)
  • func (*UnimplementedClusterManagerServer) Sync(ctx context.Context, req *SyncRequest) (*SyncResponse, error)
  • func (*UnimplementedClusterManagerServer) Trim(ctx context.Context, req *TrimRequest) (*TrimResponse, error)
  • func (*UnimplementedClusterManagerServer) UnregisterLogStream(ctx context.Context, req *UnregisterLogStreamRequest) (*UnregisterLogStreamResponse, error)
  • func (*UnimplementedClusterManagerServer) UnregisterStorageNode(ctx context.Context, req *UnregisterStorageNodeRequest) (*UnregisterStorageNodeResponse, error)
  • func (*UnimplementedClusterManagerServer) UnregisterTopic(ctx context.Context, req *UnregisterTopicRequest) (*UnregisterTopicResponse, error)
  • func (*UnimplementedClusterManagerServer) Unseal(ctx context.Context, req *UnsealRequest) (*UnsealResponse, error)
  • func (*UnimplementedClusterManagerServer) UpdateLogStream(ctx context.Context, req *UpdateLogStreamRequest) (*UpdateLogStreamResponse, error)
• type UnregisterLogStreamRequest
  • func (*UnregisterLogStreamRequest) Descriptor() ([]byte, []int)
  • func (m *UnregisterLogStreamRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID
  • func (m *UnregisterLogStreamRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID
  • func (m *UnregisterLogStreamRequest) Marshal() (dAtA []byte, err error)
  • func (m *UnregisterLogStreamRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *UnregisterLogStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UnregisterLogStreamRequest) ProtoMessage()
  • func (m *UnregisterLogStreamRequest) ProtoSize() (n int)
  • func (m *UnregisterLogStreamRequest) Reset()
  • func (m *UnregisterLogStreamRequest) String() string
  • func (m *UnregisterLogStreamRequest) Unmarshal(dAtA []byte) error
  • func (m *UnregisterLogStreamRequest) XXX_DiscardUnknown()
  • func (m *UnregisterLogStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UnregisterLogStreamRequest) XXX_Merge(src proto.Message)
  • func (m *UnregisterLogStreamRequest) XXX_Size() int
  • func (m *UnregisterLogStreamRequest) XXX_Unmarshal(b []byte) error
• type UnregisterLogStreamResponse
  • func (*UnregisterLogStreamResponse) Descriptor() ([]byte, []int)
  • func (m *UnregisterLogStreamResponse) Marshal() (dAtA []byte, err error)
  • func (m *UnregisterLogStreamResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *UnregisterLogStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UnregisterLogStreamResponse) ProtoMessage()
  • func (m *UnregisterLogStreamResponse) ProtoSize() (n int)
  • func (m *UnregisterLogStreamResponse) Reset()
  • func (m *UnregisterLogStreamResponse) String() string
  • func (m *UnregisterLogStreamResponse) Unmarshal(dAtA []byte) error
  • func (m *UnregisterLogStreamResponse) XXX_DiscardUnknown()
  • func (m *UnregisterLogStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UnregisterLogStreamResponse) XXX_Merge(src proto.Message)
  • func (m *UnregisterLogStreamResponse) XXX_Size() int
  • func (m *UnregisterLogStreamResponse) XXX_Unmarshal(b []byte) error
• type UnregisterStorageNodeRequest
  • func (*UnregisterStorageNodeRequest) Descriptor() ([]byte, []int)
  • func (m *UnregisterStorageNodeRequest) GetStorageNodeID() github_com_kakao_varlog_pkg_types.StorageNodeID
  • func (m *UnregisterStorageNodeRequest) Marshal() (dAtA []byte, err error)
  • func (m *UnregisterStorageNodeRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *UnregisterStorageNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UnregisterStorageNodeRequest) ProtoMessage()
  • func (m *UnregisterStorageNodeRequest) ProtoSize() (n int)
  • func (m *UnregisterStorageNodeRequest) Reset()
  • func (m *UnregisterStorageNodeRequest) String() string
  • func (m *UnregisterStorageNodeRequest) Unmarshal(dAtA []byte) error
  • func (m *UnregisterStorageNodeRequest) XXX_DiscardUnknown()
  • func (m *UnregisterStorageNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UnregisterStorageNodeRequest) XXX_Merge(src proto.Message)
  • func (m *UnregisterStorageNodeRequest) XXX_Size() int
  • func (m *UnregisterStorageNodeRequest) XXX_Unmarshal(b []byte) error
• type UnregisterStorageNodeResponse
  • func (*UnregisterStorageNodeResponse) Descriptor() ([]byte, []int)
  • func (m *UnregisterStorageNodeResponse) Marshal() (dAtA []byte, err error)
  • func (m *UnregisterStorageNodeResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *UnregisterStorageNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UnregisterStorageNodeResponse) ProtoMessage()
  • func (m *UnregisterStorageNodeResponse) ProtoSize() (n int)
  • func (m *UnregisterStorageNodeResponse) Reset()
  • func (m *UnregisterStorageNodeResponse) String() string
  • func (m *UnregisterStorageNodeResponse) Unmarshal(dAtA []byte) error
  • func (m *UnregisterStorageNodeResponse) XXX_DiscardUnknown()
  • func (m *UnregisterStorageNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UnregisterStorageNodeResponse) XXX_Merge(src proto.Message)
  • func (m *UnregisterStorageNodeResponse) XXX_Size() int
  • func (m *UnregisterStorageNodeResponse) XXX_Unmarshal(b []byte) error
• type UnregisterTopicRequest
  • func (*UnregisterTopicRequest) Descriptor() ([]byte, []int)
  • func (m *UnregisterTopicRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID
  • func (m *UnregisterTopicRequest) Marshal() (dAtA []byte, err error)
  • func (m *UnregisterTopicRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *UnregisterTopicRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UnregisterTopicRequest) ProtoMessage()
  • func (m *UnregisterTopicRequest) ProtoSize() (n int)
  • func (m *UnregisterTopicRequest) Reset()
  • func (m *UnregisterTopicRequest) String() string
  • func (m *UnregisterTopicRequest) Unmarshal(dAtA []byte) error
  • func (m *UnregisterTopicRequest) XXX_DiscardUnknown()
  • func (m *UnregisterTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UnregisterTopicRequest) XXX_Merge(src proto.Message)
  • func (m *UnregisterTopicRequest) XXX_Size() int
  • func (m *UnregisterTopicRequest) XXX_Unmarshal(b []byte) error
• type UnregisterTopicResponse
  • func (*UnregisterTopicResponse) Descriptor() ([]byte, []int)
  • func (m *UnregisterTopicResponse) Marshal() (dAtA []byte, err error)
  • func (m *UnregisterTopicResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *UnregisterTopicResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UnregisterTopicResponse) ProtoMessage()
  • func (m *UnregisterTopicResponse) ProtoSize() (n int)
  • func (m *UnregisterTopicResponse) Reset()
  • func (m *UnregisterTopicResponse) String() string
  • func (m *UnregisterTopicResponse) Unmarshal(dAtA []byte) error
  • func (m *UnregisterTopicResponse) XXX_DiscardUnknown()
  • func (m *UnregisterTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UnregisterTopicResponse) XXX_Merge(src proto.Message)
  • func (m *UnregisterTopicResponse) XXX_Size() int
  • func (m *UnregisterTopicResponse) XXX_Unmarshal(b []byte) error
• type UnsealRequest
  • func (*UnsealRequest) Descriptor() ([]byte, []int)
  • func (m *UnsealRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID
  • func (m *UnsealRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID
  • func (m *UnsealRequest) Marshal() (dAtA []byte, err error)
  • func (m *UnsealRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *UnsealRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UnsealRequest) ProtoMessage()
  • func (m *UnsealRequest) ProtoSize() (n int)
  • func (m *UnsealRequest) Reset()
  • func (m *UnsealRequest) String() string
  • func (m *UnsealRequest) Unmarshal(dAtA []byte) error
  • func (m *UnsealRequest) XXX_DiscardUnknown()
  • func (m *UnsealRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UnsealRequest) XXX_Merge(src proto.Message)
  • func (m *UnsealRequest) XXX_Size() int
  • func (m *UnsealRequest) XXX_Unmarshal(b []byte) error
• type UnsealResponse
  • func (*UnsealResponse) Descriptor() ([]byte, []int)
  • func (m *UnsealResponse) GetLogStream() *varlogpb.LogStreamDescriptor
  • func (m *UnsealResponse) Marshal() (dAtA []byte, err error)
  • func (m *UnsealResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *UnsealResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UnsealResponse) ProtoMessage()
  • func (m *UnsealResponse) ProtoSize() (n int)
  • func (m *UnsealResponse) Reset()
  • func (m *UnsealResponse) String() string
  • func (m *UnsealResponse) Unmarshal(dAtA []byte) error
  • func (m *UnsealResponse) XXX_DiscardUnknown()
  • func (m *UnsealResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UnsealResponse) XXX_Merge(src proto.Message)
  • func (m *UnsealResponse) XXX_Size() int
  • func (m *UnsealResponse) XXX_Unmarshal(b []byte) error
• type UpdateLogStreamRequest
  • func (*UpdateLogStreamRequest) Descriptor() ([]byte, []int)
  • func (m *UpdateLogStreamRequest) GetLogStreamID() github_com_kakao_varlog_pkg_types.LogStreamID
  • func (m *UpdateLogStreamRequest) GetPoppedReplica() *varlogpb.ReplicaDescriptor
  • func (m *UpdateLogStreamRequest) GetPushedReplica() *varlogpb.ReplicaDescriptor
  • func (m *UpdateLogStreamRequest) GetTopicID() github_com_kakao_varlog_pkg_types.TopicID
  • func (m *UpdateLogStreamRequest) Marshal() (dAtA []byte, err error)
  • func (m *UpdateLogStreamRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *UpdateLogStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UpdateLogStreamRequest) ProtoMessage()
  • func (m *UpdateLogStreamRequest) ProtoSize() (n int)
  • func (m *UpdateLogStreamRequest) Reset()
  • func (m *UpdateLogStreamRequest) String() string
  • func (m *UpdateLogStreamRequest) Unmarshal(dAtA []byte) error
  • func (m *UpdateLogStreamRequest) XXX_DiscardUnknown()
  • func (m *UpdateLogStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UpdateLogStreamRequest) XXX_Merge(src proto.Message)
  • func (m *UpdateLogStreamRequest) XXX_Size() int
  • func (m *UpdateLogStreamRequest) XXX_Unmarshal(b []byte) error
• type UpdateLogStreamResponse
  • func (*UpdateLogStreamResponse) Descriptor() ([]byte, []int)
  • func (m *UpdateLogStreamResponse) GetLogStream() *varlogpb.LogStreamDescriptor
  • func (m *UpdateLogStreamResponse) Marshal() (dAtA []byte, err error)
  • func (m *UpdateLogStreamResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *UpdateLogStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UpdateLogStreamResponse) ProtoMessage()
  • func (m *UpdateLogStreamResponse) ProtoSize() (n int)
  • func (m *UpdateLogStreamResponse) Reset()
  • func (m *UpdateLogStreamResponse) String() string
  • func (m *UpdateLogStreamResponse) Unmarshal(dAtA []byte) error
  • func (m *UpdateLogStreamResponse) XXX_DiscardUnknown()
  • func (m *UpdateLogStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UpdateLogStreamResponse) XXX_Merge(src proto.Message)
  • func (m *UpdateLogStreamResponse) XXX_Size() int
  • func (m *UpdateLogStreamResponse) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthAdmin        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAdmin          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAdmin = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterClusterManagerServer

func RegisterClusterManagerServer(s *grpc.Server, srv ClusterManagerServer)

Types

type AddLogStreamRequest

type AddLogStreamRequest struct {
	TopicID github_com_kakao_varlog_pkg_types.TopicID `` /* 134-byte string literal not displayed */
	// TODO: nullable = false
	Replicas []*varlogpb.ReplicaDescriptor `protobuf:"bytes,2,rep,name=replicas,proto3" json:"replicas,omitempty"`
}

func (*AddLogStreamRequest) Descriptor

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

func (*AddLogStreamRequest) GetReplicas

func (m *AddLogStreamRequest) GetReplicas() []*varlogpb.ReplicaDescriptor

func (*AddLogStreamRequest) GetTopicID

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

func (*AddLogStreamRequest) Marshal

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

func (*AddLogStreamRequest) MarshalTo

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

func (*AddLogStreamRequest) MarshalToSizedBuffer

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

func (*AddLogStreamRequest) ProtoMessage

func (*AddLogStreamRequest) ProtoMessage()

func (*AddLogStreamRequest) ProtoSize

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

func (*AddLogStreamRequest) Reset

func (m *AddLogStreamRequest) Reset()

func (*AddLogStreamRequest) String

func (m *AddLogStreamRequest) String() string

func (*AddLogStreamRequest) Unmarshal

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

func (*AddLogStreamRequest) XXX_DiscardUnknown

func (m *AddLogStreamRequest) XXX_DiscardUnknown()

func (*AddLogStreamRequest) XXX_Marshal

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

func (*AddLogStreamRequest) XXX_Merge

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

func (*AddLogStreamRequest) XXX_Size

func (m *AddLogStreamRequest) XXX_Size() int

func (*AddLogStreamRequest) XXX_Unmarshal

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

type AddLogStreamResponse

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

func (*AddLogStreamResponse) Descriptor

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

func (*AddLogStreamResponse) GetLogStream

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

func (*AddLogStreamResponse) Marshal

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

func (*AddLogStreamResponse) MarshalTo

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

func (*AddLogStreamResponse) MarshalToSizedBuffer

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

func (*AddLogStreamResponse) ProtoMessage

func (*AddLogStreamResponse) ProtoMessage()

func (*AddLogStreamResponse) ProtoSize

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

func (*AddLogStreamResponse) Reset

func (m *AddLogStreamResponse) Reset()

func (*AddLogStreamResponse) String

func (m *AddLogStreamResponse) String() string

func (*AddLogStreamResponse) Unmarshal

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

func (*AddLogStreamResponse) XXX_DiscardUnknown

func (m *AddLogStreamResponse) XXX_DiscardUnknown()

func (*AddLogStreamResponse) XXX_Marshal

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

func (*AddLogStreamResponse) XXX_Merge

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

func (*AddLogStreamResponse) XXX_Size

func (m *AddLogStreamResponse) XXX_Size() int

func (*AddLogStreamResponse) XXX_Unmarshal

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

type AddMRPeerRequest

type AddMRPeerRequest struct {
	RaftURL string `protobuf:"bytes,1,opt,name=raft_url,json=raftUrl,proto3" json:"raft_url,omitempty"`
	RPCAddr string `protobuf:"bytes,2,opt,name=rpc_addr,json=rpcAddr,proto3" json:"rpc_addr,omitempty"`
}

func (*AddMRPeerRequest) Descriptor

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

func (*AddMRPeerRequest) GetRPCAddr

func (m *AddMRPeerRequest) GetRPCAddr() string

func (*AddMRPeerRequest) GetRaftURL

func (m *AddMRPeerRequest) GetRaftURL() string

func (*AddMRPeerRequest) Marshal

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

func (*AddMRPeerRequest) MarshalTo

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

func (*AddMRPeerRequest) MarshalToSizedBuffer

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

func (*AddMRPeerRequest) ProtoMessage

func (*AddMRPeerRequest) ProtoMessage()

func (*AddMRPeerRequest) ProtoSize

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

func (*AddMRPeerRequest) Reset

func (m *AddMRPeerRequest) Reset()

func (*AddMRPeerRequest) String

func (m *AddMRPeerRequest) String() string

func (*AddMRPeerRequest) Unmarshal

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

func (*AddMRPeerRequest) XXX_DiscardUnknown

func (m *AddMRPeerRequest) XXX_DiscardUnknown()

func (*AddMRPeerRequest) XXX_Marshal

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

func (*AddMRPeerRequest) XXX_Merge

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

func (*AddMRPeerRequest) XXX_Size

func (m *AddMRPeerRequest) XXX_Size() int

func (*AddMRPeerRequest) XXX_Unmarshal

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

type AddMRPeerResponse

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

func (*AddMRPeerResponse) Descriptor

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

func (*AddMRPeerResponse) GetNodeID

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

func (*AddMRPeerResponse) Marshal

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

func (*AddMRPeerResponse) MarshalTo

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

func (*AddMRPeerResponse) MarshalToSizedBuffer

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

func (*AddMRPeerResponse) ProtoMessage

func (*AddMRPeerResponse) ProtoMessage()

func (*AddMRPeerResponse) ProtoSize

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

func (*AddMRPeerResponse) Reset

func (m *AddMRPeerResponse) Reset()

func (*AddMRPeerResponse) String

func (m *AddMRPeerResponse) String() string

func (*AddMRPeerResponse) Unmarshal

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

func (*AddMRPeerResponse) XXX_DiscardUnknown

func (m *AddMRPeerResponse) XXX_DiscardUnknown()

func (*AddMRPeerResponse) XXX_Marshal

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

func (*AddMRPeerResponse) XXX_Merge

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

func (*AddMRPeerResponse) XXX_Size

func (m *AddMRPeerResponse) XXX_Size() int

func (*AddMRPeerResponse) XXX_Unmarshal

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

type AddMetadataRepositoryNodeRequest

type AddMetadataRepositoryNodeRequest struct {
	RaftURL string `protobuf:"bytes,1,opt,name=raft_url,json=raftUrl,proto3" json:"raft_url,omitempty"`
	RPCAddr string `protobuf:"bytes,2,opt,name=rpc_addr,json=rpcAddr,proto3" json:"rpc_addr,omitempty"`
}

func (*AddMetadataRepositoryNodeRequest) Descriptor

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

func (*AddMetadataRepositoryNodeRequest) GetRPCAddr

func (m *AddMetadataRepositoryNodeRequest) GetRPCAddr() string

func (*AddMetadataRepositoryNodeRequest) GetRaftURL

func (m *AddMetadataRepositoryNodeRequest) GetRaftURL() string

func (*AddMetadataRepositoryNodeRequest) Marshal

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

func (*AddMetadataRepositoryNodeRequest) MarshalTo

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

func (*AddMetadataRepositoryNodeRequest) MarshalToSizedBuffer

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

func (*AddMetadataRepositoryNodeRequest) ProtoMessage

func (*AddMetadataRepositoryNodeRequest) ProtoMessage()

func (*AddMetadataRepositoryNodeRequest) ProtoSize

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

func (*AddMetadataRepositoryNodeRequest) Reset

func (m *AddMetadataRepositoryNodeRequest) Reset()

func (*AddMetadataRepositoryNodeRequest) String

func (m *AddMetadataRepositoryNodeRequest) String() string

func (*AddMetadataRepositoryNodeRequest) Unmarshal

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

func (*AddMetadataRepositoryNodeRequest) XXX_DiscardUnknown

func (m *AddMetadataRepositoryNodeRequest) XXX_DiscardUnknown()

func (*AddMetadataRepositoryNodeRequest) XXX_Marshal

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

func (*AddMetadataRepositoryNodeRequest) XXX_Merge

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

func (*AddMetadataRepositoryNodeRequest) XXX_Size

func (m *AddMetadataRepositoryNodeRequest) XXX_Size() int

func (*AddMetadataRepositoryNodeRequest) XXX_Unmarshal

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

type AddMetadataRepositoryNodeResponse

type AddMetadataRepositoryNodeResponse struct {
	Node *varlogpb.MetadataRepositoryNode `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
}

func (*AddMetadataRepositoryNodeResponse) Descriptor

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

func (*AddMetadataRepositoryNodeResponse) GetNode

func (m *AddMetadataRepositoryNodeResponse) GetNode() *varlogpb.MetadataRepositoryNode

func (*AddMetadataRepositoryNodeResponse) Marshal

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

func (*AddMetadataRepositoryNodeResponse) MarshalTo

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

func (*AddMetadataRepositoryNodeResponse) MarshalToSizedBuffer

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

func (*AddMetadataRepositoryNodeResponse) ProtoMessage

func (*AddMetadataRepositoryNodeResponse) ProtoMessage()

func (*AddMetadataRepositoryNodeResponse) ProtoSize

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

func (*AddMetadataRepositoryNodeResponse) Reset

func (m *AddMetadataRepositoryNodeResponse) Reset()

func (*AddMetadataRepositoryNodeResponse) String

func (m *AddMetadataRepositoryNodeResponse) String() string

func (*AddMetadataRepositoryNodeResponse) Unmarshal

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

func (*AddMetadataRepositoryNodeResponse) XXX_DiscardUnknown

func (m *AddMetadataRepositoryNodeResponse) XXX_DiscardUnknown()

func (*AddMetadataRepositoryNodeResponse) XXX_Marshal

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

func (*AddMetadataRepositoryNodeResponse) XXX_Merge

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

func (*AddMetadataRepositoryNodeResponse) XXX_Size

func (m *AddMetadataRepositoryNodeResponse) XXX_Size() int

func (*AddMetadataRepositoryNodeResponse) XXX_Unmarshal

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

type AddStorageNodeRequest

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

func (*AddStorageNodeRequest) Descriptor

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

func (*AddStorageNodeRequest) GetStorageNode

func (m *AddStorageNodeRequest) GetStorageNode() varlogpb.StorageNode

func (*AddStorageNodeRequest) Marshal

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

func (*AddStorageNodeRequest) MarshalTo

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

func (*AddStorageNodeRequest) MarshalToSizedBuffer

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

func (*AddStorageNodeRequest) ProtoMessage

func (*AddStorageNodeRequest) ProtoMessage()

func (*AddStorageNodeRequest) ProtoSize

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

func (*AddStorageNodeRequest) Reset

func (m *AddStorageNodeRequest) Reset()

func (*AddStorageNodeRequest) String

func (m *AddStorageNodeRequest) String() string

func (*AddStorageNodeRequest) Unmarshal

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

func (*AddStorageNodeRequest) XXX_DiscardUnknown

func (m *AddStorageNodeRequest) XXX_DiscardUnknown()

func (*AddStorageNodeRequest) XXX_Marshal

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

func (*AddStorageNodeRequest) XXX_Merge

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

func (*AddStorageNodeRequest) XXX_Size

func (m *AddStorageNodeRequest) XXX_Size() int

func (*AddStorageNodeRequest) XXX_Unmarshal

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

type AddStorageNodeResponse

type AddStorageNodeResponse struct {
	StorageNode *StorageNodeMetadata `protobuf:"bytes,1,opt,name=storage_node,json=storageNode,proto3" json:"storageNode"`
}

func (*AddStorageNodeResponse) Descriptor

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

func (*AddStorageNodeResponse) GetStorageNode

func (m *AddStorageNodeResponse) GetStorageNode() *StorageNodeMetadata

func (*AddStorageNodeResponse) Marshal

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

func (*AddStorageNodeResponse) MarshalTo

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

func (*AddStorageNodeResponse) MarshalToSizedBuffer

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

func (*AddStorageNodeResponse) ProtoMessage

func (*AddStorageNodeResponse) ProtoMessage()

func (*AddStorageNodeResponse) ProtoSize

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

func (*AddStorageNodeResponse) Reset

func (m *AddStorageNodeResponse) Reset()

func (*AddStorageNodeResponse) String

func (m *AddStorageNodeResponse) String() string

func (*AddStorageNodeResponse) Unmarshal

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

func (*AddStorageNodeResponse) XXX_DiscardUnknown

func (m *AddStorageNodeResponse) XXX_DiscardUnknown()

func (*AddStorageNodeResponse) XXX_Marshal

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

func (*AddStorageNodeResponse) XXX_Merge

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

func (*AddStorageNodeResponse) XXX_Size

func (m *AddStorageNodeResponse) XXX_Size() int

func (*AddStorageNodeResponse) XXX_Unmarshal

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

type AddTopicRequest

type AddTopicRequest struct {
}

AddTopicRequest represents a request to add a topic to the cluster.

func (*AddTopicRequest) Descriptor

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

func (*AddTopicRequest) Marshal

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

func (*AddTopicRequest) MarshalTo

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

func (*AddTopicRequest) MarshalToSizedBuffer

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

func (*AddTopicRequest) ProtoMessage

func (*AddTopicRequest) ProtoMessage()

func (*AddTopicRequest) ProtoSize

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

func (*AddTopicRequest) Reset

func (m *AddTopicRequest) Reset()

func (*AddTopicRequest) String

func (m *AddTopicRequest) String() string

func (*AddTopicRequest) Unmarshal

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

func (*AddTopicRequest) XXX_DiscardUnknown

func (m *AddTopicRequest) XXX_DiscardUnknown()

func (*AddTopicRequest) XXX_Marshal

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

func (*AddTopicRequest) XXX_Merge

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

func (*AddTopicRequest) XXX_Size

func (m *AddTopicRequest) XXX_Size() int

func (*AddTopicRequest) XXX_Unmarshal

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

type AddTopicResponse

type AddTopicResponse struct {
	Topic *varlogpb.TopicDescriptor `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic"`
}

AddTopicResponse represents a response of AddTopicRequest.

func (*AddTopicResponse) Descriptor

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

func (*AddTopicResponse) GetTopic

func (m *AddTopicResponse) GetTopic() *varlogpb.TopicDescriptor

func (*AddTopicResponse) Marshal

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

func (*AddTopicResponse) MarshalTo

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

func (*AddTopicResponse) MarshalToSizedBuffer

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

func (*AddTopicResponse) ProtoMessage

func (*AddTopicResponse) ProtoMessage()

func (*AddTopicResponse) ProtoSize

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

func (*AddTopicResponse) Reset

func (m *AddTopicResponse) Reset()

func (*AddTopicResponse) String

func (m *AddTopicResponse) String() string

func (*AddTopicResponse) Unmarshal

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

func (*AddTopicResponse) XXX_DiscardUnknown

func (m *AddTopicResponse) XXX_DiscardUnknown()

func (*AddTopicResponse) XXX_Marshal

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

func (*AddTopicResponse) XXX_Merge

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

func (*AddTopicResponse) XXX_Size

func (m *AddTopicResponse) XXX_Size() int

func (*AddTopicResponse) XXX_Unmarshal

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

type ClusterManagerClient

type ClusterManagerClient interface {
	// GetStorageNode returns the metadata of storage node requested.
	// It returns NotFound if the storage node does not exist.
	GetStorageNode(ctx context.Context, in *GetStorageNodeRequest, opts ...grpc.CallOption) (*GetStorageNodeResponse, error)
	// ListStorageNodes returns a list of storage nodes in the cluster.
	ListStorageNodes(ctx context.Context, in *ListStorageNodesRequest, opts ...grpc.CallOption) (*ListStorageNodesResponse, error)
	// AddStorageNode adds a new storage node to the cluster.
	// It is idempotent, that is, adding an already added storage node is okay.
	AddStorageNode(ctx context.Context, in *AddStorageNodeRequest, opts ...grpc.CallOption) (*AddStorageNodeResponse, error)
	// UnregisterStorageNode unregisters the storage node specified by the
	// request.
	UnregisterStorageNode(ctx context.Context, in *UnregisterStorageNodeRequest, opts ...grpc.CallOption) (*UnregisterStorageNodeResponse, error)
	// GetTopic returns the topic specified by the request.
	GetTopic(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*GetTopicResponse, error)
	// DescribeTopic returns the topic specified by the request.
	// Deprecated: Use GetTopic.
	DescribeTopic(ctx context.Context, in *DescribeTopicRequest, opts ...grpc.CallOption) (*DescribeTopicResponse, error)
	// ListTopics returns a list of topics in the cluster.
	ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error)
	// AddTopic adds a new topic and returns its metadata.
	AddTopic(ctx context.Context, in *AddTopicRequest, opts ...grpc.CallOption) (*AddTopicResponse, error)
	UnregisterTopic(ctx context.Context, in *UnregisterTopicRequest, opts ...grpc.CallOption) (*UnregisterTopicResponse, error)
	GetLogStream(ctx context.Context, in *GetLogStreamRequest, opts ...grpc.CallOption) (*GetLogStreamResponse, error)
	ListLogStreams(ctx context.Context, in *ListLogStreamsRequest, opts ...grpc.CallOption) (*ListLogStreamsResponse, error)
	AddLogStream(ctx context.Context, in *AddLogStreamRequest, opts ...grpc.CallOption) (*AddLogStreamResponse, error)
	UpdateLogStream(ctx context.Context, in *UpdateLogStreamRequest, opts ...grpc.CallOption) (*UpdateLogStreamResponse, error)
	UnregisterLogStream(ctx context.Context, in *UnregisterLogStreamRequest, opts ...grpc.CallOption) (*UnregisterLogStreamResponse, error)
	RemoveLogStreamReplica(ctx context.Context, in *RemoveLogStreamReplicaRequest, opts ...grpc.CallOption) (*RemoveLogStreamReplicaResponse, error)
	Seal(ctx context.Context, in *SealRequest, opts ...grpc.CallOption) (*SealResponse, error)
	Unseal(ctx context.Context, in *UnsealRequest, opts ...grpc.CallOption) (*UnsealResponse, error)
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error)
	Trim(ctx context.Context, in *TrimRequest, opts ...grpc.CallOption) (*TrimResponse, error)
	GetMetadataRepositoryNode(ctx context.Context, in *GetMetadataRepositoryNodeRequest, opts ...grpc.CallOption) (*GetMetadataRepositoryNodeResponse, error)
	ListMetadataRepositoryNodes(ctx context.Context, in *ListMetadataRepositoryNodesRequest, opts ...grpc.CallOption) (*ListMetadataRepositoryNodesResponse, error)
	GetMRMembers(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*GetMRMembersResponse, error)
	AddMetadataRepositoryNode(ctx context.Context, in *AddMetadataRepositoryNodeRequest, opts ...grpc.CallOption) (*AddMetadataRepositoryNodeResponse, error)
	AddMRPeer(ctx context.Context, in *AddMRPeerRequest, opts ...grpc.CallOption) (*AddMRPeerResponse, error)
	DeleteMetadataRepositoryNode(ctx context.Context, in *DeleteMetadataRepositoryNodeRequest, opts ...grpc.CallOption) (*DeleteMetadataRepositoryNodeResponse, error)
	RemoveMRPeer(ctx context.Context, in *RemoveMRPeerRequest, opts ...grpc.CallOption) (*RemoveMRPeerResponse, error)
}

ClusterManagerClient is the client API for ClusterManager service.

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

func NewClusterManagerClient

func NewClusterManagerClient(cc *grpc.ClientConn) ClusterManagerClient

type ClusterManagerServer

type ClusterManagerServer interface {
	// GetStorageNode returns the metadata of storage node requested.
	// It returns NotFound if the storage node does not exist.
	GetStorageNode(context.Context, *GetStorageNodeRequest) (*GetStorageNodeResponse, error)
	// ListStorageNodes returns a list of storage nodes in the cluster.
	ListStorageNodes(context.Context, *ListStorageNodesRequest) (*ListStorageNodesResponse, error)
	// AddStorageNode adds a new storage node to the cluster.
	// It is idempotent, that is, adding an already added storage node is okay.
	AddStorageNode(context.Context, *AddStorageNodeRequest) (*AddStorageNodeResponse, error)
	// UnregisterStorageNode unregisters the storage node specified by the
	// request.
	UnregisterStorageNode(context.Context, *UnregisterStorageNodeRequest) (*UnregisterStorageNodeResponse, error)
	// GetTopic returns the topic specified by the request.
	GetTopic(context.Context, *GetTopicRequest) (*GetTopicResponse, error)
	// DescribeTopic returns the topic specified by the request.
	// Deprecated: Use GetTopic.
	DescribeTopic(context.Context, *DescribeTopicRequest) (*DescribeTopicResponse, error)
	// ListTopics returns a list of topics in the cluster.
	ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)
	// AddTopic adds a new topic and returns its metadata.
	AddTopic(context.Context, *AddTopicRequest) (*AddTopicResponse, error)
	UnregisterTopic(context.Context, *UnregisterTopicRequest) (*UnregisterTopicResponse, error)
	GetLogStream(context.Context, *GetLogStreamRequest) (*GetLogStreamResponse, error)
	ListLogStreams(context.Context, *ListLogStreamsRequest) (*ListLogStreamsResponse, error)
	AddLogStream(context.Context, *AddLogStreamRequest) (*AddLogStreamResponse, error)
	UpdateLogStream(context.Context, *UpdateLogStreamRequest) (*UpdateLogStreamResponse, error)
	UnregisterLogStream(context.Context, *UnregisterLogStreamRequest) (*UnregisterLogStreamResponse, error)
	RemoveLogStreamReplica(context.Context, *RemoveLogStreamReplicaRequest) (*RemoveLogStreamReplicaResponse, error)
	Seal(context.Context, *SealRequest) (*SealResponse, error)
	Unseal(context.Context, *UnsealRequest) (*UnsealResponse, error)
	Sync(context.Context, *SyncRequest) (*SyncResponse, error)
	Trim(context.Context, *TrimRequest) (*TrimResponse, error)
	GetMetadataRepositoryNode(context.Context, *GetMetadataRepositoryNodeRequest) (*GetMetadataRepositoryNodeResponse, error)
	ListMetadataRepositoryNodes(context.Context, *ListMetadataRepositoryNodesRequest) (*ListMetadataRepositoryNodesResponse, error)
	GetMRMembers(context.Context, *types.Empty) (*GetMRMembersResponse, error)
	AddMetadataRepositoryNode(context.Context, *AddMetadataRepositoryNodeRequest) (*AddMetadataRepositoryNodeResponse, error)
	AddMRPeer(context.Context, *AddMRPeerRequest) (*AddMRPeerResponse, error)
	DeleteMetadataRepositoryNode(context.Context, *DeleteMetadataRepositoryNodeRequest) (*DeleteMetadataRepositoryNodeResponse, error)
	RemoveMRPeer(context.Context, *RemoveMRPeerRequest) (*RemoveMRPeerResponse, error)
}

ClusterManagerServer is the server API for ClusterManager service.

type DeleteMetadataRepositoryNodeRequest

type DeleteMetadataRepositoryNodeRequest struct {
	NodeID github_com_kakao_varlog_pkg_types.NodeID `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3,casttype=github.com/kakao/varlog/pkg/types.NodeID" json:"nodeId"`
}

func (*DeleteMetadataRepositoryNodeRequest) Descriptor

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

func (*DeleteMetadataRepositoryNodeRequest) GetNodeID

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

func (*DeleteMetadataRepositoryNodeRequest) Marshal

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

func (*DeleteMetadataRepositoryNodeRequest) MarshalTo

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

func (*DeleteMetadataRepositoryNodeRequest) MarshalToSizedBuffer

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

func (*DeleteMetadataRepositoryNodeRequest) ProtoMessage

func (*DeleteMetadataRepositoryNodeRequest) ProtoMessage()

func (*DeleteMetadataRepositoryNodeRequest) ProtoSize

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

func (*DeleteMetadataRepositoryNodeRequest) Reset

func (m *DeleteMetadataRepositoryNodeRequest) Reset()

func (*DeleteMetadataRepositoryNodeRequest) String

func (m *DeleteMetadataRepositoryNodeRequest) String() string

func (*DeleteMetadataRepositoryNodeRequest) Unmarshal

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

func (*DeleteMetadataRepositoryNodeRequest) XXX_DiscardUnknown

func (m *DeleteMetadataRepositoryNodeRequest) XXX_DiscardUnknown()

func (*DeleteMetadataRepositoryNodeRequest) XXX_Marshal

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

func (*DeleteMetadataRepositoryNodeRequest) XXX_Merge

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

func (*DeleteMetadataRepositoryNodeRequest) XXX_Size

func (m *DeleteMetadataRepositoryNodeRequest) XXX_Size() int

func (*DeleteMetadataRepositoryNodeRequest) XXX_Unmarshal

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

type DeleteMetadataRepositoryNodeResponse

type DeleteMetadataRepositoryNodeResponse struct {
}

func (*DeleteMetadataRepositoryNodeResponse) Descriptor

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

func (*DeleteMetadataRepositoryNodeResponse) Marshal

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

func (*DeleteMetadataRepositoryNodeResponse) MarshalTo

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

func (*DeleteMetadataRepositoryNodeResponse) MarshalToSizedBuffer

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

func (*DeleteMetadataRepositoryNodeResponse) ProtoMessage

func (*DeleteMetadataRepositoryNodeResponse) ProtoMessage()

func (*DeleteMetadataRepositoryNodeResponse) ProtoSize

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

func (*DeleteMetadataRepositoryNodeResponse) Reset

func (m *DeleteMetadataRepositoryNodeResponse) Reset()

func (*DeleteMetadataRepositoryNodeResponse) String

func (m *DeleteMetadataRepositoryNodeResponse) String() string

func (*DeleteMetadataRepositoryNodeResponse) Unmarshal

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

func (*DeleteMetadataRepositoryNodeResponse) XXX_DiscardUnknown

func (m *DeleteMetadataRepositoryNodeResponse) XXX_DiscardUnknown()

func (*DeleteMetadataRepositoryNodeResponse) XXX_Marshal

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

func (*DeleteMetadataRepositoryNodeResponse) XXX_Merge

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

func (*DeleteMetadataRepositoryNodeResponse) XXX_Size

func (m *DeleteMetadataRepositoryNodeResponse) XXX_Size() int

func (*DeleteMetadataRepositoryNodeResponse) XXX_Unmarshal

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

type DescribeTopicRequest

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

func (*DescribeTopicRequest) Descriptor

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

func (*DescribeTopicRequest) GetTopicID

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

func (*DescribeTopicRequest) Marshal

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

func (*DescribeTopicRequest) MarshalTo

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

func (*DescribeTopicRequest) MarshalToSizedBuffer

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

func (*DescribeTopicRequest) ProtoMessage

func (*DescribeTopicRequest) ProtoMessage()

func (*DescribeTopicRequest) ProtoSize

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

func (*DescribeTopicRequest) Reset

func (m *DescribeTopicRequest) Reset()

func (*DescribeTopicRequest) String

func (m *DescribeTopicRequest) String() string

func (*DescribeTopicRequest) Unmarshal

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

func (*DescribeTopicRequest) XXX_DiscardUnknown

func (m *DescribeTopicRequest) XXX_DiscardUnknown()

func (*DescribeTopicRequest) XXX_Marshal

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

func (*DescribeTopicRequest) XXX_Merge

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

func (*DescribeTopicRequest) XXX_Size

func (m *DescribeTopicRequest) XXX_Size() int

func (*DescribeTopicRequest) XXX_Unmarshal

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

type DescribeTopicResponse

type DescribeTopicResponse struct {
	Topic      varlogpb.TopicDescriptor       `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic"`
	LogStreams []varlogpb.LogStreamDescriptor `protobuf:"bytes,2,rep,name=log_streams,json=logStreams,proto3" json:"log_streams"`
}

func (*DescribeTopicResponse) Descriptor

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

func (*DescribeTopicResponse) GetLogStreams

func (m *DescribeTopicResponse) GetLogStreams() []varlogpb.LogStreamDescriptor

func (*DescribeTopicResponse) GetTopic

func (m *DescribeTopicResponse) GetTopic() varlogpb.TopicDescriptor

func (*DescribeTopicResponse) Marshal

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

func (*DescribeTopicResponse) MarshalTo

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

func (*DescribeTopicResponse) MarshalToSizedBuffer

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

func (*DescribeTopicResponse) ProtoMessage

func (*DescribeTopicResponse) ProtoMessage()

func (*DescribeTopicResponse) ProtoSize

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

func (*DescribeTopicResponse) Reset

func (m *DescribeTopicResponse) Reset()

func (*DescribeTopicResponse) String

func (m *DescribeTopicResponse) String() string

func (*DescribeTopicResponse) Unmarshal

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

func (*DescribeTopicResponse) XXX_DiscardUnknown

func (m *DescribeTopicResponse) XXX_DiscardUnknown()

func (*DescribeTopicResponse) XXX_Marshal

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

func (*DescribeTopicResponse) XXX_Merge

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

func (*DescribeTopicResponse) XXX_Size

func (m *DescribeTopicResponse) XXX_Size() int

func (*DescribeTopicResponse) XXX_Unmarshal

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

type GetLogStreamRequest

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

func (*GetLogStreamRequest) Descriptor

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

func (*GetLogStreamRequest) GetLogStreamID

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

func (*GetLogStreamRequest) GetTopicID

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

func (*GetLogStreamRequest) Marshal

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

func (*GetLogStreamRequest) MarshalTo

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

func (*GetLogStreamRequest) MarshalToSizedBuffer

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

func (*GetLogStreamRequest) ProtoMessage

func (*GetLogStreamRequest) ProtoMessage()

func (*GetLogStreamRequest) ProtoSize

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

func (*GetLogStreamRequest) Reset

func (m *GetLogStreamRequest) Reset()

func (*GetLogStreamRequest) String

func (m *GetLogStreamRequest) String() string

func (*GetLogStreamRequest) Unmarshal

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

func (*GetLogStreamRequest) XXX_DiscardUnknown

func (m *GetLogStreamRequest) XXX_DiscardUnknown()

func (*GetLogStreamRequest) XXX_Marshal

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

func (*GetLogStreamRequest) XXX_Merge

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

func (*GetLogStreamRequest) XXX_Size

func (m *GetLogStreamRequest) XXX_Size() int

func (*GetLogStreamRequest) XXX_Unmarshal

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

type GetLogStreamResponse

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

func (*GetLogStreamResponse) Descriptor

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

func (*GetLogStreamResponse) GetLogStream

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

func (*GetLogStreamResponse) Marshal

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

func (*GetLogStreamResponse) MarshalTo

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

func (*GetLogStreamResponse) MarshalToSizedBuffer

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

func (*GetLogStreamResponse) ProtoMessage

func (*GetLogStreamResponse) ProtoMessage()

func (*GetLogStreamResponse) ProtoSize

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

func (*GetLogStreamResponse) Reset

func (m *GetLogStreamResponse) Reset()

func (*GetLogStreamResponse) String

func (m *GetLogStreamResponse) String() string

func (*GetLogStreamResponse) Unmarshal

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

func (*GetLogStreamResponse) XXX_DiscardUnknown

func (m *GetLogStreamResponse) XXX_DiscardUnknown()

func (*GetLogStreamResponse) XXX_Marshal

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

func (*GetLogStreamResponse) XXX_Merge

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

func (*GetLogStreamResponse) XXX_Size

func (m *GetLogStreamResponse) XXX_Size() int

func (*GetLogStreamResponse) XXX_Unmarshal

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

type GetMRMembersResponse

type GetMRMembersResponse struct {
	Leader            github_com_kakao_varlog_pkg_types.NodeID            `protobuf:"varint,1,opt,name=leader,proto3,casttype=github.com/kakao/varlog/pkg/types.NodeID" json:"leader,omitempty"`
	ReplicationFactor int32                                               `protobuf:"varint,2,opt,name=replication_factor,json=replicationFactor,proto3" json:"replicationFactor,omitempty"`
	Members           map[github_com_kakao_varlog_pkg_types.NodeID]string `` /* 205-byte string literal not displayed */
}

func (*GetMRMembersResponse) Descriptor

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

func (*GetMRMembersResponse) GetLeader

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

func (*GetMRMembersResponse) GetMembers

func (m *GetMRMembersResponse) GetMembers() map[github_com_kakao_varlog_pkg_types.NodeID]string

func (*GetMRMembersResponse) GetReplicationFactor

func (m *GetMRMembersResponse) GetReplicationFactor() int32

func (*GetMRMembersResponse) Marshal

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

func (*GetMRMembersResponse) MarshalTo

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

func (*GetMRMembersResponse) MarshalToSizedBuffer

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

func (*GetMRMembersResponse) ProtoMessage

func (*GetMRMembersResponse) ProtoMessage()

func (*GetMRMembersResponse) ProtoSize

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

func (*GetMRMembersResponse) Reset

func (m *GetMRMembersResponse) Reset()

func (*GetMRMembersResponse) String

func (m *GetMRMembersResponse) String() string

func (*GetMRMembersResponse) Unmarshal

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

func (*GetMRMembersResponse) XXX_DiscardUnknown

func (m *GetMRMembersResponse) XXX_DiscardUnknown()

func (*GetMRMembersResponse) XXX_Marshal

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

func (*GetMRMembersResponse) XXX_Merge

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

func (*GetMRMembersResponse) XXX_Size

func (m *GetMRMembersResponse) XXX_Size() int

func (*GetMRMembersResponse) XXX_Unmarshal

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

type GetMetadataRepositoryNodeRequest

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

func (*GetMetadataRepositoryNodeRequest) Descriptor

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

func (*GetMetadataRepositoryNodeRequest) GetNodeID

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

func (*GetMetadataRepositoryNodeRequest) Marshal

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

func (*GetMetadataRepositoryNodeRequest) MarshalTo

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

func (*GetMetadataRepositoryNodeRequest) MarshalToSizedBuffer

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

func (*GetMetadataRepositoryNodeRequest) ProtoMessage

func (*GetMetadataRepositoryNodeRequest) ProtoMessage()

func (*GetMetadataRepositoryNodeRequest) ProtoSize

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

func (*GetMetadataRepositoryNodeRequest) Reset

func (m *GetMetadataRepositoryNodeRequest) Reset()

func (*GetMetadataRepositoryNodeRequest) String

func (m *GetMetadataRepositoryNodeRequest) String() string

func (*GetMetadataRepositoryNodeRequest) Unmarshal

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

func (*GetMetadataRepositoryNodeRequest) XXX_DiscardUnknown

func (m *GetMetadataRepositoryNodeRequest) XXX_DiscardUnknown()

func (*GetMetadataRepositoryNodeRequest) XXX_Marshal

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

func (*GetMetadataRepositoryNodeRequest) XXX_Merge

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

func (*GetMetadataRepositoryNodeRequest) XXX_Size

func (m *GetMetadataRepositoryNodeRequest) XXX_Size() int

func (*GetMetadataRepositoryNodeRequest) XXX_Unmarshal

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

type GetMetadataRepositoryNodeResponse

type GetMetadataRepositoryNodeResponse struct {
	Node *varlogpb.MetadataRepositoryNode `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
}

func (*GetMetadataRepositoryNodeResponse) Descriptor

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

func (*GetMetadataRepositoryNodeResponse) GetNode

func (m *GetMetadataRepositoryNodeResponse) GetNode() *varlogpb.MetadataRepositoryNode

func (*GetMetadataRepositoryNodeResponse) Marshal

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

func (*GetMetadataRepositoryNodeResponse) MarshalTo

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

func (*GetMetadataRepositoryNodeResponse) MarshalToSizedBuffer

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

func (*GetMetadataRepositoryNodeResponse) ProtoMessage

func (*GetMetadataRepositoryNodeResponse) ProtoMessage()

func (*GetMetadataRepositoryNodeResponse) ProtoSize

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

func (*GetMetadataRepositoryNodeResponse) Reset

func (m *GetMetadataRepositoryNodeResponse) Reset()

func (*GetMetadataRepositoryNodeResponse) String

func (m *GetMetadataRepositoryNodeResponse) String() string

func (*GetMetadataRepositoryNodeResponse) Unmarshal

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

func (*GetMetadataRepositoryNodeResponse) XXX_DiscardUnknown

func (m *GetMetadataRepositoryNodeResponse) XXX_DiscardUnknown()

func (*GetMetadataRepositoryNodeResponse) XXX_Marshal

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

func (*GetMetadataRepositoryNodeResponse) XXX_Merge

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

func (*GetMetadataRepositoryNodeResponse) XXX_Size

func (m *GetMetadataRepositoryNodeResponse) XXX_Size() int

func (*GetMetadataRepositoryNodeResponse) XXX_Unmarshal

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

type GetStorageNodeRequest

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

func (*GetStorageNodeRequest) Descriptor

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

func (*GetStorageNodeRequest) GetStorageNodeID

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

func (*GetStorageNodeRequest) Marshal

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

func (*GetStorageNodeRequest) MarshalTo

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

func (*GetStorageNodeRequest) MarshalToSizedBuffer

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

func (*GetStorageNodeRequest) ProtoMessage

func (*GetStorageNodeRequest) ProtoMessage()

func (*GetStorageNodeRequest) ProtoSize

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

func (*GetStorageNodeRequest) Reset

func (m *GetStorageNodeRequest) Reset()

func (*GetStorageNodeRequest) String

func (m *GetStorageNodeRequest) String() string

func (*GetStorageNodeRequest) Unmarshal

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

func (*GetStorageNodeRequest) XXX_DiscardUnknown

func (m *GetStorageNodeRequest) XXX_DiscardUnknown()

func (*GetStorageNodeRequest) XXX_Marshal

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

func (*GetStorageNodeRequest) XXX_Merge

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

func (*GetStorageNodeRequest) XXX_Size

func (m *GetStorageNodeRequest) XXX_Size() int

func (*GetStorageNodeRequest) XXX_Unmarshal

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

type GetStorageNodeResponse

type GetStorageNodeResponse struct {
	// StorageNode registered to the cluster.
	StorageNode *StorageNodeMetadata `protobuf:"bytes,1,opt,name=storage_node,json=storageNode,proto3" json:"storageNode"`
}

func (*GetStorageNodeResponse) Descriptor

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

func (*GetStorageNodeResponse) GetStorageNode

func (m *GetStorageNodeResponse) GetStorageNode() *StorageNodeMetadata

func (*GetStorageNodeResponse) Marshal

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

func (*GetStorageNodeResponse) MarshalTo

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

func (*GetStorageNodeResponse) MarshalToSizedBuffer

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

func (*GetStorageNodeResponse) ProtoMessage

func (*GetStorageNodeResponse) ProtoMessage()

func (*GetStorageNodeResponse) ProtoSize

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

func (*GetStorageNodeResponse) Reset

func (m *GetStorageNodeResponse) Reset()

func (*GetStorageNodeResponse) String

func (m *GetStorageNodeResponse) String() string

func (*GetStorageNodeResponse) Unmarshal

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

func (*GetStorageNodeResponse) XXX_DiscardUnknown

func (m *GetStorageNodeResponse) XXX_DiscardUnknown()

func (*GetStorageNodeResponse) XXX_Marshal

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

func (*GetStorageNodeResponse) XXX_Merge

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

func (*GetStorageNodeResponse) XXX_Size

func (m *GetStorageNodeResponse) XXX_Size() int

func (*GetStorageNodeResponse) XXX_Unmarshal

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

type GetTopicRequest

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

func (*GetTopicRequest) Descriptor

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

func (*GetTopicRequest) GetTopicID

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

func (*GetTopicRequest) Marshal

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

func (*GetTopicRequest) MarshalTo

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

func (*GetTopicRequest) MarshalToSizedBuffer

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

func (*GetTopicRequest) ProtoMessage

func (*GetTopicRequest) ProtoMessage()

func (*GetTopicRequest) ProtoSize

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

func (*GetTopicRequest) Reset

func (m *GetTopicRequest) Reset()

func (*GetTopicRequest) String

func (m *GetTopicRequest) String() string

func (*GetTopicRequest) Unmarshal

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

func (*GetTopicRequest) XXX_DiscardUnknown

func (m *GetTopicRequest) XXX_DiscardUnknown()

func (*GetTopicRequest) XXX_Marshal

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

func (*GetTopicRequest) XXX_Merge

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

func (*GetTopicRequest) XXX_Size

func (m *GetTopicRequest) XXX_Size() int

func (*GetTopicRequest) XXX_Unmarshal

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

type GetTopicResponse

type GetTopicResponse struct {
	Topic *varlogpb.TopicDescriptor `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic"`
}

func (*GetTopicResponse) Descriptor

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

func (*GetTopicResponse) GetTopic

func (m *GetTopicResponse) GetTopic() *varlogpb.TopicDescriptor

func (*GetTopicResponse) Marshal

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

func (*GetTopicResponse) MarshalTo

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

func (*GetTopicResponse) MarshalToSizedBuffer

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

func (*GetTopicResponse) ProtoMessage

func (*GetTopicResponse) ProtoMessage()

func (*GetTopicResponse) ProtoSize

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

func (*GetTopicResponse) Reset

func (m *GetTopicResponse) Reset()

func (*GetTopicResponse) String

func (m *GetTopicResponse) String() string

func (*GetTopicResponse) Unmarshal

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

func (*GetTopicResponse) XXX_DiscardUnknown

func (m *GetTopicResponse) XXX_DiscardUnknown()

func (*GetTopicResponse) XXX_Marshal

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

func (*GetTopicResponse) XXX_Merge

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

func (*GetTopicResponse) XXX_Size

func (m *GetTopicResponse) XXX_Size() int

func (*GetTopicResponse) XXX_Unmarshal

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

type ListLogStreamsRequest

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

func (*ListLogStreamsRequest) Descriptor

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

func (*ListLogStreamsRequest) GetTopicID

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

func (*ListLogStreamsRequest) Marshal

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

func (*ListLogStreamsRequest) MarshalTo

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

func (*ListLogStreamsRequest) MarshalToSizedBuffer

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

func (*ListLogStreamsRequest) ProtoMessage

func (*ListLogStreamsRequest) ProtoMessage()

func (*ListLogStreamsRequest) ProtoSize

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

func (*ListLogStreamsRequest) Reset

func (m *ListLogStreamsRequest) Reset()

func (*ListLogStreamsRequest) String

func (m *ListLogStreamsRequest) String() string

func (*ListLogStreamsRequest) Unmarshal

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

func (*ListLogStreamsRequest) XXX_DiscardUnknown

func (m *ListLogStreamsRequest) XXX_DiscardUnknown()

func (*ListLogStreamsRequest) XXX_Marshal

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

func (*ListLogStreamsRequest) XXX_Merge

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

func (*ListLogStreamsRequest) XXX_Size

func (m *ListLogStreamsRequest) XXX_Size() int

func (*ListLogStreamsRequest) XXX_Unmarshal

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

type ListLogStreamsResponse

type ListLogStreamsResponse struct {
	LogStreams []varlogpb.LogStreamDescriptor `protobuf:"bytes,1,rep,name=log_streams,json=logStreams,proto3" json:"logStreams"`
}

func (*ListLogStreamsResponse) Descriptor

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

func (*ListLogStreamsResponse) GetLogStreams

func (m *ListLogStreamsResponse) GetLogStreams() []varlogpb.LogStreamDescriptor

func (*ListLogStreamsResponse) Marshal

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

func (*ListLogStreamsResponse) MarshalTo

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

func (*ListLogStreamsResponse) MarshalToSizedBuffer

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

func (*ListLogStreamsResponse) ProtoMessage

func (*ListLogStreamsResponse) ProtoMessage()

func (*ListLogStreamsResponse) ProtoSize

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

func (*ListLogStreamsResponse) Reset

func (m *ListLogStreamsResponse) Reset()

func (*ListLogStreamsResponse) String

func (m *ListLogStreamsResponse) String() string

func (*ListLogStreamsResponse) Unmarshal

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

func (*ListLogStreamsResponse) XXX_DiscardUnknown

func (m *ListLogStreamsResponse) XXX_DiscardUnknown()

func (*ListLogStreamsResponse) XXX_Marshal

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

func (*ListLogStreamsResponse) XXX_Merge

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

func (*ListLogStreamsResponse) XXX_Size

func (m *ListLogStreamsResponse) XXX_Size() int

func (*ListLogStreamsResponse) XXX_Unmarshal

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

type ListMetadataRepositoryNodesRequest

type ListMetadataRepositoryNodesRequest struct {
}

func (*ListMetadataRepositoryNodesRequest) Descriptor

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

func (*ListMetadataRepositoryNodesRequest) Marshal

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

func (*ListMetadataRepositoryNodesRequest) MarshalTo

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

func (*ListMetadataRepositoryNodesRequest) MarshalToSizedBuffer

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

func (*ListMetadataRepositoryNodesRequest) ProtoMessage

func (*ListMetadataRepositoryNodesRequest) ProtoMessage()

func (*ListMetadataRepositoryNodesRequest) ProtoSize

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

func (*ListMetadataRepositoryNodesRequest) Reset

func (m *ListMetadataRepositoryNodesRequest) Reset()

func (*ListMetadataRepositoryNodesRequest) String

func (m *ListMetadataRepositoryNodesRequest) String() string

func (*ListMetadataRepositoryNodesRequest) Unmarshal

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

func (*ListMetadataRepositoryNodesRequest) XXX_DiscardUnknown

func (m *ListMetadataRepositoryNodesRequest) XXX_DiscardUnknown()

func (*ListMetadataRepositoryNodesRequest) XXX_Marshal

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

func (*ListMetadataRepositoryNodesRequest) XXX_Merge

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

func (*ListMetadataRepositoryNodesRequest) XXX_Size

func (m *ListMetadataRepositoryNodesRequest) XXX_Size() int

func (*ListMetadataRepositoryNodesRequest) XXX_Unmarshal

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

type ListMetadataRepositoryNodesResponse

type ListMetadataRepositoryNodesResponse struct {
	Nodes []varlogpb.MetadataRepositoryNode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes"`
}

func (*ListMetadataRepositoryNodesResponse) Descriptor

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

func (*ListMetadataRepositoryNodesResponse) GetNodes

func (m *ListMetadataRepositoryNodesResponse) GetNodes() []varlogpb.MetadataRepositoryNode

func (*ListMetadataRepositoryNodesResponse) Marshal

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

func (*ListMetadataRepositoryNodesResponse) MarshalTo

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

func (*ListMetadataRepositoryNodesResponse) MarshalToSizedBuffer

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

func (*ListMetadataRepositoryNodesResponse) ProtoMessage

func (*ListMetadataRepositoryNodesResponse) ProtoMessage()

func (*ListMetadataRepositoryNodesResponse) ProtoSize

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

func (*ListMetadataRepositoryNodesResponse) Reset

func (m *ListMetadataRepositoryNodesResponse) Reset()

func (*ListMetadataRepositoryNodesResponse) String

func (m *ListMetadataRepositoryNodesResponse) String() string

func (*ListMetadataRepositoryNodesResponse) Unmarshal

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

func (*ListMetadataRepositoryNodesResponse) XXX_DiscardUnknown

func (m *ListMetadataRepositoryNodesResponse) XXX_DiscardUnknown()

func (*ListMetadataRepositoryNodesResponse) XXX_Marshal

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

func (*ListMetadataRepositoryNodesResponse) XXX_Merge

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

func (*ListMetadataRepositoryNodesResponse) XXX_Size

func (m *ListMetadataRepositoryNodesResponse) XXX_Size() int

func (*ListMetadataRepositoryNodesResponse) XXX_Unmarshal

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

type ListStorageNodesRequest

type ListStorageNodesRequest struct {
}

func (*ListStorageNodesRequest) Descriptor

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

func (*ListStorageNodesRequest) Marshal

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

func (*ListStorageNodesRequest) MarshalTo

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

func (*ListStorageNodesRequest) MarshalToSizedBuffer

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

func (*ListStorageNodesRequest) ProtoMessage

func (*ListStorageNodesRequest) ProtoMessage()

func (*ListStorageNodesRequest) ProtoSize

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

func (*ListStorageNodesRequest) Reset

func (m *ListStorageNodesRequest) Reset()

func (*ListStorageNodesRequest) String

func (m *ListStorageNodesRequest) String() string

func (*ListStorageNodesRequest) Unmarshal

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

func (*ListStorageNodesRequest) XXX_DiscardUnknown

func (m *ListStorageNodesRequest) XXX_DiscardUnknown()

func (*ListStorageNodesRequest) XXX_Marshal

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

func (*ListStorageNodesRequest) XXX_Merge

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

func (*ListStorageNodesRequest) XXX_Size

func (m *ListStorageNodesRequest) XXX_Size() int

func (*ListStorageNodesRequest) XXX_Unmarshal

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

type ListStorageNodesResponse

type ListStorageNodesResponse struct {
	// StorageNodes registered to the cluster.
	StorageNodes []StorageNodeMetadata `protobuf:"bytes,1,rep,name=storage_nodes,json=storageNodes,proto3" json:"storageNodes"`
}

func (*ListStorageNodesResponse) Descriptor

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

func (*ListStorageNodesResponse) GetStorageNodes

func (m *ListStorageNodesResponse) GetStorageNodes() []StorageNodeMetadata

func (*ListStorageNodesResponse) Marshal

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

func (*ListStorageNodesResponse) MarshalTo

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

func (*ListStorageNodesResponse) MarshalToSizedBuffer

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

func (*ListStorageNodesResponse) ProtoMessage

func (*ListStorageNodesResponse) ProtoMessage()

func (*ListStorageNodesResponse) ProtoSize

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

func (*ListStorageNodesResponse) Reset

func (m *ListStorageNodesResponse) Reset()

func (*ListStorageNodesResponse) String

func (m *ListStorageNodesResponse) String() string

func (*ListStorageNodesResponse) Unmarshal

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

func (*ListStorageNodesResponse) XXX_DiscardUnknown

func (m *ListStorageNodesResponse) XXX_DiscardUnknown()

func (*ListStorageNodesResponse) XXX_Marshal

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

func (*ListStorageNodesResponse) XXX_Merge

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

func (*ListStorageNodesResponse) XXX_Size

func (m *ListStorageNodesResponse) XXX_Size() int

func (*ListStorageNodesResponse) XXX_Unmarshal

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

type ListTopicsRequest

type ListTopicsRequest struct {
}

func (*ListTopicsRequest) Descriptor

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

func (*ListTopicsRequest) Marshal

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

func (*ListTopicsRequest) MarshalTo

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

func (*ListTopicsRequest) MarshalToSizedBuffer

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

func (*ListTopicsRequest) ProtoMessage

func (*ListTopicsRequest) ProtoMessage()

func (*ListTopicsRequest) ProtoSize

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

func (*ListTopicsRequest) Reset

func (m *ListTopicsRequest) Reset()

func (*ListTopicsRequest) String

func (m *ListTopicsRequest) String() string

func (*ListTopicsRequest) Unmarshal

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

func (*ListTopicsRequest) XXX_DiscardUnknown

func (m *ListTopicsRequest) XXX_DiscardUnknown()

func (*ListTopicsRequest) XXX_Marshal

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

func (*ListTopicsRequest) XXX_Merge

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

func (*ListTopicsRequest) XXX_Size

func (m *ListTopicsRequest) XXX_Size() int

func (*ListTopicsRequest) XXX_Unmarshal

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

type ListTopicsResponse

type ListTopicsResponse struct {
	Topics []varlogpb.TopicDescriptor `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics"`
}

func (*ListTopicsResponse) Descriptor

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

func (*ListTopicsResponse) GetTopics

func (m *ListTopicsResponse) GetTopics() []varlogpb.TopicDescriptor

func (*ListTopicsResponse) Marshal

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

func (*ListTopicsResponse) MarshalTo

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

func (*ListTopicsResponse) MarshalToSizedBuffer

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

func (*ListTopicsResponse) ProtoMessage

func (*ListTopicsResponse) ProtoMessage()

func (*ListTopicsResponse) ProtoSize

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

func (*ListTopicsResponse) Reset

func (m *ListTopicsResponse) Reset()

func (*ListTopicsResponse) String

func (m *ListTopicsResponse) String() string

func (*ListTopicsResponse) Unmarshal

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

func (*ListTopicsResponse) XXX_DiscardUnknown

func (m *ListTopicsResponse) XXX_DiscardUnknown()

func (*ListTopicsResponse) XXX_Marshal

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

func (*ListTopicsResponse) XXX_Merge

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

func (*ListTopicsResponse) XXX_Size

func (m *ListTopicsResponse) XXX_Size() int

func (*ListTopicsResponse) XXX_Unmarshal

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

type RemoveLogStreamReplicaRequest

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

func (*RemoveLogStreamReplicaRequest) Descriptor

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

func (*RemoveLogStreamReplicaRequest) GetLogStreamID

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

func (*RemoveLogStreamReplicaRequest) GetStorageNodeID

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

func (*RemoveLogStreamReplicaRequest) GetTopicID

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

func (*RemoveLogStreamReplicaRequest) Marshal

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

func (*RemoveLogStreamReplicaRequest) MarshalTo

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

func (*RemoveLogStreamReplicaRequest) MarshalToSizedBuffer

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

func (*RemoveLogStreamReplicaRequest) ProtoMessage

func (*RemoveLogStreamReplicaRequest) ProtoMessage()

func (*RemoveLogStreamReplicaRequest) ProtoSize

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

func (*RemoveLogStreamReplicaRequest) Reset

func (m *RemoveLogStreamReplicaRequest) Reset()

func (*RemoveLogStreamReplicaRequest) String

func (m *RemoveLogStreamReplicaRequest) String() string

func (*RemoveLogStreamReplicaRequest) Unmarshal

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

func (*RemoveLogStreamReplicaRequest) XXX_DiscardUnknown

func (m *RemoveLogStreamReplicaRequest) XXX_DiscardUnknown()

func (*RemoveLogStreamReplicaRequest) XXX_Marshal

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

func (*RemoveLogStreamReplicaRequest) XXX_Merge

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

func (*RemoveLogStreamReplicaRequest) XXX_Size

func (m *RemoveLogStreamReplicaRequest) XXX_Size() int

func (*RemoveLogStreamReplicaRequest) XXX_Unmarshal

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

type RemoveLogStreamReplicaResponse

type RemoveLogStreamReplicaResponse struct {
}

func (*RemoveLogStreamReplicaResponse) Descriptor

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

func (*RemoveLogStreamReplicaResponse) Marshal

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

func (*RemoveLogStreamReplicaResponse) MarshalTo

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

func (*RemoveLogStreamReplicaResponse) MarshalToSizedBuffer

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

func (*RemoveLogStreamReplicaResponse) ProtoMessage

func (*RemoveLogStreamReplicaResponse) ProtoMessage()

func (*RemoveLogStreamReplicaResponse) ProtoSize

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

func (*RemoveLogStreamReplicaResponse) Reset

func (m *RemoveLogStreamReplicaResponse) Reset()

func (*RemoveLogStreamReplicaResponse) String

func (m *RemoveLogStreamReplicaResponse) String() string

func (*RemoveLogStreamReplicaResponse) Unmarshal

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

func (*RemoveLogStreamReplicaResponse) XXX_DiscardUnknown

func (m *RemoveLogStreamReplicaResponse) XXX_DiscardUnknown()

func (*RemoveLogStreamReplicaResponse) XXX_Marshal

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

func (*RemoveLogStreamReplicaResponse) XXX_Merge

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

func (*RemoveLogStreamReplicaResponse) XXX_Size

func (m *RemoveLogStreamReplicaResponse) XXX_Size() int

func (*RemoveLogStreamReplicaResponse) XXX_Unmarshal

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

type RemoveMRPeerRequest

type RemoveMRPeerRequest struct {
	RaftURL string `protobuf:"bytes,1,opt,name=raft_url,json=raftUrl,proto3" json:"raft_url,omitempty"`
}

func (*RemoveMRPeerRequest) Descriptor

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

func (*RemoveMRPeerRequest) GetRaftURL

func (m *RemoveMRPeerRequest) GetRaftURL() string

func (*RemoveMRPeerRequest) Marshal

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

func (*RemoveMRPeerRequest) MarshalTo

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

func (*RemoveMRPeerRequest) MarshalToSizedBuffer

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

func (*RemoveMRPeerRequest) ProtoMessage

func (*RemoveMRPeerRequest) ProtoMessage()

func (*RemoveMRPeerRequest) ProtoSize

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

func (*RemoveMRPeerRequest) Reset

func (m *RemoveMRPeerRequest) Reset()

func (*RemoveMRPeerRequest) String

func (m *RemoveMRPeerRequest) String() string

func (*RemoveMRPeerRequest) Unmarshal

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

func (*RemoveMRPeerRequest) XXX_DiscardUnknown

func (m *RemoveMRPeerRequest) XXX_DiscardUnknown()

func (*RemoveMRPeerRequest) XXX_Marshal

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

func (*RemoveMRPeerRequest) XXX_Merge

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

func (*RemoveMRPeerRequest) XXX_Size

func (m *RemoveMRPeerRequest) XXX_Size() int

func (*RemoveMRPeerRequest) XXX_Unmarshal

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

type RemoveMRPeerResponse

type RemoveMRPeerResponse struct {
}

func (*RemoveMRPeerResponse) Descriptor

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

func (*RemoveMRPeerResponse) Marshal

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

func (*RemoveMRPeerResponse) MarshalTo

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

func (*RemoveMRPeerResponse) MarshalToSizedBuffer

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

func (*RemoveMRPeerResponse) ProtoMessage

func (*RemoveMRPeerResponse) ProtoMessage()

func (*RemoveMRPeerResponse) ProtoSize

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

func (*RemoveMRPeerResponse) Reset

func (m *RemoveMRPeerResponse) Reset()

func (*RemoveMRPeerResponse) String

func (m *RemoveMRPeerResponse) String() string

func (*RemoveMRPeerResponse) Unmarshal

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

func (*RemoveMRPeerResponse) XXX_DiscardUnknown

func (m *RemoveMRPeerResponse) XXX_DiscardUnknown()

func (*RemoveMRPeerResponse) XXX_Marshal

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

func (*RemoveMRPeerResponse) XXX_Merge

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

func (*RemoveMRPeerResponse) XXX_Size

func (m *RemoveMRPeerResponse) XXX_Size() int

func (*RemoveMRPeerResponse) XXX_Unmarshal

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

type SealRequest

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

func (*SealRequest) Descriptor

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

func (*SealRequest) GetLogStreamID

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

func (*SealRequest) GetTopicID

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

func (*SealRequest) Marshal

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

func (*SealRequest) MarshalTo

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

func (*SealRequest) MarshalToSizedBuffer

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

func (*SealRequest) ProtoMessage

func (*SealRequest) ProtoMessage()

func (*SealRequest) ProtoSize

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

func (*SealRequest) Reset

func (m *SealRequest) Reset()

func (*SealRequest) String

func (m *SealRequest) String() string

func (*SealRequest) Unmarshal

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

func (*SealRequest) XXX_DiscardUnknown

func (m *SealRequest) XXX_DiscardUnknown()

func (*SealRequest) XXX_Marshal

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

func (*SealRequest) XXX_Merge

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

func (*SealRequest) XXX_Size

func (m *SealRequest) XXX_Size() int

func (*SealRequest) XXX_Unmarshal

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

type SealResponse

type SealResponse struct {
	LogStreams []snpb.LogStreamReplicaMetadataDescriptor `protobuf:"bytes,1,rep,name=log_streams,json=logStreams,proto3" json:"logStreams"`
	SealedGLSN github_com_kakao_varlog_pkg_types.GLSN    `` /* 129-byte string literal not displayed */
}

func (*SealResponse) Descriptor

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

func (*SealResponse) GetLogStreams

func (m *SealResponse) GetLogStreams() []snpb.LogStreamReplicaMetadataDescriptor

func (*SealResponse) GetSealedGLSN

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

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 StorageNodeMetadata

type StorageNodeMetadata struct {
	snpb.StorageNodeMetadataDescriptor `protobuf:"bytes,1,opt,name=storage_node,json=storageNode,proto3,embedded=storage_node" json:""`
	CreateTime                         time.Time `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3,stdtime" json:"createTime"`
	LastHeartbeatTime                  time.Time `protobuf:"bytes,3,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3,stdtime" json:"lastHeartbeatTime"`
}

func (*StorageNodeMetadata) Descriptor

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

func (*StorageNodeMetadata) Equal

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

func (*StorageNodeMetadata) GetCreateTime

func (m *StorageNodeMetadata) GetCreateTime() time.Time

func (*StorageNodeMetadata) GetLastHeartbeatTime

func (m *StorageNodeMetadata) GetLastHeartbeatTime() time.Time

func (*StorageNodeMetadata) Marshal

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

func (*StorageNodeMetadata) MarshalTo

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

func (*StorageNodeMetadata) MarshalToSizedBuffer

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

func (*StorageNodeMetadata) ProtoMessage

func (*StorageNodeMetadata) ProtoMessage()

func (*StorageNodeMetadata) ProtoSize

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

func (*StorageNodeMetadata) Reset

func (m *StorageNodeMetadata) Reset()

func (*StorageNodeMetadata) String

func (m *StorageNodeMetadata) String() string

func (*StorageNodeMetadata) Unmarshal

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

func (*StorageNodeMetadata) XXX_DiscardUnknown

func (m *StorageNodeMetadata) XXX_DiscardUnknown()

func (*StorageNodeMetadata) XXX_Marshal

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

func (*StorageNodeMetadata) XXX_Merge

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

func (*StorageNodeMetadata) XXX_Size

func (m *StorageNodeMetadata) XXX_Size() int

func (*StorageNodeMetadata) XXX_Unmarshal

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

type SyncRequest

type SyncRequest struct {
	TopicID          github_com_kakao_varlog_pkg_types.TopicID       `` /* 134-byte string literal not displayed */
	LogStreamID      github_com_kakao_varlog_pkg_types.LogStreamID   `` /* 152-byte string literal not displayed */
	SrcStorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 171-byte string literal not displayed */
	DstStorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 171-byte string literal not displayed */
}

func (*SyncRequest) Descriptor

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

func (*SyncRequest) GetDstStorageNodeID

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

func (*SyncRequest) GetLogStreamID

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

func (*SyncRequest) GetSrcStorageNodeID

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

func (*SyncRequest) GetTopicID

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

func (*SyncRequest) Marshal

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

func (*SyncRequest) MarshalTo

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

func (*SyncRequest) MarshalToSizedBuffer

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

func (*SyncRequest) ProtoMessage

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) ProtoSize

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

func (*SyncRequest) Reset

func (m *SyncRequest) Reset()

func (*SyncRequest) String

func (m *SyncRequest) String() string

func (*SyncRequest) Unmarshal

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

func (*SyncRequest) XXX_DiscardUnknown

func (m *SyncRequest) XXX_DiscardUnknown()

func (*SyncRequest) XXX_Marshal

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

func (*SyncRequest) XXX_Merge

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

func (*SyncRequest) XXX_Size

func (m *SyncRequest) XXX_Size() int

func (*SyncRequest) XXX_Unmarshal

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

type SyncResponse

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

func (*SyncResponse) Descriptor

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

func (*SyncResponse) GetStatus

func (m *SyncResponse) GetStatus() *snpb.SyncStatus

func (*SyncResponse) Marshal

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

func (*SyncResponse) MarshalTo

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

func (*SyncResponse) MarshalToSizedBuffer

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

func (*SyncResponse) ProtoMessage

func (*SyncResponse) ProtoMessage()

func (*SyncResponse) ProtoSize

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

func (*SyncResponse) Reset

func (m *SyncResponse) Reset()

func (*SyncResponse) String

func (m *SyncResponse) String() string

func (*SyncResponse) Unmarshal

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

func (*SyncResponse) XXX_DiscardUnknown

func (m *SyncResponse) XXX_DiscardUnknown()

func (*SyncResponse) XXX_Marshal

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

func (*SyncResponse) XXX_Merge

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

func (*SyncResponse) XXX_Size

func (m *SyncResponse) XXX_Size() int

func (*SyncResponse) XXX_Unmarshal

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

type TrimRequest

type TrimRequest struct {
	TopicID  github_com_kakao_varlog_pkg_types.TopicID `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3,casttype=github.com/kakao/varlog/pkg/types.TopicID" json:"topicId"`
	LastGLSN github_com_kakao_varlog_pkg_types.GLSN    `protobuf:"varint,2,opt,name=last_glsn,json=lastGlsn,proto3,casttype=github.com/kakao/varlog/pkg/types.GLSN" json:"lastGLSN"`
}

func (*TrimRequest) Descriptor

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

func (*TrimRequest) GetLastGLSN

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

func (*TrimRequest) GetTopicID

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

func (*TrimRequest) Marshal

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

func (*TrimRequest) MarshalTo

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

func (*TrimRequest) MarshalToSizedBuffer

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

func (*TrimRequest) ProtoMessage

func (*TrimRequest) ProtoMessage()

func (*TrimRequest) ProtoSize

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

func (*TrimRequest) Reset

func (m *TrimRequest) Reset()

func (*TrimRequest) String

func (m *TrimRequest) String() string

func (*TrimRequest) Unmarshal

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

func (*TrimRequest) XXX_DiscardUnknown

func (m *TrimRequest) XXX_DiscardUnknown()

func (*TrimRequest) XXX_Marshal

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

func (*TrimRequest) XXX_Merge

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

func (*TrimRequest) XXX_Size

func (m *TrimRequest) XXX_Size() int

func (*TrimRequest) XXX_Unmarshal

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

type TrimResponse

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

func (*TrimResponse) Descriptor

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

func (*TrimResponse) GetResults

func (m *TrimResponse) GetResults() []TrimResult

func (*TrimResponse) Marshal

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

func (*TrimResponse) MarshalTo

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

func (*TrimResponse) MarshalToSizedBuffer

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

func (*TrimResponse) ProtoMessage

func (*TrimResponse) ProtoMessage()

func (*TrimResponse) ProtoSize

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

func (*TrimResponse) Reset

func (m *TrimResponse) Reset()

func (*TrimResponse) String

func (m *TrimResponse) String() string

func (*TrimResponse) Unmarshal

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

func (*TrimResponse) XXX_DiscardUnknown

func (m *TrimResponse) XXX_DiscardUnknown()

func (*TrimResponse) XXX_Marshal

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

func (*TrimResponse) XXX_Merge

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

func (*TrimResponse) XXX_Size

func (m *TrimResponse) XXX_Size() int

func (*TrimResponse) XXX_Unmarshal

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

type TrimResult

type TrimResult struct {
	StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID `` /* 148-byte string literal not displayed */
	LogStreamID   github_com_kakao_varlog_pkg_types.LogStreamID   `` /* 140-byte string literal not displayed */
	Error         string                                          `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
}

func (*TrimResult) Descriptor

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

func (*TrimResult) GetError

func (m *TrimResult) GetError() string

func (*TrimResult) GetLogStreamID

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

func (*TrimResult) GetStorageNodeID

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

func (*TrimResult) Marshal

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

func (*TrimResult) MarshalTo

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

func (*TrimResult) MarshalToSizedBuffer

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

func (*TrimResult) ProtoMessage

func (*TrimResult) ProtoMessage()

func (*TrimResult) ProtoSize

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

func (*TrimResult) Reset

func (m *TrimResult) Reset()

func (*TrimResult) String

func (m *TrimResult) String() string

func (*TrimResult) Unmarshal

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

func (*TrimResult) XXX_DiscardUnknown

func (m *TrimResult) XXX_DiscardUnknown()

func (*TrimResult) XXX_Marshal

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

func (*TrimResult) XXX_Merge

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

func (*TrimResult) XXX_Size

func (m *TrimResult) XXX_Size() int

func (*TrimResult) XXX_Unmarshal

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

type UnimplementedClusterManagerServer

type UnimplementedClusterManagerServer struct {
}

UnimplementedClusterManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedClusterManagerServer) AddLogStream

func (*UnimplementedClusterManagerServer) AddLogStream(ctx context.Context, req *AddLogStreamRequest) (*AddLogStreamResponse, error)

func (*UnimplementedClusterManagerServer) AddMRPeer

func (*UnimplementedClusterManagerServer) AddMRPeer(ctx context.Context, req *AddMRPeerRequest) (*AddMRPeerResponse, error)

func (*UnimplementedClusterManagerServer) AddMetadataRepositoryNode

func (*UnimplementedClusterManagerServer) AddMetadataRepositoryNode(ctx context.Context, req *AddMetadataRepositoryNodeRequest) (*AddMetadataRepositoryNodeResponse, error)

func (*UnimplementedClusterManagerServer) AddStorageNode

func (*UnimplementedClusterManagerServer) AddStorageNode(ctx context.Context, req *AddStorageNodeRequest) (*AddStorageNodeResponse, error)

func (*UnimplementedClusterManagerServer) AddTopic

func (*UnimplementedClusterManagerServer) AddTopic(ctx context.Context, req *AddTopicRequest) (*AddTopicResponse, error)

func (*UnimplementedClusterManagerServer) DeleteMetadataRepositoryNode

func (*UnimplementedClusterManagerServer) DeleteMetadataRepositoryNode(ctx context.Context, req *DeleteMetadataRepositoryNodeRequest) (*DeleteMetadataRepositoryNodeResponse, error)

func (*UnimplementedClusterManagerServer) DescribeTopic

func (*UnimplementedClusterManagerServer) DescribeTopic(ctx context.Context, req *DescribeTopicRequest) (*DescribeTopicResponse, error)

func (*UnimplementedClusterManagerServer) GetLogStream

func (*UnimplementedClusterManagerServer) GetLogStream(ctx context.Context, req *GetLogStreamRequest) (*GetLogStreamResponse, error)

func (*UnimplementedClusterManagerServer) GetMRMembers

func (*UnimplementedClusterManagerServer) GetMRMembers(ctx context.Context, req *types.Empty) (*GetMRMembersResponse, error)

func (*UnimplementedClusterManagerServer) GetMetadataRepositoryNode

func (*UnimplementedClusterManagerServer) GetMetadataRepositoryNode(ctx context.Context, req *GetMetadataRepositoryNodeRequest) (*GetMetadataRepositoryNodeResponse, error)

func (*UnimplementedClusterManagerServer) GetStorageNode

func (*UnimplementedClusterManagerServer) GetStorageNode(ctx context.Context, req *GetStorageNodeRequest) (*GetStorageNodeResponse, error)

func (*UnimplementedClusterManagerServer) GetTopic

func (*UnimplementedClusterManagerServer) GetTopic(ctx context.Context, req *GetTopicRequest) (*GetTopicResponse, error)

func (*UnimplementedClusterManagerServer) ListLogStreams

func (*UnimplementedClusterManagerServer) ListLogStreams(ctx context.Context, req *ListLogStreamsRequest) (*ListLogStreamsResponse, error)

func (*UnimplementedClusterManagerServer) ListMetadataRepositoryNodes

func (*UnimplementedClusterManagerServer) ListMetadataRepositoryNodes(ctx context.Context, req *ListMetadataRepositoryNodesRequest) (*ListMetadataRepositoryNodesResponse, error)

func (*UnimplementedClusterManagerServer) ListStorageNodes

func (*UnimplementedClusterManagerServer) ListStorageNodes(ctx context.Context, req *ListStorageNodesRequest) (*ListStorageNodesResponse, error)

func (*UnimplementedClusterManagerServer) ListTopics

func (*UnimplementedClusterManagerServer) ListTopics(ctx context.Context, req *ListTopicsRequest) (*ListTopicsResponse, error)

func (*UnimplementedClusterManagerServer) RemoveLogStreamReplica

func (*UnimplementedClusterManagerServer) RemoveLogStreamReplica(ctx context.Context, req *RemoveLogStreamReplicaRequest) (*RemoveLogStreamReplicaResponse, error)

func (*UnimplementedClusterManagerServer) RemoveMRPeer

func (*UnimplementedClusterManagerServer) RemoveMRPeer(ctx context.Context, req *RemoveMRPeerRequest) (*RemoveMRPeerResponse, error)

func (*UnimplementedClusterManagerServer) Seal

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

func (*UnimplementedClusterManagerServer) Sync

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

func (*UnimplementedClusterManagerServer) Trim

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

func (*UnimplementedClusterManagerServer) UnregisterLogStream

func (*UnimplementedClusterManagerServer) UnregisterLogStream(ctx context.Context, req *UnregisterLogStreamRequest) (*UnregisterLogStreamResponse, error)

func (*UnimplementedClusterManagerServer) UnregisterStorageNode

func (*UnimplementedClusterManagerServer) UnregisterStorageNode(ctx context.Context, req *UnregisterStorageNodeRequest) (*UnregisterStorageNodeResponse, error)

func (*UnimplementedClusterManagerServer) UnregisterTopic

func (*UnimplementedClusterManagerServer) UnregisterTopic(ctx context.Context, req *UnregisterTopicRequest) (*UnregisterTopicResponse, error)

func (*UnimplementedClusterManagerServer) Unseal

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

func (*UnimplementedClusterManagerServer) UpdateLogStream

func (*UnimplementedClusterManagerServer) UpdateLogStream(ctx context.Context, req *UpdateLogStreamRequest) (*UpdateLogStreamResponse, error)

type UnregisterLogStreamRequest

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

func (*UnregisterLogStreamRequest) Descriptor

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

func (*UnregisterLogStreamRequest) GetLogStreamID

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

func (*UnregisterLogStreamRequest) GetTopicID

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

func (*UnregisterLogStreamRequest) Marshal

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

func (*UnregisterLogStreamRequest) MarshalTo

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

func (*UnregisterLogStreamRequest) MarshalToSizedBuffer

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

func (*UnregisterLogStreamRequest) ProtoMessage

func (*UnregisterLogStreamRequest) ProtoMessage()

func (*UnregisterLogStreamRequest) ProtoSize

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

func (*UnregisterLogStreamRequest) Reset

func (m *UnregisterLogStreamRequest) Reset()

func (*UnregisterLogStreamRequest) String

func (m *UnregisterLogStreamRequest) String() string

func (*UnregisterLogStreamRequest) Unmarshal

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

func (*UnregisterLogStreamRequest) XXX_DiscardUnknown

func (m *UnregisterLogStreamRequest) XXX_DiscardUnknown()

func (*UnregisterLogStreamRequest) XXX_Marshal

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

func (*UnregisterLogStreamRequest) XXX_Merge

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

func (*UnregisterLogStreamRequest) XXX_Size

func (m *UnregisterLogStreamRequest) XXX_Size() int

func (*UnregisterLogStreamRequest) XXX_Unmarshal

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

type UnregisterLogStreamResponse

type UnregisterLogStreamResponse struct {
}

func (*UnregisterLogStreamResponse) Descriptor

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

func (*UnregisterLogStreamResponse) Marshal

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

func (*UnregisterLogStreamResponse) MarshalTo

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

func (*UnregisterLogStreamResponse) MarshalToSizedBuffer

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

func (*UnregisterLogStreamResponse) ProtoMessage

func (*UnregisterLogStreamResponse) ProtoMessage()

func (*UnregisterLogStreamResponse) ProtoSize

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

func (*UnregisterLogStreamResponse) Reset

func (m *UnregisterLogStreamResponse) Reset()

func (*UnregisterLogStreamResponse) String

func (m *UnregisterLogStreamResponse) String() string

func (*UnregisterLogStreamResponse) Unmarshal

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

func (*UnregisterLogStreamResponse) XXX_DiscardUnknown

func (m *UnregisterLogStreamResponse) XXX_DiscardUnknown()

func (*UnregisterLogStreamResponse) XXX_Marshal

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

func (*UnregisterLogStreamResponse) XXX_Merge

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

func (*UnregisterLogStreamResponse) XXX_Size

func (m *UnregisterLogStreamResponse) XXX_Size() int

func (*UnregisterLogStreamResponse) XXX_Unmarshal

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

type UnregisterStorageNodeRequest

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

func (*UnregisterStorageNodeRequest) Descriptor

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

func (*UnregisterStorageNodeRequest) GetStorageNodeID

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

func (*UnregisterStorageNodeRequest) Marshal

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

func (*UnregisterStorageNodeRequest) MarshalTo

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

func (*UnregisterStorageNodeRequest) MarshalToSizedBuffer

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

func (*UnregisterStorageNodeRequest) ProtoMessage

func (*UnregisterStorageNodeRequest) ProtoMessage()

func (*UnregisterStorageNodeRequest) ProtoSize

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

func (*UnregisterStorageNodeRequest) Reset

func (m *UnregisterStorageNodeRequest) Reset()

func (*UnregisterStorageNodeRequest) String

func (m *UnregisterStorageNodeRequest) String() string

func (*UnregisterStorageNodeRequest) Unmarshal

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

func (*UnregisterStorageNodeRequest) XXX_DiscardUnknown

func (m *UnregisterStorageNodeRequest) XXX_DiscardUnknown()

func (*UnregisterStorageNodeRequest) XXX_Marshal

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

func (*UnregisterStorageNodeRequest) XXX_Merge

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

func (*UnregisterStorageNodeRequest) XXX_Size

func (m *UnregisterStorageNodeRequest) XXX_Size() int

func (*UnregisterStorageNodeRequest) XXX_Unmarshal

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

type UnregisterStorageNodeResponse

type UnregisterStorageNodeResponse struct {
}

func (*UnregisterStorageNodeResponse) Descriptor

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

func (*UnregisterStorageNodeResponse) Marshal

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

func (*UnregisterStorageNodeResponse) MarshalTo

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

func (*UnregisterStorageNodeResponse) MarshalToSizedBuffer

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

func (*UnregisterStorageNodeResponse) ProtoMessage

func (*UnregisterStorageNodeResponse) ProtoMessage()

func (*UnregisterStorageNodeResponse) ProtoSize

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

func (*UnregisterStorageNodeResponse) Reset

func (m *UnregisterStorageNodeResponse) Reset()

func (*UnregisterStorageNodeResponse) String

func (m *UnregisterStorageNodeResponse) String() string

func (*UnregisterStorageNodeResponse) Unmarshal

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

func (*UnregisterStorageNodeResponse) XXX_DiscardUnknown

func (m *UnregisterStorageNodeResponse) XXX_DiscardUnknown()

func (*UnregisterStorageNodeResponse) XXX_Marshal

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

func (*UnregisterStorageNodeResponse) XXX_Merge

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

func (*UnregisterStorageNodeResponse) XXX_Size

func (m *UnregisterStorageNodeResponse) XXX_Size() int

func (*UnregisterStorageNodeResponse) XXX_Unmarshal

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

type UnregisterTopicRequest

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

func (*UnregisterTopicRequest) Descriptor

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

func (*UnregisterTopicRequest) GetTopicID

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

func (*UnregisterTopicRequest) Marshal

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

func (*UnregisterTopicRequest) MarshalTo

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

func (*UnregisterTopicRequest) MarshalToSizedBuffer

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

func (*UnregisterTopicRequest) ProtoMessage

func (*UnregisterTopicRequest) ProtoMessage()

func (*UnregisterTopicRequest) ProtoSize

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

func (*UnregisterTopicRequest) Reset

func (m *UnregisterTopicRequest) Reset()

func (*UnregisterTopicRequest) String

func (m *UnregisterTopicRequest) String() string

func (*UnregisterTopicRequest) Unmarshal

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

func (*UnregisterTopicRequest) XXX_DiscardUnknown

func (m *UnregisterTopicRequest) XXX_DiscardUnknown()

func (*UnregisterTopicRequest) XXX_Marshal

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

func (*UnregisterTopicRequest) XXX_Merge

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

func (*UnregisterTopicRequest) XXX_Size

func (m *UnregisterTopicRequest) XXX_Size() int

func (*UnregisterTopicRequest) XXX_Unmarshal

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

type UnregisterTopicResponse

type UnregisterTopicResponse struct {
}

func (*UnregisterTopicResponse) Descriptor

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

func (*UnregisterTopicResponse) Marshal

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

func (*UnregisterTopicResponse) MarshalTo

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

func (*UnregisterTopicResponse) MarshalToSizedBuffer

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

func (*UnregisterTopicResponse) ProtoMessage

func (*UnregisterTopicResponse) ProtoMessage()

func (*UnregisterTopicResponse) ProtoSize

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

func (*UnregisterTopicResponse) Reset

func (m *UnregisterTopicResponse) Reset()

func (*UnregisterTopicResponse) String

func (m *UnregisterTopicResponse) String() string

func (*UnregisterTopicResponse) Unmarshal

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

func (*UnregisterTopicResponse) XXX_DiscardUnknown

func (m *UnregisterTopicResponse) XXX_DiscardUnknown()

func (*UnregisterTopicResponse) XXX_Marshal

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

func (*UnregisterTopicResponse) XXX_Merge

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

func (*UnregisterTopicResponse) XXX_Size

func (m *UnregisterTopicResponse) XXX_Size() int

func (*UnregisterTopicResponse) XXX_Unmarshal

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

type UnsealRequest

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

func (*UnsealRequest) Descriptor

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

func (*UnsealRequest) GetLogStreamID

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

func (*UnsealRequest) GetTopicID

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

func (*UnsealRequest) Marshal

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

func (*UnsealRequest) MarshalTo

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

func (*UnsealRequest) MarshalToSizedBuffer

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

func (*UnsealRequest) ProtoMessage

func (*UnsealRequest) ProtoMessage()

func (*UnsealRequest) ProtoSize

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

func (*UnsealRequest) Reset

func (m *UnsealRequest) Reset()

func (*UnsealRequest) String

func (m *UnsealRequest) String() string

func (*UnsealRequest) Unmarshal

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

func (*UnsealRequest) XXX_DiscardUnknown

func (m *UnsealRequest) XXX_DiscardUnknown()

func (*UnsealRequest) XXX_Marshal

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

func (*UnsealRequest) XXX_Merge

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

func (*UnsealRequest) XXX_Size

func (m *UnsealRequest) XXX_Size() int

func (*UnsealRequest) XXX_Unmarshal

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

type UnsealResponse

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

func (*UnsealResponse) Descriptor

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

func (*UnsealResponse) GetLogStream

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

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 UpdateLogStreamRequest

type UpdateLogStreamRequest struct {
	TopicID     github_com_kakao_varlog_pkg_types.TopicID     `` /* 134-byte string literal not displayed */
	LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID `` /* 152-byte string literal not displayed */
	//
	//// NOTE: popped_replica need not be varlog.ReplicaDescriptor, but it is
	//// natural. Though it is awkward, popped_storage_node_id is used here.
	//uint32 popped_storage_node_id = 2 [
	//(gogoproto.casttype) =
	//"github.com/kakao/varlog/pkg/types.StorageNodeID",
	//(gogoproto.customname) = "PoppedStorageNodeID"
	//];
	PoppedReplica *varlogpb.ReplicaDescriptor `protobuf:"bytes,3,opt,name=popped_replica,json=poppedReplica,proto3" json:"popped_replica,omitempty"`
	PushedReplica *varlogpb.ReplicaDescriptor `protobuf:"bytes,4,opt,name=pushed_replica,json=pushedReplica,proto3" json:"pushed_replica,omitempty"`
}

func (*UpdateLogStreamRequest) Descriptor

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

func (*UpdateLogStreamRequest) GetLogStreamID

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

func (*UpdateLogStreamRequest) GetPoppedReplica

func (m *UpdateLogStreamRequest) GetPoppedReplica() *varlogpb.ReplicaDescriptor

func (*UpdateLogStreamRequest) GetPushedReplica

func (m *UpdateLogStreamRequest) GetPushedReplica() *varlogpb.ReplicaDescriptor

func (*UpdateLogStreamRequest) GetTopicID

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

func (*UpdateLogStreamRequest) Marshal

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

func (*UpdateLogStreamRequest) MarshalTo

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

func (*UpdateLogStreamRequest) MarshalToSizedBuffer

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

func (*UpdateLogStreamRequest) ProtoMessage

func (*UpdateLogStreamRequest) ProtoMessage()

func (*UpdateLogStreamRequest) ProtoSize

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

func (*UpdateLogStreamRequest) Reset

func (m *UpdateLogStreamRequest) Reset()

func (*UpdateLogStreamRequest) String

func (m *UpdateLogStreamRequest) String() string

func (*UpdateLogStreamRequest) Unmarshal

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

func (*UpdateLogStreamRequest) XXX_DiscardUnknown

func (m *UpdateLogStreamRequest) XXX_DiscardUnknown()

func (*UpdateLogStreamRequest) XXX_Marshal

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

func (*UpdateLogStreamRequest) XXX_Merge

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

func (*UpdateLogStreamRequest) XXX_Size

func (m *UpdateLogStreamRequest) XXX_Size() int

func (*UpdateLogStreamRequest) XXX_Unmarshal

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

type UpdateLogStreamResponse

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

func (*UpdateLogStreamResponse) Descriptor

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

func (*UpdateLogStreamResponse) GetLogStream

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

func (*UpdateLogStreamResponse) Marshal

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

func (*UpdateLogStreamResponse) MarshalTo

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

func (*UpdateLogStreamResponse) MarshalToSizedBuffer

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

func (*UpdateLogStreamResponse) ProtoMessage

func (*UpdateLogStreamResponse) ProtoMessage()

func (*UpdateLogStreamResponse) ProtoSize

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

func (*UpdateLogStreamResponse) Reset

func (m *UpdateLogStreamResponse) Reset()

func (*UpdateLogStreamResponse) String

func (m *UpdateLogStreamResponse) String() string

func (*UpdateLogStreamResponse) Unmarshal

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

func (*UpdateLogStreamResponse) XXX_DiscardUnknown

func (m *UpdateLogStreamResponse) XXX_DiscardUnknown()

func (*UpdateLogStreamResponse) XXX_Marshal

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

func (*UpdateLogStreamResponse) XXX_Merge

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

func (*UpdateLogStreamResponse) XXX_Size

func (m *UpdateLogStreamResponse) XXX_Size() int

func (*UpdateLogStreamResponse) XXX_Unmarshal

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