apipb

package
v0.0.0-...-16dfdc2 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2018 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package apipb is a generated protocol buffer package.

It is generated from these files: 

rpc.proto

It has these top-level messages: 

RateListRequest
RateListResponse
RateUpdateRequest
RateUpdateResponse
SnapshotRequeest
SnapshotResponse
DebugSwitchRequest
DebugSwitchResponse
DeleteFileRequest
GetDeletePermissionReq
GetDeletePermissionResp
SetDeletePermissionReq
SetDeletePermissionResp
DeleteFileResponse
LogStreamLeaderTransferRequeset
LogStreamLeaderTransferResponse
LogStreamStartRequest
LogStreamStartResponse
LogStreamStopRequest
LogStreamStopResponse
LogStreamDeleteRequest
LogStreamDeleteResponse
MemberAddRequest
MemberAddResponse
MemberRemoveRequest
MemberRemoveResponse
MemberUpdateRequest
MemberUpdateResponse
MemberListRequest
MemberListResponse
ResponseHeader
Member

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDevToolServer 

func RegisterDevToolServer(s *grpc.Server, srv DevToolServer)

func RegisterLogStreamAdminServer 

func RegisterLogStreamAdminServer(s *grpc.Server, srv LogStreamAdminServer)

func RegisterMembershipServer 

func RegisterMembershipServer(s *grpc.Server, srv MembershipServer)

func RegisterRateAdminServer 

func RegisterRateAdminServer(s *grpc.Server, srv RateAdminServer)

func RegisterSnapshotAdminServer 

func RegisterSnapshotAdminServer(s *grpc.Server, srv SnapshotAdminServer)

Types

type DebugSwitchRequest 

type DebugSwitchRequest struct {
	Switch uint64 `protobuf:"varint,1,opt,name=switch" json:"switch,omitempty"`
}

func (*DebugSwitchRequest) Descriptor 

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

func (*DebugSwitchRequest) GetSwitch 

func (m *DebugSwitchRequest) GetSwitch() uint64

func (*DebugSwitchRequest) ProtoMessage 

func (*DebugSwitchRequest) ProtoMessage()

func (*DebugSwitchRequest) Reset 

func (m *DebugSwitchRequest) Reset()

func (*DebugSwitchRequest) String 

func (m *DebugSwitchRequest) String() string

type DebugSwitchResponse 

type DebugSwitchResponse struct {
	ResultStatus string `protobuf:"bytes,1,opt,name=result_status,json=resultStatus" json:"result_status,omitempty"`
	ErrorMsg     string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg" json:"error_msg,omitempty"`
}

func (*DebugSwitchResponse) Descriptor 

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

func (*DebugSwitchResponse) GetErrorMsg 

func (m *DebugSwitchResponse) GetErrorMsg() string

func (*DebugSwitchResponse) GetResultStatus 

func (m *DebugSwitchResponse) GetResultStatus() string

func (*DebugSwitchResponse) ProtoMessage 

func (*DebugSwitchResponse) ProtoMessage()

func (*DebugSwitchResponse) Reset 

func (m *DebugSwitchResponse) Reset()

func (*DebugSwitchResponse) String 

func (m *DebugSwitchResponse) String() string

type DeleteFileRequest 

type DeleteFileRequest struct {
	LogstreamName string   `protobuf:"bytes,1,opt,name=logstream_name,json=logstreamName" json:"logstream_name,omitempty"`
	SegmentFiles  []string `protobuf:"bytes,2,rep,name=segment_files,json=segmentFiles" json:"segment_files,omitempty"`
}

func (*DeleteFileRequest) Descriptor 

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

func (*DeleteFileRequest) GetLogstreamName 

func (m *DeleteFileRequest) GetLogstreamName() string

func (*DeleteFileRequest) GetSegmentFiles 

func (m *DeleteFileRequest) GetSegmentFiles() []string

func (*DeleteFileRequest) ProtoMessage 

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) Reset 

func (m *DeleteFileRequest) Reset()

func (*DeleteFileRequest) String 

func (m *DeleteFileRequest) String() string

type DeleteFileResponse 

