talaria

package
v0.0.0-...-7f8ad27 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2018 License: MIT Imports: 5 Imported by: 1

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

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) Descriptor() ([]byte, []int)

func (*ListInfo) GetNames 

func (m *ListInfo) GetNames() []string

func (*ListInfo) ProtoMessage 

func (*ListInfo) ProtoMessage()

func (*ListInfo) Reset 

func (m *ListInfo) Reset()

func (*ListInfo) String 

func (m *ListInfo) String() string

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) Descriptor() ([]byte, []int)

func (*NodeInfo) GetURI 

func (m *NodeInfo) GetURI() string

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset 

func (m *NodeInfo) Reset()

func (*NodeInfo) String 

func (m *NodeInfo) String() string

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

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.