streaming_v1

package
v0.1.2 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_api_streaming_v1_streaming_proto protoreflect.FileDescriptor

Functions

func RegisterFollowerResolverHelperServer added in v0.1.1 

func RegisterFollowerResolverHelperServer(s *grpc.Server, srv FollowerResolverHelperServer)

func RegisterLBResolverHelperServer added in v0.1.1 

func RegisterLBResolverHelperServer(s *grpc.Server, srv LBResolverHelperServer)

func RegisterStreamingServer 

func RegisterStreamingServer(s *grpc.Server, srv StreamingServer)

Types

type ConsumeRequest 

type ConsumeRequest struct {
	Point     string `protobuf:"bytes,1,opt,name=point,proto3" json:"point,omitempty"`
	Offset    uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit     uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	ChunkSize uint64 `protobuf:"varint,4,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumeRequest) Descriptor deprecated 

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

Deprecated: Use ConsumeRequest.ProtoReflect.Descriptor instead.

func (*ConsumeRequest) GetChunkSize added in v0.1.2 

func (x *ConsumeRequest) GetChunkSize() uint64

func (*ConsumeRequest) GetLimit added in v0.1.2 

func (x *ConsumeRequest) GetLimit() uint64

func (*ConsumeRequest) GetOffset added in v0.1.2 

func (x *ConsumeRequest) GetOffset() uint64

func (*ConsumeRequest) GetPoint 

func (x *ConsumeRequest) GetPoint() string

func (*ConsumeRequest) ProtoMessage 

func (*ConsumeRequest) ProtoMessage()

func (*ConsumeRequest) ProtoReflect 

func (x *ConsumeRequest) ProtoReflect() protoreflect.Message

func (*ConsumeRequest) Reset 

func (x *ConsumeRequest) Reset()

func (*ConsumeRequest) String 

func (x *ConsumeRequest) String() string

type ConsumeResponse 

type ConsumeResponse struct {
	Frame []byte `protobuf:"bytes,1,opt,name=frame,proto3" json:"frame,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumeResponse) Descriptor deprecated 

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

Deprecated: Use ConsumeResponse.ProtoReflect.Descriptor instead.

func (*ConsumeResponse) GetFrame 

func (x *ConsumeResponse) GetFrame() []byte

func (*ConsumeResponse) ProtoMessage 

func (*ConsumeResponse) ProtoMessage()

func (*ConsumeResponse) ProtoReflect 

func (x *ConsumeResponse) ProtoReflect() protoreflect.Message

func (*ConsumeResponse) Reset 

func (x *ConsumeResponse) Reset()

func (*ConsumeResponse) String 

func (x *ConsumeResponse) String() string

type FollowerResolverHelperClient added in v0.1.1 

type FollowerResolverHelperClient interface {
	GetFollowers(ctx context.Context, in *GetFollowersRequest, opts ...grpc.CallOption) (*GetFollowersResponse, error)
}

FollowerResolverHelperClient is the client API for FollowerResolverHelper service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFollowerResolverHelperClient added in v0.1.1 

func NewFollowerResolverHelperClient(cc grpc.ClientConnInterface) FollowerResolverHelperClient

type FollowerResolverHelperServer added in v0.1.1 

type FollowerResolverHelperServer interface {
	GetFollowers(context.Context, *GetFollowersRequest) (*GetFollowersResponse, error)
	// contains filtered or unexported methods
}

FollowerResolverHelperServer is the server API for FollowerResolverHelper service. All implementations must embed UnimplementedFollowerResolverHelperServer for forward compatibility

type GetFollowersRequest added in v0.1.1 

type GetFollowersRequest struct {
	// contains filtered or unexported fields
}

func (*GetFollowersRequest) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use GetFollowersRequest.ProtoReflect.Descriptor instead.

func (*GetFollowersRequest) ProtoMessage added in v0.1.1 

func (*GetFollowersRequest) ProtoMessage()

func (*GetFollowersRequest) ProtoReflect added in v0.1.1 

func (x *GetFollowersRequest) ProtoReflect() protoreflect.Message

func (*GetFollowersRequest) Reset added in v0.1.1 

func (x *GetFollowersRequest) Reset()

func (*GetFollowersRequest) String added in v0.1.1 

func (x *GetFollowersRequest) String() string

type GetFollowersResponse added in v0.1.1 

type GetFollowersResponse struct {
	Servers []*Server `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFollowersResponse) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use GetFollowersResponse.ProtoReflect.Descriptor instead.

func (*GetFollowersResponse) GetServers added in v0.1.1 

func (x *GetFollowersResponse) GetServers() []*Server

func (*GetFollowersResponse) ProtoMessage added in v0.1.1 

func (*GetFollowersResponse) ProtoMessage()

func (*GetFollowersResponse) ProtoReflect added in v0.1.1 

func (x *GetFollowersResponse) ProtoReflect() protoreflect.Message

func (*GetFollowersResponse) Reset added in v0.1.1 

func (x *GetFollowersResponse) Reset()

func (*GetFollowersResponse) String added in v0.1.1 

func (x *GetFollowersResponse) String() string

type GetServersRequest added in v0.1.1 

type GetServersRequest struct {
	// contains filtered or unexported fields
}

func (*GetServersRequest) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use GetServersRequest.ProtoReflect.Descriptor instead.

func (*GetServersRequest) ProtoMessage added in v0.1.1 

func (*GetServersRequest) ProtoMessage()

func (*GetServersRequest) ProtoReflect added in v0.1.1 

func (x *GetServersRequest) ProtoReflect() protoreflect.Message

func (*GetServersRequest) Reset added in v0.1.1 

func (x *GetServersRequest) Reset()

func (*GetServersRequest) String added in v0.1.1 

func (x *GetServersRequest) String() string

type GetServersResponse added in v0.1.1 

type GetServersResponse struct {
	Servers []*Server `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServersResponse) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use GetServersResponse.ProtoReflect.Descriptor instead.

func (*GetServersResponse) GetServers added in v0.1.1 

func (x *GetServersResponse) GetServers() []*Server

func (*GetServersResponse) ProtoMessage added in v0.1.1 

func (*GetServersResponse) ProtoMessage()

func (*GetServersResponse) ProtoReflect added in v0.1.1 

func (x *GetServersResponse) ProtoReflect() protoreflect.Message

func (*GetServersResponse) Reset added in v0.1.1 

func (x *GetServersResponse) Reset()

func (*GetServersResponse) String added in v0.1.1 

func (x *GetServersResponse) String() string

type LBResolverHelperClient added in v0.1.1 

type LBResolverHelperClient interface {
	GetServers(ctx context.Context, in *GetServersRequest, opts ...grpc.CallOption) (*GetServersResponse, error)
}

LBResolverHelperClient is the client API for LBResolverHelper service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLBResolverHelperClient added in v0.1.1 

func NewLBResolverHelperClient(cc grpc.ClientConnInterface) LBResolverHelperClient

type LBResolverHelperServer added in v0.1.1 

type LBResolverHelperServer interface {
	GetServers(context.Context, *GetServersRequest) (*GetServersResponse, error)
	// contains filtered or unexported methods
}

LBResolverHelperServer is the server API for LBResolverHelper service. All implementations must embed UnimplementedLBResolverHelperServer for forward compatibility

type LocusNotFound 

type LocusNotFound struct {
	LocusId string
}

func (LocusNotFound) Error 

func (e LocusNotFound) Error() string

func (LocusNotFound) GRPCStatus 

func (e LocusNotFound) GRPCStatus() *status.Status

type MetadataRequest added in v0.1.2 

type MetadataRequest struct {
	Point string `protobuf:"bytes,1,opt,name=point,proto3" json:"point,omitempty"`
	// contains filtered or unexported fields
}

func (*MetadataRequest) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use MetadataRequest.ProtoReflect.Descriptor instead.

func (*MetadataRequest) GetPoint added in v0.1.2 

func (x *MetadataRequest) GetPoint() string

func (*MetadataRequest) ProtoMessage added in v0.1.2 

func (*MetadataRequest) ProtoMessage()

func (*MetadataRequest) ProtoReflect added in v0.1.2 

func (x *MetadataRequest) ProtoReflect() protoreflect.Message

func (*MetadataRequest) Reset added in v0.1.2 

func (x *MetadataRequest) Reset()

func (*MetadataRequest) String added in v0.1.2 

func (x *MetadataRequest) String() string

type MetadataResponse added in v0.1.2 

type MetadataResponse struct {
	Workers []string `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
	Size    uint64   `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*MetadataResponse) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use MetadataResponse.ProtoReflect.Descriptor instead.

func (*MetadataResponse) GetSize added in v0.1.2 

func (x *MetadataResponse) GetSize() uint64

func (*MetadataResponse) GetWorkers added in v0.1.2 

func (x *MetadataResponse) GetWorkers() []string

func (*MetadataResponse) ProtoMessage added in v0.1.2 

func (*MetadataResponse) ProtoMessage()

func (*MetadataResponse) ProtoReflect added in v0.1.2 

func (x *MetadataResponse) ProtoReflect() protoreflect.Message

func (*MetadataResponse) Reset added in v0.1.2 

func (x *MetadataResponse) Reset()

func (*MetadataResponse) String added in v0.1.2 

func (x *MetadataResponse) String() string

type PointNotFound 

type PointNotFound struct {
	PointId string
}

func (PointNotFound) Error 

func (e PointNotFound) Error() string

func (PointNotFound) GRPCStatus 

func (e PointNotFound) GRPCStatus() *status.Status

type ProduceRequest 

type ProduceRequest struct {
	Point string `protobuf:"bytes,1,opt,name=point,proto3" json:"point,omitempty"`
	Frame []byte `protobuf:"bytes,3,opt,name=frame,proto3" json:"frame,omitempty"`
	// contains filtered or unexported fields
}

func (*ProduceRequest) Descriptor deprecated 

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

Deprecated: Use ProduceRequest.ProtoReflect.Descriptor instead.

func (*ProduceRequest) GetFrame 

func (x *ProduceRequest) GetFrame() []byte

func (*ProduceRequest) GetPoint 

func (x *ProduceRequest) GetPoint() string

func (*ProduceRequest) ProtoMessage 

func (*ProduceRequest) ProtoMessage()

func (*ProduceRequest) ProtoReflect 

func (x *ProduceRequest) ProtoReflect() protoreflect.Message

func (*ProduceRequest) Reset 

func (x *ProduceRequest) Reset()

func (*ProduceRequest) String 

func (x *ProduceRequest) String() string

type ProduceResponse 

type ProduceResponse struct {
	Records []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*ProduceResponse) Descriptor deprecated 

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

Deprecated: Use ProduceResponse.ProtoReflect.Descriptor instead.

func (*ProduceResponse) GetRecords 

func (x *ProduceResponse) GetRecords() []*Record

func (*ProduceResponse) ProtoMessage 

func (*ProduceResponse) ProtoMessage()

func (*ProduceResponse) ProtoReflect 

func (x *ProduceResponse) ProtoReflect() protoreflect.Message

func (*ProduceResponse) Reset 

func (x *ProduceResponse) Reset()

func (*ProduceResponse) String 

func (x *ProduceResponse) String() string

type Record 

type Record struct {
	Point  string `protobuf:"bytes,1,opt,name=point,proto3" json:"point,omitempty"`
	Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*Record) Descriptor deprecated 

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetOffset 

func (x *Record) GetOffset() uint64

func (*Record) GetPoint 

func (x *Record) GetPoint() string

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect 

func (x *Record) ProtoReflect() protoreflect.Message

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) String 

