Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

admpb

package

Go to main page

Versions in this module

v0

v0.20.0

Mar 5, 2024

v0.19.2

Feb 14, 2024

v0.19.1

Feb 1, 2024

v0.19.0

Jan 2, 2024

v0.18.1

Oct 17, 2023

v0.18.0

Oct 10, 2023

v0.17.0

Oct 10, 2023

v0.16.0

Oct 4, 2023

v0.15.0

Aug 7, 2023

v0.14.1

Jun 20, 2023

v0.14.0

Jun 19, 2023

v0.13.0

Jun 1, 2023

v0.12.0

Apr 6, 2023

v0.11.0

Feb 21, 2023

Changes in this version

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

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

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

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

+ type AddLogStreamRequest struct

+ Replicas []*varlogpb.ReplicaDescriptor

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

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

+ func (*AddLogStreamRequest) ProtoMessage()

+ 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 (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 struct

+ LogStream *varlogpb.LogStreamDescriptor

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

+ func (*AddLogStreamResponse) ProtoMessage()

+ 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 (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 struct

+ RPCAddr string

+ RaftURL string

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

+ func (*AddMRPeerRequest) ProtoMessage()

+ 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 (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 struct

+ NodeID github_com_kakao_varlog_pkg_types.NodeID

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

+ func (*AddMRPeerResponse) ProtoMessage()

+ 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 (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 struct

+ RPCAddr string

+ RaftURL string

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

+ func (*AddMetadataRepositoryNodeRequest) ProtoMessage()

+ 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 (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 struct

+ Node *varlogpb.MetadataRepositoryNode

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

+ func (*AddMetadataRepositoryNodeResponse) ProtoMessage()

+ 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 (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 struct

+ StorageNode varlogpb.StorageNode

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

+ func (*AddStorageNodeRequest) ProtoMessage()

+ 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 (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 struct

+ StorageNode *StorageNodeMetadata

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

+ func (*AddStorageNodeResponse) ProtoMessage()

+ 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 (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 struct

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

+ func (*AddTopicRequest) ProtoMessage()

+ 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 (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 struct

+ Topic *varlogpb.TopicDescriptor

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

+ func (*AddTopicResponse) ProtoMessage()

+ 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 (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 interface

+ AddLogStream func(ctx context.Context, in *AddLogStreamRequest, opts ...grpc.CallOption) (*AddLogStreamResponse, error)

+ AddMRPeer func(ctx context.Context, in *AddMRPeerRequest, opts ...grpc.CallOption) (*AddMRPeerResponse, error)

+ AddMetadataRepositoryNode func(ctx context.Context, in *AddMetadataRepositoryNodeRequest, ...) (*AddMetadataRepositoryNodeResponse, error)

+ AddStorageNode func(ctx context.Context, in *AddStorageNodeRequest, opts ...grpc.CallOption) (*AddStorageNodeResponse, error)

+ AddTopic func(ctx context.Context, in *AddTopicRequest, opts ...grpc.CallOption) (*AddTopicResponse, error)

+ DeleteMetadataRepositoryNode func(ctx context.Context, in *DeleteMetadataRepositoryNodeRequest, ...) (*DeleteMetadataRepositoryNodeResponse, error)

+ DescribeTopic func(ctx context.Context, in *DescribeTopicRequest, opts ...grpc.CallOption) (*DescribeTopicResponse, error)

+ GetLogStream func(ctx context.Context, in *GetLogStreamRequest, opts ...grpc.CallOption) (*GetLogStreamResponse, error)

+ GetMRMembers func(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*GetMRMembersResponse, error)

+ GetMetadataRepositoryNode func(ctx context.Context, in *GetMetadataRepositoryNodeRequest, ...) (*GetMetadataRepositoryNodeResponse, error)

+ GetStorageNode func(ctx context.Context, in *GetStorageNodeRequest, opts ...grpc.CallOption) (*GetStorageNodeResponse, error)

+ GetTopic func(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*GetTopicResponse, error)

+ ListLogStreams func(ctx context.Context, in *ListLogStreamsRequest, opts ...grpc.CallOption) (*ListLogStreamsResponse, error)

+ ListMetadataRepositoryNodes func(ctx context.Context, in *ListMetadataRepositoryNodesRequest, ...) (*ListMetadataRepositoryNodesResponse, error)

+ ListStorageNodes func(ctx context.Context, in *ListStorageNodesRequest, opts ...grpc.CallOption) (*ListStorageNodesResponse, error)

+ ListTopics func(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error)

+ RemoveLogStreamReplica func(ctx context.Context, in *RemoveLogStreamReplicaRequest, ...) (*RemoveLogStreamReplicaResponse, error)

+ RemoveMRPeer func(ctx context.Context, in *RemoveMRPeerRequest, opts ...grpc.CallOption) (*RemoveMRPeerResponse, error)

+ Seal func(ctx context.Context, in *SealRequest, opts ...grpc.CallOption) (*SealResponse, error)

+ Sync func(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error)

+ Trim func(ctx context.Context, in *TrimRequest, opts ...grpc.CallOption) (*TrimResponse, error)

+ UnregisterLogStream func(ctx context.Context, in *UnregisterLogStreamRequest, opts ...grpc.CallOption) (*UnregisterLogStreamResponse, error)

+ UnregisterStorageNode func(ctx context.Context, in *UnregisterStorageNodeRequest, opts ...grpc.CallOption) (*UnregisterStorageNodeResponse, error)

+ UnregisterTopic func(ctx context.Context, in *UnregisterTopicRequest, opts ...grpc.CallOption) (*UnregisterTopicResponse, error)

+ Unseal func(ctx context.Context, in *UnsealRequest, opts ...grpc.CallOption) (*UnsealResponse, error)

+ UpdateLogStream func(ctx context.Context, in *UpdateLogStreamRequest, opts ...grpc.CallOption) (*UpdateLogStreamResponse, error)

+ func NewClusterManagerClient(cc *grpc.ClientConn) ClusterManagerClient

+ type ClusterManagerServer interface

+ AddLogStream func(context.Context, *AddLogStreamRequest) (*AddLogStreamResponse, error)

+ AddMRPeer func(context.Context, *AddMRPeerRequest) (*AddMRPeerResponse, error)

+ AddMetadataRepositoryNode func(context.Context, *AddMetadataRepositoryNodeRequest) (*AddMetadataRepositoryNodeResponse, error)

+ AddStorageNode func(context.Context, *AddStorageNodeRequest) (*AddStorageNodeResponse, error)

+ AddTopic func(context.Context, *AddTopicRequest) (*AddTopicResponse, error)

+ DeleteMetadataRepositoryNode func(context.Context, *DeleteMetadataRepositoryNodeRequest) (*DeleteMetadataRepositoryNodeResponse, error)

+ DescribeTopic func(context.Context, *DescribeTopicRequest) (*DescribeTopicResponse, error)

+ GetLogStream func(context.Context, *GetLogStreamRequest) (*GetLogStreamResponse, error)

+ GetMRMembers func(context.Context, *types.Empty) (*GetMRMembersResponse, error)

+ GetMetadataRepositoryNode func(context.Context, *GetMetadataRepositoryNodeRequest) (*GetMetadataRepositoryNodeResponse, error)

+ GetStorageNode func(context.Context, *GetStorageNodeRequest) (*GetStorageNodeResponse, error)

+ GetTopic func(context.Context, *GetTopicRequest) (*GetTopicResponse, error)

+ ListLogStreams func(context.Context, *ListLogStreamsRequest) (*ListLogStreamsResponse, error)

+ ListMetadataRepositoryNodes func(context.Context, *ListMetadataRepositoryNodesRequest) (*ListMetadataRepositoryNodesResponse, error)

+ ListStorageNodes func(context.Context, *ListStorageNodesRequest) (*ListStorageNodesResponse, error)

+ ListTopics func(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)

+ RemoveLogStreamReplica func(context.Context, *RemoveLogStreamReplicaRequest) (*RemoveLogStreamReplicaResponse, error)

+ RemoveMRPeer func(context.Context, *RemoveMRPeerRequest) (*RemoveMRPeerResponse, error)

+ Seal func(context.Context, *SealRequest) (*SealResponse, error)

+ Sync func(context.Context, *SyncRequest) (*SyncResponse, error)

+ Trim func(context.Context, *TrimRequest) (*TrimResponse, error)

+ UnregisterLogStream func(context.Context, *UnregisterLogStreamRequest) (*UnregisterLogStreamResponse, error)

+ UnregisterStorageNode func(context.Context, *UnregisterStorageNodeRequest) (*UnregisterStorageNodeResponse, error)

+ UnregisterTopic func(context.Context, *UnregisterTopicRequest) (*UnregisterTopicResponse, error)

+ Unseal func(context.Context, *UnsealRequest) (*UnsealResponse, error)

+ UpdateLogStream func(context.Context, *UpdateLogStreamRequest) (*UpdateLogStreamResponse, error)

+ type DeleteMetadataRepositoryNodeRequest struct

+ NodeID github_com_kakao_varlog_pkg_types.NodeID

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

+ func (*DeleteMetadataRepositoryNodeRequest) ProtoMessage()

+ 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 (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 struct

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

+ func (*DeleteMetadataRepositoryNodeResponse) ProtoMessage()

+ 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 (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 struct

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

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

+ func (*DescribeTopicRequest) ProtoMessage()

+ 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 (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 struct

+ LogStreams []varlogpb.LogStreamDescriptor

+ Topic varlogpb.TopicDescriptor

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

+ func (*DescribeTopicResponse) ProtoMessage()

+ 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 (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 struct

+ LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

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

+ func (*GetLogStreamRequest) ProtoMessage()

+ 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 (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 struct

+ LogStream *varlogpb.LogStreamDescriptor

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

+ func (*GetLogStreamResponse) ProtoMessage()

+ 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 (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 struct

+ Leader github_com_kakao_varlog_pkg_types.NodeID

+ Members map[github_com_kakao_varlog_pkg_types.NodeID]string

+ ReplicationFactor int32

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

+ func (*GetMRMembersResponse) ProtoMessage()

+ 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 (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 struct

+ NodeID github_com_kakao_varlog_pkg_types.NodeID

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

+ func (*GetMetadataRepositoryNodeRequest) ProtoMessage()

+ 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 (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 struct

+ Node *varlogpb.MetadataRepositoryNode

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

+ func (*GetMetadataRepositoryNodeResponse) ProtoMessage()

+ 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 (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 struct

+ StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID

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

+ func (*GetStorageNodeRequest) ProtoMessage()

+ 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 (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 struct

+ StorageNode *StorageNodeMetadata

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

+ func (*GetStorageNodeResponse) ProtoMessage()

+ 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 (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 struct

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

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

+ func (*GetTopicRequest) ProtoMessage()

+ 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 (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 struct

+ Topic *varlogpb.TopicDescriptor

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

+ func (*GetTopicResponse) ProtoMessage()

+ 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 (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 struct

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

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

+ func (*ListLogStreamsRequest) ProtoMessage()

+ 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 (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 struct

+ LogStreams []varlogpb.LogStreamDescriptor

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

+ func (*ListLogStreamsResponse) ProtoMessage()

+ 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 (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 struct

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

+ func (*ListMetadataRepositoryNodesRequest) ProtoMessage()

+ 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 (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 struct

+ Nodes []varlogpb.MetadataRepositoryNode

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

+ func (*ListMetadataRepositoryNodesResponse) ProtoMessage()

+ 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 (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 struct

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

+ func (*ListStorageNodesRequest) ProtoMessage()

+ 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 (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 struct

+ StorageNodes []StorageNodeMetadata

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

+ func (*ListStorageNodesResponse) ProtoMessage()

+ 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 (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 struct

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

+ func (*ListTopicsRequest) ProtoMessage()

+ 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 (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 struct

+ Topics []varlogpb.TopicDescriptor

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

+ func (*ListTopicsResponse) ProtoMessage()

+ 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 (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 MockClusterManagerClient struct

+ func NewMockClusterManagerClient(ctrl *gomock.Controller) *MockClusterManagerClient

+ func (m *MockClusterManagerClient) AddLogStream(arg0 context.Context, arg1 *AddLogStreamRequest, arg2 ...grpc.CallOption) (*AddLogStreamResponse, error)

+ func (m *MockClusterManagerClient) AddMRPeer(arg0 context.Context, arg1 *AddMRPeerRequest, arg2 ...grpc.CallOption) (*AddMRPeerResponse, error)

+ func (m *MockClusterManagerClient) AddMetadataRepositoryNode(arg0 context.Context, arg1 *AddMetadataRepositoryNodeRequest, ...) (*AddMetadataRepositoryNodeResponse, error)

+ func (m *MockClusterManagerClient) AddStorageNode(arg0 context.Context, arg1 *AddStorageNodeRequest, arg2 ...grpc.CallOption) (*AddStorageNodeResponse, error)

+ func (m *MockClusterManagerClient) AddTopic(arg0 context.Context, arg1 *AddTopicRequest, arg2 ...grpc.CallOption) (*AddTopicResponse, error)

+ func (m *MockClusterManagerClient) DeleteMetadataRepositoryNode(arg0 context.Context, arg1 *DeleteMetadataRepositoryNodeRequest, ...) (*DeleteMetadataRepositoryNodeResponse, error)

+ func (m *MockClusterManagerClient) DescribeTopic(arg0 context.Context, arg1 *DescribeTopicRequest, arg2 ...grpc.CallOption) (*DescribeTopicResponse, error)

+ func (m *MockClusterManagerClient) EXPECT() *MockClusterManagerClientMockRecorder

+ func (m *MockClusterManagerClient) GetLogStream(arg0 context.Context, arg1 *GetLogStreamRequest, arg2 ...grpc.CallOption) (*GetLogStreamResponse, error)

+ func (m *MockClusterManagerClient) GetMRMembers(arg0 context.Context, arg1 *types.Empty, arg2 ...grpc.CallOption) (*GetMRMembersResponse, error)

+ func (m *MockClusterManagerClient) GetMetadataRepositoryNode(arg0 context.Context, arg1 *GetMetadataRepositoryNodeRequest, ...) (*GetMetadataRepositoryNodeResponse, error)

+ func (m *MockClusterManagerClient) GetStorageNode(arg0 context.Context, arg1 *GetStorageNodeRequest, arg2 ...grpc.CallOption) (*GetStorageNodeResponse, error)

+ func (m *MockClusterManagerClient) GetTopic(arg0 context.Context, arg1 *GetTopicRequest, arg2 ...grpc.CallOption) (*GetTopicResponse, error)

+ func (m *MockClusterManagerClient) ListLogStreams(arg0 context.Context, arg1 *ListLogStreamsRequest, arg2 ...grpc.CallOption) (*ListLogStreamsResponse, error)

+ func (m *MockClusterManagerClient) ListMetadataRepositoryNodes(arg0 context.Context, arg1 *ListMetadataRepositoryNodesRequest, ...) (*ListMetadataRepositoryNodesResponse, error)

+ func (m *MockClusterManagerClient) ListStorageNodes(arg0 context.Context, arg1 *ListStorageNodesRequest, arg2 ...grpc.CallOption) (*ListStorageNodesResponse, error)

+ func (m *MockClusterManagerClient) ListTopics(arg0 context.Context, arg1 *ListTopicsRequest, arg2 ...grpc.CallOption) (*ListTopicsResponse, error)

+ func (m *MockClusterManagerClient) RemoveLogStreamReplica(arg0 context.Context, arg1 *RemoveLogStreamReplicaRequest, ...) (*RemoveLogStreamReplicaResponse, error)

+ func (m *MockClusterManagerClient) RemoveMRPeer(arg0 context.Context, arg1 *RemoveMRPeerRequest, arg2 ...grpc.CallOption) (*RemoveMRPeerResponse, error)

+ func (m *MockClusterManagerClient) Seal(arg0 context.Context, arg1 *SealRequest, arg2 ...grpc.CallOption) (*SealResponse, error)

+ func (m *MockClusterManagerClient) Sync(arg0 context.Context, arg1 *SyncRequest, arg2 ...grpc.CallOption) (*SyncResponse, error)

+ func (m *MockClusterManagerClient) Trim(arg0 context.Context, arg1 *TrimRequest, arg2 ...grpc.CallOption) (*TrimResponse, error)

+ func (m *MockClusterManagerClient) UnregisterLogStream(arg0 context.Context, arg1 *UnregisterLogStreamRequest, ...) (*UnregisterLogStreamResponse, error)

+ func (m *MockClusterManagerClient) UnregisterStorageNode(arg0 context.Context, arg1 *UnregisterStorageNodeRequest, ...) (*UnregisterStorageNodeResponse, error)

+ func (m *MockClusterManagerClient) UnregisterTopic(arg0 context.Context, arg1 *UnregisterTopicRequest, arg2 ...grpc.CallOption) (*UnregisterTopicResponse, error)

+ func (m *MockClusterManagerClient) Unseal(arg0 context.Context, arg1 *UnsealRequest, arg2 ...grpc.CallOption) (*UnsealResponse, error)

+ func (m *MockClusterManagerClient) UpdateLogStream(arg0 context.Context, arg1 *UpdateLogStreamRequest, arg2 ...grpc.CallOption) (*UpdateLogStreamResponse, error)

+ type MockClusterManagerClientMockRecorder struct

+ func (mr *MockClusterManagerClientMockRecorder) AddLogStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) AddMRPeer(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) AddMetadataRepositoryNode(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) AddStorageNode(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) AddTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) DeleteMetadataRepositoryNode(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) DescribeTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) GetLogStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) GetMRMembers(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) GetMetadataRepositoryNode(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) GetStorageNode(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) GetTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) ListLogStreams(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) ListMetadataRepositoryNodes(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) ListStorageNodes(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) ListTopics(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) RemoveLogStreamReplica(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) RemoveMRPeer(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) Seal(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) Sync(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) Trim(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) UnregisterLogStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) UnregisterStorageNode(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) UnregisterTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) Unseal(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockClusterManagerClientMockRecorder) UpdateLogStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ type MockClusterManagerServer struct

+ func NewMockClusterManagerServer(ctrl *gomock.Controller) *MockClusterManagerServer

+ func (m *MockClusterManagerServer) AddLogStream(arg0 context.Context, arg1 *AddLogStreamRequest) (*AddLogStreamResponse, error)

+ func (m *MockClusterManagerServer) AddMRPeer(arg0 context.Context, arg1 *AddMRPeerRequest) (*AddMRPeerResponse, error)

+ func (m *MockClusterManagerServer) AddMetadataRepositoryNode(arg0 context.Context, arg1 *AddMetadataRepositoryNodeRequest) (*AddMetadataRepositoryNodeResponse, error)

+ func (m *MockClusterManagerServer) AddStorageNode(arg0 context.Context, arg1 *AddStorageNodeRequest) (*AddStorageNodeResponse, error)

+ func (m *MockClusterManagerServer) AddTopic(arg0 context.Context, arg1 *AddTopicRequest) (*AddTopicResponse, error)

+ func (m *MockClusterManagerServer) DeleteMetadataRepositoryNode(arg0 context.Context, arg1 *DeleteMetadataRepositoryNodeRequest) (*DeleteMetadataRepositoryNodeResponse, error)

+ func (m *MockClusterManagerServer) DescribeTopic(arg0 context.Context, arg1 *DescribeTopicRequest) (*DescribeTopicResponse, error)

+ func (m *MockClusterManagerServer) EXPECT() *MockClusterManagerServerMockRecorder

+ func (m *MockClusterManagerServer) GetLogStream(arg0 context.Context, arg1 *GetLogStreamRequest) (*GetLogStreamResponse, error)

+ func (m *MockClusterManagerServer) GetMRMembers(arg0 context.Context, arg1 *types.Empty) (*GetMRMembersResponse, error)

+ func (m *MockClusterManagerServer) GetMetadataRepositoryNode(arg0 context.Context, arg1 *GetMetadataRepositoryNodeRequest) (*GetMetadataRepositoryNodeResponse, error)

+ func (m *MockClusterManagerServer) GetStorageNode(arg0 context.Context, arg1 *GetStorageNodeRequest) (*GetStorageNodeResponse, error)

+ func (m *MockClusterManagerServer) GetTopic(arg0 context.Context, arg1 *GetTopicRequest) (*GetTopicResponse, error)

+ func (m *MockClusterManagerServer) ListLogStreams(arg0 context.Context, arg1 *ListLogStreamsRequest) (*ListLogStreamsResponse, error)

+ func (m *MockClusterManagerServer) ListMetadataRepositoryNodes(arg0 context.Context, arg1 *ListMetadataRepositoryNodesRequest) (*ListMetadataRepositoryNodesResponse, error)

+ func (m *MockClusterManagerServer) ListStorageNodes(arg0 context.Context, arg1 *ListStorageNodesRequest) (*ListStorageNodesResponse, error)

+ func (m *MockClusterManagerServer) ListTopics(arg0 context.Context, arg1 *ListTopicsRequest) (*ListTopicsResponse, error)

+ func (m *MockClusterManagerServer) RemoveLogStreamReplica(arg0 context.Context, arg1 *RemoveLogStreamReplicaRequest) (*RemoveLogStreamReplicaResponse, error)

+ func (m *MockClusterManagerServer) RemoveMRPeer(arg0 context.Context, arg1 *RemoveMRPeerRequest) (*RemoveMRPeerResponse, error)

+ func (m *MockClusterManagerServer) Seal(arg0 context.Context, arg1 *SealRequest) (*SealResponse, error)

+ func (m *MockClusterManagerServer) Sync(arg0 context.Context, arg1 *SyncRequest) (*SyncResponse, error)

+ func (m *MockClusterManagerServer) Trim(arg0 context.Context, arg1 *TrimRequest) (*TrimResponse, error)

+ func (m *MockClusterManagerServer) UnregisterLogStream(arg0 context.Context, arg1 *UnregisterLogStreamRequest) (*UnregisterLogStreamResponse, error)

+ func (m *MockClusterManagerServer) UnregisterStorageNode(arg0 context.Context, arg1 *UnregisterStorageNodeRequest) (*UnregisterStorageNodeResponse, error)

+ func (m *MockClusterManagerServer) UnregisterTopic(arg0 context.Context, arg1 *UnregisterTopicRequest) (*UnregisterTopicResponse, error)

+ func (m *MockClusterManagerServer) Unseal(arg0 context.Context, arg1 *UnsealRequest) (*UnsealResponse, error)

+ func (m *MockClusterManagerServer) UpdateLogStream(arg0 context.Context, arg1 *UpdateLogStreamRequest) (*UpdateLogStreamResponse, error)

+ type MockClusterManagerServerMockRecorder struct

+ func (mr *MockClusterManagerServerMockRecorder) AddLogStream(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) AddMRPeer(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) AddMetadataRepositoryNode(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) AddStorageNode(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) AddTopic(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) DeleteMetadataRepositoryNode(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) DescribeTopic(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) GetLogStream(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) GetMRMembers(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) GetMetadataRepositoryNode(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) GetStorageNode(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) GetTopic(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) ListLogStreams(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) ListMetadataRepositoryNodes(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) ListStorageNodes(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) ListTopics(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) RemoveLogStreamReplica(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) RemoveMRPeer(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) Seal(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) Sync(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) Trim(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) UnregisterLogStream(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) UnregisterStorageNode(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) UnregisterTopic(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) Unseal(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockClusterManagerServerMockRecorder) UpdateLogStream(arg0, arg1 interface{}) *gomock.Call

+ type RemoveLogStreamReplicaRequest struct

+ LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID

+ StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

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

+ func (*RemoveLogStreamReplicaRequest) ProtoMessage()

+ 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 (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 struct

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

+ func (*RemoveLogStreamReplicaResponse) ProtoMessage()

+ 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 (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 struct

+ RaftURL string

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

+ func (*RemoveMRPeerRequest) ProtoMessage()

+ 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 (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 struct

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

+ func (*RemoveMRPeerResponse) ProtoMessage()

+ 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 (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 struct

+ LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

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

+ func (*SealRequest) ProtoMessage()

+ 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 (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 struct

+ LogStreams []snpb.LogStreamReplicaMetadataDescriptor

+ SealedGLSN github_com_kakao_varlog_pkg_types.GLSN

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

+ func (*SealResponse) ProtoMessage()

+ 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 (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 struct

+ CreateTime time.Time

+ LastHeartbeatTime time.Time

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

+ func (*StorageNodeMetadata) ProtoMessage()

+ 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 (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

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

+ type SyncRequest struct

+ DstStorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID

+ LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID

+ SrcStorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

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

+ func (*SyncRequest) ProtoMessage()

+ 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 (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 struct

+ Status *snpb.SyncStatus

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

+ func (*SyncResponse) ProtoMessage()

+ 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 (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 struct

+ LastGLSN github_com_kakao_varlog_pkg_types.GLSN

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

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

+ func (*TrimRequest) ProtoMessage()

+ 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 (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 struct

+ Results []TrimResult

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

+ func (*TrimResponse) ProtoMessage()

+ 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 (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 struct

+ Error string

+ LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID

+ StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID

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

+ func (*TrimResult) ProtoMessage()

+ 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 (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 struct

+ 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 struct

+ LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

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

+ func (*UnregisterLogStreamRequest) ProtoMessage()

+ 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 (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 struct

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

+ func (*UnregisterLogStreamResponse) ProtoMessage()

+ 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 (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 struct

+ StorageNodeID github_com_kakao_varlog_pkg_types.StorageNodeID

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

+ func (*UnregisterStorageNodeRequest) ProtoMessage()

+ 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 (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 struct

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

+ func (*UnregisterStorageNodeResponse) ProtoMessage()

+ 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 (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 struct

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

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

+ func (*UnregisterTopicRequest) ProtoMessage()

+ 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 (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 struct

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

+ func (*UnregisterTopicResponse) ProtoMessage()

+ 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 (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 struct

+ LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

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

+ func (*UnsealRequest) ProtoMessage()

+ 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 (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 struct

+ LogStream *varlogpb.LogStreamDescriptor

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

+ func (*UnsealResponse) ProtoMessage()

+ 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 (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 struct

+ LogStreamID github_com_kakao_varlog_pkg_types.LogStreamID

+ PoppedReplica varlogpb.ReplicaDescriptor

+ PushedReplica varlogpb.ReplicaDescriptor

+ TopicID github_com_kakao_varlog_pkg_types.TopicID

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

+ func (*UpdateLogStreamRequest) ProtoMessage()

+ 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 (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 struct

+ LogStream *varlogpb.LogStreamDescriptor

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

+ func (*UpdateLogStreamResponse) ProtoMessage()

+ 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 (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