type DeleteFileResponse struct {
	ResultStatus string `protobuf:"bytes,1,opt,name=result_status,json=resultStatus" json:"result_status,omitempty"`
	ErrorMsg     string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg" json:"error_msg,omitempty"`
}

func (*DeleteFileResponse) Descriptor 

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

func (*DeleteFileResponse) GetErrorMsg 

func (m *DeleteFileResponse) GetErrorMsg() string

func (*DeleteFileResponse) GetResultStatus 

func (m *DeleteFileResponse) GetResultStatus() string

func (*DeleteFileResponse) ProtoMessage 

func (*DeleteFileResponse) ProtoMessage()

func (*DeleteFileResponse) Reset 

func (m *DeleteFileResponse) Reset()

func (*DeleteFileResponse) String 

func (m *DeleteFileResponse) String() string

type DevToolClient 

type DevToolClient interface {
	// Enable or Disable debug
	DebugSwitch(ctx context.Context, in *DebugSwitchRequest, opts ...grpc.CallOption) (*DebugSwitchResponse, error)
}

func NewDevToolClient 

func NewDevToolClient(cc *grpc.ClientConn) DevToolClient

type DevToolServer 

type DevToolServer interface {
	// Enable or Disable debug
	DebugSwitch(context.Context, *DebugSwitchRequest) (*DebugSwitchResponse, error)
}

type GetDeletePermissionReq 

type GetDeletePermissionReq struct {
	LogstreamName string `protobuf:"bytes,1,opt,name=logstream_name,json=logstreamName" json:"logstream_name,omitempty"`
}

func (*GetDeletePermissionReq) Descriptor 

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

func (*GetDeletePermissionReq) GetLogstreamName 

func (m *GetDeletePermissionReq) GetLogstreamName() string

func (*GetDeletePermissionReq) ProtoMessage 

func (*GetDeletePermissionReq) ProtoMessage()

func (*GetDeletePermissionReq) Reset 

func (m *GetDeletePermissionReq) Reset()

func (*GetDeletePermissionReq) String 

func (m *GetDeletePermissionReq) String() string

type GetDeletePermissionResp 

type GetDeletePermissionResp struct {
	ResultStatus string `protobuf:"bytes,1,opt,name=result_status,json=resultStatus" json:"result_status,omitempty"`
}

func (*GetDeletePermissionResp) Descriptor 

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

func (*GetDeletePermissionResp) GetResultStatus 

func (m *GetDeletePermissionResp) GetResultStatus() string

func (*GetDeletePermissionResp) ProtoMessage 

func (*GetDeletePermissionResp) ProtoMessage()

func (*GetDeletePermissionResp) Reset 

func (m *GetDeletePermissionResp) Reset()

func (*GetDeletePermissionResp) String 

func (m *GetDeletePermissionResp) String() string

type LogStreamAdminClient 

type LogStreamAdminClient interface {
	// Start a log stream.
	LogStreamStart(ctx context.Context, in *LogStreamStartRequest, opts ...grpc.CallOption) (*LogStreamStartResponse, error)
	// Stop a log stream.
	LogStreamStop(ctx context.Context, in *LogStreamStopRequest, opts ...grpc.CallOption) (*LogStreamStopResponse, error)
	// Delete a log stream.
	LogStreamDelete(ctx context.Context, in *LogStreamDeleteRequest, opts ...grpc.CallOption) (*LogStreamDeleteResponse, error)
	// Delete segment file in log stream.
	DeleteFile(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*DeleteFileResponse, error)
	// get delete segment file permission
	GetDeletePermission(ctx context.Context, in *GetDeletePermissionReq, opts ...grpc.CallOption) (*GetDeletePermissionResp, error)
	// set delete segment file permission
	SetDeletePermission(ctx context.Context, in *SetDeletePermissionReq, opts ...grpc.CallOption) (*SetDeletePermissionResp, error)
	// leade tranfser
	LeaderTransfer(ctx context.Context, in *LogStreamLeaderTransferRequeset, opts ...grpc.CallOption) (*LogStreamLeaderTransferResponse, error)
}

func NewLogStreamAdminClient 

