Documentation ¶
Index ¶
- type ClientStreamCloser
- type RequestMessageStreamer
- type RequestMessageWriter
- type ResponseMessage
- type ResponseMessageReader
- type ResponseMessageStreamer
- type ResponseMessageWriter
- type ServerStream
- type ServerStreamHandler
- type SignService
- func (s *SignService) CreateRequestStreamer(sender RequestMessageWriter, closer ClientStreamCloser) *RequestMessageStreamer
- func (s *SignService) HandleServerStreamRequest(req interface{}, respWriter ResponseMessageWriter) (ResponseMessageWriter, error)
- func (s *SignService) HandleUnaryRequest(ctx context.Context, req interface{}, handler UnaryHandler) (ResponseMessage, error)
- type UnaryHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientStreamCloser ¶
type ClientStreamCloser func() (ResponseMessage, error)
type RequestMessageStreamer ¶
type RequestMessageStreamer struct {
// contains filtered or unexported fields
}
func (*RequestMessageStreamer) CloseAndRecv ¶
func (s *RequestMessageStreamer) CloseAndRecv() (ResponseMessage, error)
func (*RequestMessageStreamer) Send ¶
func (s *RequestMessageStreamer) Send(req interface{}) error
type RequestMessageWriter ¶
type RequestMessageWriter func(interface{}) error
type ResponseMessage ¶
type ResponseMessage interface { GetMetaHeader() *session.ResponseMetaHeader SetMetaHeader(*session.ResponseMetaHeader) }
ResponseMessage is an interface of NeoFS response message.
type ResponseMessageReader ¶
type ResponseMessageReader func() (ResponseMessage, error)
type ResponseMessageStreamer ¶
type ResponseMessageStreamer struct {
// contains filtered or unexported fields
}
func (*ResponseMessageStreamer) Recv ¶
func (s *ResponseMessageStreamer) Recv() (ResponseMessage, error)
type ResponseMessageWriter ¶ added in v0.13.0
type ResponseMessageWriter func(ResponseMessage) error
type ServerStream ¶ added in v0.13.0
ServerStream is an interface of server-side stream v2.
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(req interface{}, respWriter ResponseMessageWriter) (ResponseMessageWriter, error)
func (*SignService) HandleUnaryRequest ¶
func (s *SignService) HandleUnaryRequest(ctx context.Context, req interface{}, handler UnaryHandler) (ResponseMessage, error)
type UnaryHandler ¶
type UnaryHandler func(context.Context, interface{}) (ResponseMessage, error)
Click to show internal directories.
Click to hide internal directories.