Documentation ¶
Overview ¶
Package talaria is a generated protocol buffer package.
It is generated from these files:
node.proto scheduler.proto
It has these top-level messages:
BufferInfo WriteDataPacket ReadDataPacket WriteResponse InfoResponse ListClustersInfo ListClustersResponse CreateInfo CreateResponse ListInfo ListResponse ClusterInfo NodeInfo
Index ¶
- func RegisterNodeServer(s *grpc.Server, srv NodeServer)
- func RegisterSchedulerServer(s *grpc.Server, srv SchedulerServer)
- type BufferInfo
- func (*BufferInfo) Descriptor() ([]byte, []int)
- func (m *BufferInfo) GetName() string
- func (m *BufferInfo) GetStartFromEnd() bool
- func (m *BufferInfo) GetStartIndex() uint64
- func (m *BufferInfo) GetTail() bool
- func (*BufferInfo) ProtoMessage()
- func (m *BufferInfo) Reset()
- func (m *BufferInfo) String() string
- type ClusterInfo
- type CreateInfo
- type CreateResponse
- type InfoResponse
- type ListClustersInfo
- type ListClustersResponse
- type ListInfo
- type ListResponse
- type NodeClient
- type NodeInfo
- type NodeServer
- type Node_ReadClient
- type Node_ReadServer
- type Node_WriteClient
- type Node_WriteServer
- type ReadDataPacket
- type SchedulerClient
- type SchedulerServer
- type WriteDataPacket
- type WriteResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterNodeServer ¶
func RegisterNodeServer(s *grpc.Server, srv NodeServer)
func RegisterSchedulerServer ¶
func RegisterSchedulerServer(s *grpc.Server, srv SchedulerServer)
Types ¶
type BufferInfo ¶
type BufferInfo struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` StartIndex uint64 `protobuf:"varint,2,opt,name=startIndex" json:"startIndex,omitempty"` StartFromEnd bool `protobuf:"varint,3,opt,name=startFromEnd" json:"startFromEnd,omitempty"` Tail bool `protobuf:"varint,4,opt,name=tail" json:"tail,omitempty"` }
func (*BufferInfo) Descriptor ¶
func (*BufferInfo) Descriptor() ([]byte, []int)
func (*BufferInfo) GetName ¶
func (m *BufferInfo) GetName() string
func (*BufferInfo) GetStartFromEnd ¶
func (m *BufferInfo) GetStartFromEnd() bool
func (*BufferInfo) GetStartIndex ¶
func (m *BufferInfo) GetStartIndex() uint64
func (*BufferInfo) GetTail ¶
func (m *BufferInfo) GetTail() bool
func (*BufferInfo) ProtoMessage ¶
func (*BufferInfo) ProtoMessage()
func (*BufferInfo) Reset ¶
func (m *BufferInfo) Reset()
func (*BufferInfo) String ¶
func (m *BufferInfo) String() string
type ClusterInfo ¶
type ClusterInfo struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` Leader string `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"` Nodes []*NodeInfo `protobuf:"bytes,3,rep,name=nodes" json:"nodes,omitempty"` }
func (*ClusterInfo) Descriptor ¶
func (*ClusterInfo) Descriptor() ([]byte, []int)
func (*ClusterInfo) GetLeader ¶
func (m *ClusterInfo) GetLeader() string
func (*ClusterInfo) GetName ¶
func (m *ClusterInfo) GetName() string
func (*ClusterInfo) GetNodes ¶
func (m *ClusterInfo) GetNodes() []*NodeInfo
func (*ClusterInfo) ProtoMessage ¶
func (*ClusterInfo) ProtoMessage()
func (*ClusterInfo) Reset ¶
func (m *ClusterInfo) Reset()
func (*ClusterInfo) String ¶
func (m *ClusterInfo) String() string
type CreateInfo ¶
type CreateInfo struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` BufferSize uint64 `protobuf:"varint,2,opt,name=buffer_size,json=bufferSize" json:"buffer_size,omitempty"` }
func (*CreateInfo) Descriptor ¶
func (*CreateInfo) Descriptor() ([]byte, []int)
func (*CreateInfo) GetBufferSize ¶
func (m *CreateInfo) GetBufferSize() uint64
func (*CreateInfo) GetName ¶
func (m *CreateInfo) GetName() string
func (*CreateInfo) ProtoMessage ¶
func (*CreateInfo) ProtoMessage()
func (*CreateInfo) Reset ¶
func (m *CreateInfo) Reset()
func (*CreateInfo) String ¶
func (m *CreateInfo) String() string
type CreateResponse ¶
type CreateResponse struct { }
func (*CreateResponse) Descriptor ¶
func (*CreateResponse) Descriptor() ([]byte, []int)
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) Reset ¶
func (m *CreateResponse) Reset()
func (*CreateResponse) String ¶
func (m *CreateResponse) String() string
type InfoResponse ¶
type InfoResponse struct {
Uri string `protobuf:"bytes,1,opt,name=uri" json:"uri,omitempty"`
}
func (*InfoResponse) Descriptor ¶
func (*InfoResponse) Descriptor() ([]byte, []int)
func (*InfoResponse) GetUri ¶
func (m *InfoResponse) GetUri() string
func (*InfoResponse) ProtoMessage ¶
func (*InfoResponse) ProtoMessage()
func (*InfoResponse) Reset ¶
func (m *InfoResponse) Reset()
func (*InfoResponse) String ¶
func (m *InfoResponse) String() string
type ListClustersInfo ¶
type ListClustersInfo struct { }
func (*ListClustersInfo) Descriptor ¶
func (*ListClustersInfo) Descriptor() ([]byte, []int)
func (*ListClustersInfo) ProtoMessage ¶
func (*ListClustersInfo) ProtoMessage()
func (*ListClustersInfo) Reset ¶
func (m *ListClustersInfo) Reset()
func (*ListClustersInfo) String ¶
func (m *ListClustersInfo) String() string
type ListClustersResponse ¶
type ListClustersResponse struct {
Names []string `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`
}
func (*ListClustersResponse) Descriptor ¶
func (*ListClustersResponse) Descriptor() ([]byte, []int)
func (*ListClustersResponse) GetNames ¶
func (m *ListClustersResponse) GetNames() []string
func (*ListClustersResponse) ProtoMessage ¶
func (*ListClustersResponse) ProtoMessage()
func (*ListClustersResponse) Reset ¶
func (m *ListClustersResponse) Reset()
func (*ListClustersResponse) String ¶
func (m *ListClustersResponse) String() string
type ListInfo ¶
type ListInfo struct {
Names []string `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`
}
func (*ListInfo) Descriptor ¶
func (*ListInfo) ProtoMessage ¶
func (*ListInfo) ProtoMessage()
type ListResponse ¶
type ListResponse struct {
Info []*ClusterInfo `protobuf:"bytes,1,rep,name=info" json:"info,omitempty"`
}
func (*ListResponse) Descriptor ¶
func (*ListResponse) Descriptor() ([]byte, []int)
func (*ListResponse) GetInfo ¶
func (m *ListResponse) GetInfo() []*ClusterInfo
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) Reset ¶
func (m *ListResponse) Reset()
func (*ListResponse) String ¶
func (m *ListResponse) String() string
type NodeClient ¶
type NodeClient interface { Write(ctx context.Context, opts ...grpc.CallOption) (Node_WriteClient, error) Read(ctx context.Context, in *BufferInfo, opts ...grpc.CallOption) (Node_ReadClient, error) ListClusters(ctx context.Context, in *ListClustersInfo, opts ...grpc.CallOption) (*ListClustersResponse, error) }
func NewNodeClient ¶
func NewNodeClient(cc *grpc.ClientConn) NodeClient
type NodeInfo ¶
type NodeInfo struct {
URI string `protobuf:"bytes,1,opt,name=URI,json=uRI" json:"URI,omitempty"`
}
func (*NodeInfo) Descriptor ¶
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
type NodeServer ¶
type NodeServer interface { Write(Node_WriteServer) error Read(*BufferInfo, Node_ReadServer) error ListClusters(context.Context, *ListClustersInfo) (*ListClustersResponse, error) }
type Node_ReadClient ¶
type Node_ReadClient interface { Recv() (*ReadDataPacket, error) grpc.ClientStream }
type Node_ReadServer ¶
type Node_ReadServer interface { Send(*ReadDataPacket) error grpc.ServerStream }
type Node_WriteClient ¶
type Node_WriteClient interface { Send(*WriteDataPacket) error CloseAndRecv() (*WriteResponse, error) grpc.ClientStream }
type Node_WriteServer ¶
type Node_WriteServer interface { SendAndClose(*WriteResponse) error Recv() (*WriteDataPacket, error) grpc.ServerStream }
type ReadDataPacket ¶
type ReadDataPacket struct { Message []byte `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index" json:"index,omitempty"` }
func (*ReadDataPacket) Descriptor ¶
func (*ReadDataPacket) Descriptor() ([]byte, []int)
func (*ReadDataPacket) GetIndex ¶
func (m *ReadDataPacket) GetIndex() uint64
func (*ReadDataPacket) GetMessage ¶
func (m *ReadDataPacket) GetMessage() []byte
func (*ReadDataPacket) ProtoMessage ¶
func (*ReadDataPacket) ProtoMessage()
func (*ReadDataPacket) Reset ¶
func (m *ReadDataPacket) Reset()
func (*ReadDataPacket) String ¶
func (m *ReadDataPacket) String() string
type SchedulerClient ¶
type SchedulerClient interface { Create(ctx context.Context, in *CreateInfo, opts ...grpc.CallOption) (*CreateResponse, error) ListClusterInfo(ctx context.Context, in *ListInfo, opts ...grpc.CallOption) (*ListResponse, error) }
func NewSchedulerClient ¶
func NewSchedulerClient(cc *grpc.ClientConn) SchedulerClient
type SchedulerServer ¶
type SchedulerServer interface { Create(context.Context, *CreateInfo) (*CreateResponse, error) ListClusterInfo(context.Context, *ListInfo) (*ListResponse, error) }
type WriteDataPacket ¶
type WriteDataPacket struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` Message []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` }
func (*WriteDataPacket) Descriptor ¶
func (*WriteDataPacket) Descriptor() ([]byte, []int)
func (*WriteDataPacket) GetMessage ¶
func (m *WriteDataPacket) GetMessage() []byte
func (*WriteDataPacket) GetName ¶
func (m *WriteDataPacket) GetName() string
func (*WriteDataPacket) ProtoMessage ¶
func (*WriteDataPacket) ProtoMessage()
func (*WriteDataPacket) Reset ¶
func (m *WriteDataPacket) Reset()
func (*WriteDataPacket) String ¶
func (m *WriteDataPacket) String() string
type WriteResponse ¶
type WriteResponse struct { LastWriteIndex uint64 `protobuf:"varint,1,opt,name=lastWriteIndex" json:"lastWriteIndex,omitempty"` Error string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` }
func (*WriteResponse) Descriptor ¶
func (*WriteResponse) Descriptor() ([]byte, []int)
func (*WriteResponse) GetError ¶
func (m *WriteResponse) GetError() string
func (*WriteResponse) GetLastWriteIndex ¶
func (m *WriteResponse) GetLastWriteIndex() uint64
func (*WriteResponse) ProtoMessage ¶
func (*WriteResponse) ProtoMessage()
func (*WriteResponse) Reset ¶
func (m *WriteResponse) Reset()
func (*WriteResponse) String ¶
func (m *WriteResponse) String() string
Click to show internal directories.
Click to hide internal directories.