func NewLogStreamAdminClient(cc *grpc.ClientConn) LogStreamAdminClient

type LogStreamAdminServer 

type LogStreamAdminServer interface {
	// Start a log stream.
	LogStreamStart(context.Context, *LogStreamStartRequest) (*LogStreamStartResponse, error)
	// Stop a log stream.
	LogStreamStop(context.Context, *LogStreamStopRequest) (*LogStreamStopResponse, error)
	// Delete a log stream.
	LogStreamDelete(context.Context, *LogStreamDeleteRequest) (*LogStreamDeleteResponse, error)
	// Delete segment file in log stream.
	DeleteFile(context.Context, *DeleteFileRequest) (*DeleteFileResponse, error)
	// get delete segment file permission
	GetDeletePermission(context.Context, *GetDeletePermissionReq) (*GetDeletePermissionResp, error)
	// set delete segment file permission
	SetDeletePermission(context.Context, *SetDeletePermissionReq) (*SetDeletePermissionResp, error)
	// leade tranfser
	LeaderTransfer(context.Context, *LogStreamLeaderTransferRequeset) (*LogStreamLeaderTransferResponse, error)
}

type LogStreamDeleteRequest 

type LogStreamDeleteRequest struct {
	// which raft group member to delete
	LogstreamName string `protobuf:"bytes,1,opt,name=logstream_name,json=logstreamName" json:"logstream_name,omitempty"`
}

func (*LogStreamDeleteRequest) Descriptor 

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

func (*LogStreamDeleteRequest) GetLogstreamName 

func (m *LogStreamDeleteRequest) GetLogstreamName() string

func (*LogStreamDeleteRequest) ProtoMessage 

func (*LogStreamDeleteRequest) ProtoMessage()

func (*LogStreamDeleteRequest) Reset 

func (m *LogStreamDeleteRequest) Reset()

func (*LogStreamDeleteRequest) String 

func (m *LogStreamDeleteRequest) String() string

type LogStreamDeleteResponse 

type LogStreamDeleteResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*LogStreamDeleteResponse) Descriptor 

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

func (*LogStreamDeleteResponse) GetHeader 

func (m *LogStreamDeleteResponse) GetHeader() *ResponseHeader

func (*LogStreamDeleteResponse) ProtoMessage 

func (*LogStreamDeleteResponse) ProtoMessage()

func (*LogStreamDeleteResponse) Reset 

func (m *LogStreamDeleteResponse) Reset()

func (*LogStreamDeleteResponse) String 

func (m *LogStreamDeleteResponse) String() string

type LogStreamLeaderTransferRequeset 

type LogStreamLeaderTransferRequeset struct {
	LogstreamName string `protobuf:"bytes,1,opt,name=logstream_name,json=logstreamName" json:"logstream_name,omitempty"`
	// which transfer to
	Transferee uint64 `protobuf:"varint,2,opt,name=transferee" json:"transferee,omitempty"`
}

func (*LogStreamLeaderTransferRequeset) Descriptor 

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

func (*LogStreamLeaderTransferRequeset) GetLogstreamName 

func (m *LogStreamLeaderTransferRequeset) GetLogstreamName() string

func (*LogStreamLeaderTransferRequeset) GetTransferee 

func (m *LogStreamLeaderTransferRequeset) GetTransferee() uint64

func (*LogStreamLeaderTransferRequeset) ProtoMessage 

func (*LogStreamLeaderTransferRequeset) ProtoMessage()

func (*LogStreamLeaderTransferRequeset) Reset 

func (m *LogStreamLeaderTransferRequeset) Reset()

func (*LogStreamLeaderTransferRequeset) String 

func (m *LogStreamLeaderTransferRequeset) String() string

type LogStreamLeaderTransferResponse 

type LogStreamLeaderTransferResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*LogStreamLeaderTransferResponse) Descriptor 

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

func (*LogStreamLeaderTransferResponse) GetHeader 

func (m *LogStreamLeaderTransferResponse) GetHeader() *ResponseHeader

func (*LogStreamLeaderTransferResponse) ProtoMessage 

func (*LogStreamLeaderTransferResponse) ProtoMessage()

