vmspb

package
v0.3.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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 changes the configuration of replicas in a log stream.
	// Its codes are defines as followings:
	// - InvalidArgument: The client tries to swap the same replica.
	// - Unavailable: The cluster metadata cannot be fetched from the metadata
	// repository transiently.
	// - NotFound: The target log stream does not exist.
	// - FailedPrecondition: Either the target log stream is not sealed, the
	// target log stream doesn't have a victim replica, or the target log stream
	// already has both victim and new replica. Note that clients should not retry
	// without any action.
	// - Unknown: Either storage node or metadata repository returns an error.
	//
	// TODO: Moving the data directory within the same node is not supported yet.
	// TODO: We will define codes for errors returned from storage nodes and
	// metadata repository soon.
	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 changes the configuration of replicas in a log stream.
	// Its codes are defines as followings:
	// - InvalidArgument: The client tries to swap the same replica.
	// - Unavailable: The cluster metadata cannot be fetched from the metadata
	// repository transiently.
	// - NotFound: The target log stream does not exist.
	// - FailedPrecondition: Either the target log stream is not sealed, the
	// target log stream doesn't have a victim replica, or the target log stream
	// already has both victim and new replica. Note that clients should not retry
	// without any action.
	// - Unknown: Either storage node or metadata repository returns an error.
	//
	// TODO: Moving the data directory within the same node is not supported yet.
	// TODO: We will define codes for errors returned from storage nodes and
	// metadata repository soon.
	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 is the time when the storage node is created and registered to
	// the metadata repository.
	CreateTime time.Time `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3,stdtime" json:"createTime"`
	// LastHeartbeatTime is the time when the admin server checked the liveness of
	// the storage node. A zero value indicates that the admin server does not
	// check the storage node. Typically, since the storage node is just
	// registered, the admin server does not know the field. It is also possible
	// that the admin server is just restarted.
	LastHeartbeatTime time.Time `protobuf:"bytes,3,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3,stdtime" json:"lastHeartbeatTime"`
}

StorageNodeMetadata represents the current status of the storage node.

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"`
	PushedReplica varlogpb.ReplicaDescriptor `protobuf:"bytes,4,opt,name=pushed_replica,json=pushedReplica,proto3" json:"pushed_replica"`
}

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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