util

Documentation

Index

• Variables
• type ClientStreamCloser
• type RequestMessage
• type RequestMessageStreamer
  • func (s *RequestMessageStreamer) CloseAndRecv() (ResponseMessage, error)
  • func (s *RequestMessageStreamer) Send(req any) error
• type RequestMessageWriter
• type ResponseConstructor
• type ResponseMessage
• type ResponseMessageReader
• type ResponseMessageWriter
• type ServerStream
• type ServerStreamHandler
• type SignService
  • func NewUnarySignService(key *ecdsa.PrivateKey) *SignService
  • func (s *SignService) CreateRequestStreamer(sender RequestMessageWriter, closer ClientStreamCloser, ...) *RequestMessageStreamer
  • func (s *SignService) HandleServerStreamRequest(req any, respWriter ResponseMessageWriter, blankResp ResponseConstructor, ...) error
  • func (s *SignService) HandleUnaryRequest(ctx context.Context, req any, handler UnaryHandler, ...) (ResponseMessage, error)
• type UnaryHandler

Variables

var ErrAbortStream = errors.New("abort message stream")

Types

type ClientStreamCloser

type ClientStreamCloser func() (ResponseMessage, error)

type RequestMessage

type RequestMessage interface {
	GetMetaHeader() *session.RequestMetaHeader
}

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 any) error

type RequestMessageWriter

type RequestMessageWriter func(any) error

type ResponseConstructor

type ResponseConstructor func() ResponseMessage

type ResponseMessage

type ResponseMessage interface {
	GetMetaHeader() *session.ResponseMetaHeader
	SetMetaHeader(*session.ResponseMetaHeader)
}

ResponseMessage is an interface of FrostFS response message.

type ResponseMessageReader

type ResponseMessageReader func() (ResponseMessage, error)

type ResponseMessageWriter

type ResponseMessageWriter func(ResponseMessage) error

type ServerStream

type ServerStream interface {
	Context() context.Context
}

ServerStream is an interface of server-side stream v2.

type ServerStreamHandler

type ServerStreamHandler func(context.Context, any) (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, blankResp ResponseConstructor) *RequestMessageStreamer

func (*SignService) HandleServerStreamRequest

func (s *SignService) HandleServerStreamRequest(
	req any,
	respWriter ResponseMessageWriter,
	blankResp ResponseConstructor,
	respWriterCaller func(ResponseMessageWriter) error,
) error

func (*SignService) HandleUnaryRequest

func (s *SignService) HandleUnaryRequest(ctx context.Context, req any, handler UnaryHandler, blankResp ResponseConstructor) (ResponseMessage, error)

type UnaryHandler

type UnaryHandler func(context.Context, any) (ResponseMessage, error)