grpc

package

v0.3.3 Latest Latest Go to latest Published: Dec 8, 2017 License: MIT Imports: 7 Imported by: 0

Details

Package grpc is a generated protocol buffer package.

It is generated from these files:

frunner.proto

It has these top-level messages:

Data

This section is empty.

This section is empty.

func CopyFromStream(ctx context.Context, source DataStream, dest io.Writer) error

CopyFromStream copies data from a stream to a writer

func CopyToStream(ctx context.Context, source io.Reader, dest DataStream) error

CopyToStream copies from a reader to a stream

func RegisterFunctionRunnerServer(s *grpc1.Server, srv FunctionRunnerServer)

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

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

func (m *Data) GetData() []byte

func (*Data) ProtoMessage()

func (m *Data) Reset()

func (m *Data) String() string

type DataStream interface {
	Send(*Data) error
	Recv() (*Data, error)
}

DataStream is either a FunctionRunner_RunClient or FunctionRunner_RunServer

type FunctionRunnerClient interface {
	Run(ctx context.Context, opts ...grpc1.CallOption) (FunctionRunner_RunClient, error)
}

func NewFunctionRunnerClient(cc *grpc1.ClientConn) FunctionRunnerClient

type FunctionRunnerServer interface {
	Run(FunctionRunner_RunServer) error
}

type FunctionRunner_RunClient interface {
	Send(*Data) error
	Recv() (*Data, error)
	grpc1.ClientStream
}

type FunctionRunner_RunServer interface {
	Send(*Data) error
	Recv() (*Data, error)
	grpc1.ServerStream
}