protos

Documentation

Index

• Variables
• func RegisterStreamProviderServer(s *grpc.Server, srv StreamProviderServer)
• type StreamProviderClient
  • func NewStreamProviderClient(cc grpc.ClientConnInterface) StreamProviderClient
• type StreamProviderServer
• type UnimplementedStreamProviderServer
  • func (*UnimplementedStreamProviderServer) GetUpdates(context.Context, *protos.StreamRequest) (*protos.DataUpdateBatch, error)

Variables

var File_provider_proto protoreflect.FileDescriptor

Functions

func RegisterStreamProviderServer

func RegisterStreamProviderServer(s *grpc.Server, srv StreamProviderServer)

Types

type StreamProviderClient

type StreamProviderClient interface {
	GetUpdates(ctx context.Context, in *protos.StreamRequest, opts ...grpc.CallOption) (*protos.DataUpdateBatch, error)
}

StreamProviderClient is the client API for StreamProvider service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStreamProviderClient

func NewStreamProviderClient(cc grpc.ClientConnInterface) StreamProviderClient

type StreamProviderServer

type StreamProviderServer interface {
	GetUpdates(context.Context, *protos.StreamRequest) (*protos.DataUpdateBatch, error)
}

StreamProviderServer is the server API for StreamProvider service.

type UnimplementedStreamProviderServer

type UnimplementedStreamProviderServer struct {
}

UnimplementedStreamProviderServer can be embedded to have forward compatible implementations.

func (*UnimplementedStreamProviderServer) GetUpdates

func (*UnimplementedStreamProviderServer) GetUpdates(context.Context, *protos.StreamRequest) (*protos.DataUpdateBatch, error)