func (*LogStreamLeaderTransferResponse) Reset 

func (m *LogStreamLeaderTransferResponse) Reset()

func (*LogStreamLeaderTransferResponse) String 

func (m *LogStreamLeaderTransferResponse) String() string

type LogStreamStartRequest 

type LogStreamStartRequest struct {
	// which raft group member to start
	LogstreamName string `protobuf:"bytes,1,opt,name=logstream_name,json=logstreamName" json:"logstream_name,omitempty"`
}

func (*LogStreamStartRequest) Descriptor 

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

func (*LogStreamStartRequest) GetLogstreamName 

func (m *LogStreamStartRequest) GetLogstreamName() string

func (*LogStreamStartRequest) ProtoMessage 

func (*LogStreamStartRequest) ProtoMessage()

func (*LogStreamStartRequest) Reset 

func (m *LogStreamStartRequest) Reset()

func (*LogStreamStartRequest) String 

func (m *LogStreamStartRequest) String() string

type LogStreamStartResponse 

type LogStreamStartResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*LogStreamStartResponse) Descriptor 

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

func (*LogStreamStartResponse) GetHeader 

func (m *LogStreamStartResponse) GetHeader() *ResponseHeader

func (*LogStreamStartResponse) ProtoMessage 

func (*LogStreamStartResponse) ProtoMessage()

func (*LogStreamStartResponse) Reset 

func (m *LogStreamStartResponse) Reset()

func (*LogStreamStartResponse) String 

func (m *LogStreamStartResponse) String() string

type LogStreamStopRequest 

type LogStreamStopRequest struct {
	// which raft group member to stop
	LogstreamName string `protobuf:"bytes,1,opt,name=logstream_name,json=logstreamName" json:"logstream_name,omitempty"`
}

func (*LogStreamStopRequest) Descriptor 

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

func (*LogStreamStopRequest) GetLogstreamName 

func (m *LogStreamStopRequest) GetLogstreamName() string

func (*LogStreamStopRequest) ProtoMessage 

func (*LogStreamStopRequest) ProtoMessage()

func (*LogStreamStopRequest) Reset 

func (m *LogStreamStopRequest) Reset()

func (*LogStreamStopRequest) String 

func (m *LogStreamStopRequest) String() string

type LogStreamStopResponse 

type LogStreamStopResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*LogStreamStopResponse) Descriptor 

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

func (*LogStreamStopResponse) GetHeader 

func (m *LogStreamStopResponse) GetHeader() *ResponseHeader

func (*LogStreamStopResponse) ProtoMessage 

func (*LogStreamStopResponse) ProtoMessage()

func (*LogStreamStopResponse) Reset 

func (m *LogStreamStopResponse) Reset()

func (*LogStreamStopResponse) String 

func (m *LogStreamStopResponse) String() string

type Member 

type Member struct {
	// ID is the member ID for this member.
	ID uint64 `protobuf:"varint,1,opt,name=ID" json:"ID,omitempty"`
	// name is the human-readable name of the member. If the member is not started, the name will be an empty string.
	Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	// peerURLs is the list of URLs the member exposes to the cluster for communication.
	PeerURLs []string `protobuf:"bytes,3,rep,name=peerURLs" json:"peerURLs,omitempty"`
}

func (*Member) Descriptor 

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

func (*Member) GetID 

func (m *Member) GetID() uint64

func (*Member) GetName 

func (m *Member) GetName() string

func (*Member) GetPeerURLs 

func (m *Member) GetPeerURLs() []string

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) Reset 

func (m *Member) Reset()

func (*Member) String 

func (m *Member) String() string

type MemberAddRequest 

type MemberAddRequest struct {
	// which raft group member add to
	LogstreamName string `protobuf:"bytes,1,opt,name=logstream_name,json=logstreamName" json:"logstream_name,omitempty"`
	// which server will be add to
	ServerName string `protobuf:"bytes,2,opt,name=server_name,json=serverName" json:"server_name,omitempty"`
	// peerURLs is the list of URLs the added member will use to communicate with the cluster.
	PeerURLs []string `protobuf:"bytes,3,rep,name=peerURLs" json:"peerURLs,omitempty"`
}

