util

Documentation

Index

• type ClientStreamCloser
• type RequestMessageStreamer
  • func (s *RequestMessageStreamer) CloseAndRecv() (interface{}, error)
  • func (s *RequestMessageStreamer) Send(req interface{}) error
• type RequestMessageWriter
• type ResponseMessageReader
• type ResponseMessageStreamer
  • func (s *ResponseMessageStreamer) Recv() (interface{}, error)
• type ServerStreamHandler
• type SignService
  • func NewUnarySignService(key *ecdsa.PrivateKey) *SignService
  • func (s *SignService) CreateRequestStreamer(sender RequestMessageWriter, closer ClientStreamCloser) *RequestMessageStreamer
  • func (s *SignService) HandleServerStreamRequest(ctx context.Context, req interface{}, handler ServerStreamHandler) (*ResponseMessageStreamer, error)
  • func (s *SignService) HandleUnaryRequest(ctx context.Context, req interface{}, handler UnaryHandler) (interface{}, error)
• type UnaryHandler

Types

type ClientStreamCloser

type ClientStreamCloser func() (interface{}, error)

type RequestMessageStreamer

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

func (*RequestMessageStreamer) CloseAndRecv

func (s *RequestMessageStreamer) CloseAndRecv() (interface{}, error)

func (*RequestMessageStreamer) Send

func (s *RequestMessageStreamer) Send(req interface{}) error

type RequestMessageWriter

type RequestMessageWriter func(interface{}) error

type ResponseMessageReader

type ResponseMessageReader func() (interface{}, error)

type ResponseMessageStreamer

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

func (*ResponseMessageStreamer) Recv

func (s *ResponseMessageStreamer) Recv() (interface{}, error)

type ServerStreamHandler

type ServerStreamHandler func(context.Context, interface{}) (ResponseMessageReader, error)

type SignService

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

func NewUnarySignService

func NewUnarySignService(key *ecdsa.PrivateKey) *SignService

func (*SignService) CreateRequestStreamer

func (s *SignService) CreateRequestStreamer(sender RequestMessageWriter, closer ClientStreamCloser) *RequestMessageStreamer

func (*SignService) HandleServerStreamRequest

func (s *SignService) HandleServerStreamRequest(ctx context.Context, req interface{}, handler ServerStreamHandler) (*ResponseMessageStreamer, error)

func (*SignService) HandleUnaryRequest

func (s *SignService) HandleUnaryRequest(ctx context.Context, req interface{}, handler UnaryHandler) (interface{}, error)

type UnaryHandler

type UnaryHandler func(context.Context, interface{}) (interface{}, error)