func (x *Record) String() string

type Server added in v0.1.1 

type Server struct {
	RpcAddr string `protobuf:"bytes,1,opt,name=rpc_addr,json=rpcAddr,proto3" json:"rpc_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*Server) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use Server.ProtoReflect.Descriptor instead.

func (*Server) GetRpcAddr added in v0.1.1 

func (x *Server) GetRpcAddr() string

func (*Server) ProtoMessage added in v0.1.1 

func (*Server) ProtoMessage()

func (*Server) ProtoReflect added in v0.1.1 

func (x *Server) ProtoReflect() protoreflect.Message

func (*Server) Reset added in v0.1.1 

func (x *Server) Reset()

func (*Server) String added in v0.1.1 

func (x *Server) String() string

type StreamingClient 

type StreamingClient interface {
	ConsumeStream(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (Streaming_ConsumeStreamClient, error)
	ProduceStream(ctx context.Context, opts ...grpc.CallOption) (Streaming_ProduceStreamClient, error)
	GetMetadata(ctx context.Context, in *MetadataRequest, opts ...grpc.CallOption) (*MetadataResponse, error)
}

StreamingClient is the client API for Streaming service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStreamingClient 

func NewStreamingClient(cc grpc.ClientConnInterface) StreamingClient

type StreamingServer 

type StreamingServer interface {
	ConsumeStream(*ConsumeRequest, Streaming_ConsumeStreamServer) error
	ProduceStream(Streaming_ProduceStreamServer) error
	GetMetadata(context.Context, *MetadataRequest) (*MetadataResponse, error)
	// contains filtered or unexported methods
}

StreamingServer is the server API for Streaming service. All implementations must embed UnimplementedStreamingServer for forward compatibility

type Streaming_ConsumeStreamClient 

type Streaming_ConsumeStreamClient interface {
	Recv() (*ConsumeResponse, error)
	grpc.ClientStream
}

type Streaming_ConsumeStreamServer 

type Streaming_ConsumeStreamServer interface {
	Send(*ConsumeResponse) error
	grpc.ServerStream
}

type Streaming_ProduceStreamClient 

type Streaming_ProduceStreamClient interface {
	Send(*ProduceRequest) error
	CloseAndRecv() (*ProduceResponse, error)
	grpc.ClientStream
}

type Streaming_ProduceStreamServer 

type Streaming_ProduceStreamServer interface {
	SendAndClose(*ProduceResponse) error
	Recv() (*ProduceRequest, error)
	grpc.ServerStream
}

type UnimplementedFollowerResolverHelperServer added in v0.1.1 

type UnimplementedFollowerResolverHelperServer struct {
}

UnimplementedFollowerResolverHelperServer must be embedded to have forward compatible implementations.

func (UnimplementedFollowerResolverHelperServer) GetFollowers added in v0.1.1 

func (UnimplementedFollowerResolverHelperServer) GetFollowers(context.Context, *GetFollowersRequest) (*GetFollowersResponse, error)

type UnimplementedLBResolverHelperServer added in v0.1.1 

type UnimplementedLBResolverHelperServer struct {
}

UnimplementedLBResolverHelperServer must be embedded to have forward compatible implementations.

func (UnimplementedLBResolverHelperServer) GetServers added in v0.1.1 

func (UnimplementedLBResolverHelperServer) GetServers(context.Context, *GetServersRequest) (*GetServersResponse, error)

type UnimplementedStreamingServer 

type UnimplementedStreamingServer struct {
}

UnimplementedStreamingServer must be embedded to have forward compatible implementations.

func (UnimplementedStreamingServer) ConsumeStream 

func (UnimplementedStreamingServer) ConsumeStream(*ConsumeRequest, Streaming_ConsumeStreamServer) error

func (UnimplementedStreamingServer) GetMetadata added in v0.1.2 

func (UnimplementedStreamingServer) GetMetadata(context.Context, *MetadataRequest) (*MetadataResponse, error)

func (UnimplementedStreamingServer) ProduceStream 

func (UnimplementedStreamingServer) ProduceStream(Streaming_ProduceStreamServer) error

type UnsafeFollowerResolverHelperServer added in v0.1.1 

type UnsafeFollowerResolverHelperServer interface {
	// contains filtered or unexported methods
}

UnsafeFollowerResolverHelperServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FollowerResolverHelperServer will result in compilation errors.

type UnsafeLBResolverHelperServer added in v0.1.1 

type UnsafeLBResolverHelperServer interface {
	// contains filtered or unexported methods
}

UnsafeLBResolverHelperServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LBResolverHelperServer will result in compilation errors.

type UnsafeStreamingServer 

type UnsafeStreamingServer interface {
	// contains filtered or unexported methods
}

UnsafeStreamingServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamingServer will result in compilation errors.

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.