builtin

Documentation

Index

• Variables
• func BidiStreamPipe(ctx context.Context) (BidiStreamClient, BidiStreamServer)
• func RecvStreamPipe(ctx context.Context) (RecvStreamClient, RecvStreamServer)
• func SendStreamPipe(ctx context.Context) (SendStreamClient, SendStreamServer)
• type BidiStreamClient
• type BidiStreamServer
• type RecvStreamClient
• type RecvStreamServer
• type SendStreamClient
• type SendStreamServer

Variables

var (
	ErrPipeClosed = errors.New("pipe closed")
)

Functions

func BidiStreamPipe

func BidiStreamPipe(ctx context.Context) (BidiStreamClient, BidiStreamServer)

func RecvStreamPipe

func RecvStreamPipe(ctx context.Context) (RecvStreamClient, RecvStreamServer)

func SendStreamPipe

func SendStreamPipe(ctx context.Context) (SendStreamClient, SendStreamServer)

Types

type BidiStreamClient

type BidiStreamClient interface {
	Context() context.Context
	Send(proto.Message) error
	Recv() (proto.Message, error)
	CloseSend() error
}

type BidiStreamServer

type BidiStreamServer interface {
	Context() context.Context
	Send(proto.Message) error
	Recv() (proto.Message, error)
	Close(err error)
}

type RecvStreamClient

type RecvStreamClient interface {
	Context() context.Context
	Recv() (proto.Message, error)
}

type RecvStreamServer

type RecvStreamServer interface {
	Context() context.Context
	Send(proto.Message) error
	Close(err error)
}

type SendStreamClient

type SendStreamClient interface {
	Context() context.Context
	Send(proto.Message) error
	CloseAndRecv() (proto.Message, error)
}

type SendStreamServer

type SendStreamServer interface {
	Context() context.Context
	SendAndClose(proto.Message) error
	Recv() (proto.Message, error)
	Close(err error)
}