func (*MemberAddRequest) Descriptor 

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

func (*MemberAddRequest) GetLogstreamName 

func (m *MemberAddRequest) GetLogstreamName() string

func (*MemberAddRequest) GetPeerURLs 

func (m *MemberAddRequest) GetPeerURLs() []string

func (*MemberAddRequest) GetServerName 

func (m *MemberAddRequest) GetServerName() string

func (*MemberAddRequest) ProtoMessage 

func (*MemberAddRequest) ProtoMessage()

func (*MemberAddRequest) Reset 

func (m *MemberAddRequest) Reset()

func (*MemberAddRequest) String 

func (m *MemberAddRequest) String() string

type MemberAddResponse 

type MemberAddResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// member is the member information for the added member.
	Member *Member `protobuf:"bytes,2,opt,name=member" json:"member,omitempty"`
	// members is a list of all members after adding the new member.
	Members []*Member `protobuf:"bytes,3,rep,name=members" json:"members,omitempty"`
}

func (*MemberAddResponse) Descriptor 

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

func (*MemberAddResponse) GetHeader 

func (m *MemberAddResponse) GetHeader() *ResponseHeader

func (*MemberAddResponse) GetMember 

func (m *MemberAddResponse) GetMember() *Member

func (*MemberAddResponse) GetMembers 

func (m *MemberAddResponse) GetMembers() []*Member

func (*MemberAddResponse) ProtoMessage 

func (*MemberAddResponse) ProtoMessage()

func (*MemberAddResponse) Reset 

func (m *MemberAddResponse) Reset()

func (*MemberAddResponse) String 

func (m *MemberAddResponse) String() string

type MemberListRequest 

type MemberListRequest struct {
	// which raft group member add to
	LogstreamName string `protobuf:"bytes,1,opt,name=logstream_name,json=logstreamName" json:"logstream_name,omitempty"`
}

func (*MemberListRequest) Descriptor 

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

func (*MemberListRequest) GetLogstreamName 

func (m *MemberListRequest) GetLogstreamName() string

func (*MemberListRequest) ProtoMessage 

func (*MemberListRequest) ProtoMessage()

func (*MemberListRequest) Reset 

func (m *MemberListRequest) Reset()

func (*MemberListRequest) String 

func (m *MemberListRequest) String() string

type MemberListResponse 

type MemberListResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// cluster leader id, 0 if no leader
	Leader uint64 `protobuf:"varint,2,opt,name=leader" json:"leader,omitempty"`
	// members is a list of all members associated with the cluster.
	Members []*Member `protobuf:"bytes,3,rep,name=members" json:"members,omitempty"`
	// list all remove members
	RemovedMembers []uint64 `protobuf:"varint,4,rep,packed,name=removed_members,json=removedMembers" json:"removed_members,omitempty"`
}

func (*MemberListResponse) Descriptor 

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

func (*MemberListResponse) GetHeader 

func (m *MemberListResponse) GetHeader() *ResponseHeader

func (*MemberListResponse) GetLeader 

func (m *MemberListResponse) GetLeader() uint64

func (*MemberListResponse) GetMembers 

func (m *MemberListResponse) GetMembers() []*Member

func (*MemberListResponse) GetRemovedMembers 

func (m *MemberListResponse) GetRemovedMembers() []uint64

func (*MemberListResponse) ProtoMessage 

func (*MemberListResponse) ProtoMessage()

func (*MemberListResponse) Reset 

func (m *MemberListResponse) Reset()

func (*MemberListResponse) String 

func (m *MemberListResponse) String() string

type MemberRemoveRequest 

type MemberRemoveRequest struct {
	// which raft group member add to
	LogstreamName string `protobuf:"bytes,1,opt,name=logstream_name,json=logstreamName" json:"logstream_name,omitempty"`
	// ID is the member ID of the member to remove.
	ID uint64 `protobuf:"varint,2,opt,name=ID" json:"ID,omitempty"`
}

func (*MemberRemoveRequest) Descriptor 

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

func (*MemberRemoveRequest) GetID 

