util

Documentation

Index

• Variables
• func EnsureNonNilResponse[T any](resp *T, err error) (*T, error)
• type RequestMessage
• type ResponseMessage
• type ServerStream
• type SignService
  • func NewUnarySignService(key *ecdsa.PrivateKey) *SignService
  • func (s *SignService) SignResponse(resp ResponseMessage, err error) error
  • func (s *SignService) VerifyRequest(req RequestMessage) error

Variables

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

Functions

func EnsureNonNilResponse

func EnsureNonNilResponse[T any](resp *T, err error) (*T, error)

EnsureNonNilResponse creates an appropriate response struct if it is nil.

Types

type RequestMessage

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

type ResponseMessage

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

ResponseMessage is an interface of FrostFS response message.

type ServerStream

type ServerStream interface {
	Context() context.Context
}

ServerStream is an interface of server-side stream v2.

type SignService

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

func NewUnarySignService

func NewUnarySignService(key *ecdsa.PrivateKey) *SignService

func (*SignService) SignResponse

func (s *SignService) SignResponse(resp ResponseMessage, err error) error

SignResponse response with private key via signature.SignServiceMessage. The signature error affects the result depending on the protocol version:

• if status return is supported, panics since we cannot return the failed status, because it will not be signed.
• otherwise, returns error in order to transport it directly.

func (*SignService) VerifyRequest

func (s *SignService) VerifyRequest(req RequestMessage) error