func (m *MemberRemoveRequest) GetID() uint64

func (*MemberRemoveRequest) GetLogstreamName 

func (m *MemberRemoveRequest) GetLogstreamName() string

func (*MemberRemoveRequest) ProtoMessage 

func (*MemberRemoveRequest) ProtoMessage()

func (*MemberRemoveRequest) Reset 

func (m *MemberRemoveRequest) Reset()

func (*MemberRemoveRequest) String 

func (m *MemberRemoveRequest) String() string

type MemberRemoveResponse 

type MemberRemoveResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// members is a list of all members after removing the member.
	Members []*Member `protobuf:"bytes,2,rep,name=members" json:"members,omitempty"`
}

func (*MemberRemoveResponse) Descriptor 

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

func (*MemberRemoveResponse) GetHeader 

func (m *MemberRemoveResponse) GetHeader() *ResponseHeader

func (*MemberRemoveResponse) GetMembers 

func (m *MemberRemoveResponse) GetMembers() []*Member

func (*MemberRemoveResponse) ProtoMessage 

func (*MemberRemoveResponse) ProtoMessage()

func (*MemberRemoveResponse) Reset 

func (m *MemberRemoveResponse) Reset()

func (*MemberRemoveResponse) String 

func (m *MemberRemoveResponse) String() string

type MemberUpdateRequest 

type MemberUpdateRequest struct {
	// which raft group member(log stream) add to
	LogstreamName string `protobuf:"bytes,1,opt,name=logstream_name,json=logstreamName" json:"logstream_name,omitempty"`
	// ID is the member ID of the member to update.
	ID uint64 `protobuf:"varint,2,opt,name=ID" json:"ID,omitempty"`
	// peerURLs is the new list of URLs the member will use to communicate with the cluster.
	PeerURLs []string `protobuf:"bytes,3,rep,name=peerURLs" json:"peerURLs,omitempty"`
}

func (*MemberUpdateRequest) Descriptor 

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

func (*MemberUpdateRequest) GetID 

func (m *MemberUpdateRequest) GetID() uint64

func (*MemberUpdateRequest) GetLogstreamName 

func (m *MemberUpdateRequest) GetLogstreamName() string

func (*MemberUpdateRequest) GetPeerURLs 

func (m *MemberUpdateRequest) GetPeerURLs() []string

func (*MemberUpdateRequest) ProtoMessage 

func (*MemberUpdateRequest) ProtoMessage()

func (*MemberUpdateRequest) Reset 

func (m *MemberUpdateRequest) Reset()

func (*MemberUpdateRequest) String 

func (m *MemberUpdateRequest) String() string

type MemberUpdateResponse 

type MemberUpdateResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// members is a list of all members after updating the member.
	Members []*Member `protobuf:"bytes,2,rep,name=members" json:"members,omitempty"`
}

func (*MemberUpdateResponse) Descriptor 

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

func (*MemberUpdateResponse) GetHeader 

func (m *MemberUpdateResponse) GetHeader() *ResponseHeader

func (*MemberUpdateResponse) GetMembers 

func (m *MemberUpdateResponse) GetMembers() []*Member

func (*MemberUpdateResponse) ProtoMessage 

func (*MemberUpdateResponse) ProtoMessage()

func (*MemberUpdateResponse) Reset 

func (m *MemberUpdateResponse) Reset()

func (*MemberUpdateResponse) String 

func (m *MemberUpdateResponse) String() string

type MembershipClient 

type MembershipClient interface {
	// MemberAdd adds a member into the cluster.
	MemberAdd(ctx context.Context, in *MemberAddRequest, opts ...grpc.CallOption) (*MemberAddResponse, error)
	// MemberRemove removes an existing member from the cluster.
	MemberRemove(ctx context.Context, in *MemberRemoveRequest, opts ...grpc.CallOption) (*MemberRemoveResponse, error)
	// MemberUpdate updates the member configuration.
	MemberUpdate(ctx context.Context, in *MemberUpdateRequest, opts ...grpc.CallOption) (*MemberUpdateResponse, error)
	// MemberList lists all the members in the cluster.
	MemberList(ctx context.Context, in *MemberListRequest, opts ...grpc.CallOption) (*MemberListResponse, error)
}

func NewMembershipClient 

func NewMembershipClient(cc *grpc.ClientConn) MembershipClient

type MembershipServer 

type MembershipServer interface {
	// MemberAdd adds a member into the cluster.
	MemberAdd(context.Context, *MemberAddRequest) (*MemberAddResponse, error)
	// MemberRemove removes an existing member from the cluster.
	MemberRemove(context.Context, *MemberRemoveRequest) (*MemberRemoveResponse, error)
	// MemberUpdate updates the member configuration.
	MemberUpdate(context.Context, *MemberUpdateRequest) (*MemberUpdateResponse, error)
	// MemberList lists all the members in the cluster.
	MemberList(context.Context, *MemberListRequest) (*MemberListResponse, error)
}

type RateAdminClient 

type RateAdminClient interface {
	ListRateInfo(ctx context.Context, in *RateListRequest, opts ...grpc.CallOption) (*RateListResponse, error)
	UpdateRateInfo(ctx context.Context, in *RateUpdateRequest, opts ...grpc.CallOption) (*RateUpdateResponse, error)
}

func NewRateAdminClient 

func NewRateAdminClient(cc *grpc.ClientConn) RateAdminClient

type RateAdminServer 

type RateAdminServer interface {
	ListRateInfo(context.Context, *RateListRequest) (*RateListResponse, error)
	UpdateRateInfo(context.Context, *RateUpdateRequest) (*RateUpdateResponse, error)
}

type RateListRequest 

type RateListRequest struct {
}

func (*RateListRequest) Descriptor 

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

func (*RateListRequest) ProtoMessage 

func (*RateListRequest) ProtoMessage()

func (*RateListRequest) Reset 

func (m *RateListRequest) Reset()

func (*RateListRequest) String 

func (m *RateListRequest) String() string

type RateListResponse 

type RateListResponse struct {
	Msg []byte `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*RateListResponse) Descriptor 

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

func (*RateListResponse) GetMsg 

func (m *RateListResponse) GetMsg() []byte

func (*RateListResponse) ProtoMessage 

func (*RateListResponse) ProtoMessage()

func (*RateListResponse) Reset 

func (m *RateListResponse) Reset()

func (*RateListResponse) String 

func (m *RateListResponse) String() string

type RateUpdateRequest 

type RateUpdateRequest struct {
	Msg []byte `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*RateUpdateRequest) Descriptor 

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

func (*RateUpdateRequest) GetMsg 

func (m *RateUpdateRequest) GetMsg() []byte

func (*RateUpdateRequest) ProtoMessage 

func (*RateUpdateRequest) ProtoMessage()

func (*RateUpdateRequest) Reset 

func (m *RateUpdateRequest) Reset()

func (*RateUpdateRequest) String 

func (m *RateUpdateRequest) String() string

type RateUpdateResponse 

type RateUpdateResponse struct {
	Msg []byte `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*RateUpdateResponse) Descriptor 

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

func (*RateUpdateResponse) GetMsg 

func (m *RateUpdateResponse) GetMsg() []byte

func (*RateUpdateResponse) ProtoMessage 

func (*RateUpdateResponse) ProtoMessage()

func (*RateUpdateResponse) Reset 

func (m *RateUpdateResponse) Reset()

func (*RateUpdateResponse) String 

func (m *RateUpdateResponse) String() string

type ResponseHeader 

type ResponseHeader struct {
	// logstream_name which operator for.
	LogstreamName string `protobuf:"bytes,1,opt,name=logstream_name,json=logstreamName" json:"logstream_name,omitempty"`
	// cluster id which log stream in
	ClusterId uint64 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId" json:"cluster_id,omitempty"`
	// server name which send the response
	ServerName string `protobuf:"bytes,3,opt,name=server_name,json=serverName" json:"server_name,omitempty"`
}

func (*ResponseHeader) Descriptor 

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

func (*ResponseHeader) GetClusterId 

func (m *ResponseHeader) GetClusterId() uint64

func (*ResponseHeader) GetLogstreamName 

func (m *ResponseHeader) GetLogstreamName() string

func (*ResponseHeader) GetServerName 

func (m *ResponseHeader) GetServerName() string

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset 

func (m *ResponseHeader) Reset()

func (*ResponseHeader) String 

func (m *ResponseHeader) String() string

type SetDeletePermissionReq 

type SetDeletePermissionReq struct {
	LogstreamName string `protobuf:"bytes,1,opt,name=logstream_name,json=logstreamName" json:"logstream_name,omitempty"`
	Switch        uint64 `protobuf:"varint,2,opt,name=switch" json:"switch,omitempty"`
}

func (*SetDeletePermissionReq) Descriptor 

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

func (*SetDeletePermissionReq) GetLogstreamName 

func (m *SetDeletePermissionReq) GetLogstreamName() string

func (*SetDeletePermissionReq) GetSwitch 

func (m *SetDeletePermissionReq) GetSwitch() uint64

func (*SetDeletePermissionReq) ProtoMessage 

func (*SetDeletePermissionReq) ProtoMessage()

func (*SetDeletePermissionReq) Reset 

func (m *SetDeletePermissionReq) Reset()

func (*SetDeletePermissionReq) String 

func (m *SetDeletePermissionReq) String() string

type SetDeletePermissionResp 

type SetDeletePermissionResp struct {
	ResultStatus string `protobuf:"bytes,1,opt,name=result_status,json=resultStatus" json:"result_status,omitempty"`
	ErrorMsg     string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg" json:"error_msg,omitempty"`
}

func (*SetDeletePermissionResp) Descriptor 

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

func (*SetDeletePermissionResp) GetErrorMsg 

func (m *SetDeletePermissionResp) GetErrorMsg() string

func (*SetDeletePermissionResp) GetResultStatus 

func (m *SetDeletePermissionResp) GetResultStatus() string

func (*SetDeletePermissionResp) ProtoMessage 

func (*SetDeletePermissionResp) ProtoMessage()

func (*SetDeletePermissionResp) Reset 

func (m *SetDeletePermissionResp) Reset()

func (*SetDeletePermissionResp) String 

func (m *SetDeletePermissionResp) String() string

type SnapshotAdminClient 

type SnapshotAdminClient interface {
	CreateSnapshotMeta(ctx context.Context, in *SnapshotRequeest, opts ...grpc.CallOption) (*SnapshotResponse, error)
}

func NewSnapshotAdminClient 

func NewSnapshotAdminClient(cc *grpc.ClientConn) SnapshotAdminClient

type SnapshotAdminServer 

type SnapshotAdminServer interface {
	CreateSnapshotMeta(context.Context, *SnapshotRequeest) (*SnapshotResponse, error)
}

type SnapshotRequeest 

type SnapshotRequeest struct {
	RaftGroup string `protobuf:"bytes,1,opt,name=raft_group,json=raftGroup" json:"raft_group,omitempty"`
}

func (*SnapshotRequeest) Descriptor 

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

func (*SnapshotRequeest) GetRaftGroup 

func (m *SnapshotRequeest) GetRaftGroup() string

func (*SnapshotRequeest) ProtoMessage 

func (*SnapshotRequeest) ProtoMessage()

func (*SnapshotRequeest) Reset 

func (m *SnapshotRequeest) Reset()

func (*SnapshotRequeest) String 

func (m *SnapshotRequeest) String() string

type SnapshotResponse 

type SnapshotResponse struct {
	ResultStatus string `protobuf:"bytes,1,opt,name=result_status,json=resultStatus" json:"result_status,omitempty"`
	Msg          []byte `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*SnapshotResponse) Descriptor 

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

func (*SnapshotResponse) GetMsg 

func (m *SnapshotResponse) GetMsg() []byte

func (*SnapshotResponse) GetResultStatus 

func (m *SnapshotResponse) GetResultStatus() string

func (*SnapshotResponse) ProtoMessage 

func (*SnapshotResponse) ProtoMessage()

func (*SnapshotResponse) Reset 

func (m *SnapshotResponse) Reset()

func (*SnapshotResponse) String 

func (m *SnapshotResponse) String() string

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.