rfq

Documentation

Index

• type Service
  • func (s *Service) Maker(_ context.Context, _ *connect.BidiStream[v1.QuoteResponse, v1.QuoteRequest]) error
  • func (s *Service) Taker(_ context.Context, _ *connect.BidiStream[v1.QuoteRequest, v1.QuoteResponse]) error
  • func (s *Service) WebTaker(_ context.Context, _ *connect.Request[v1.QuoteRequest], ...) error

Types

type Service

type Service struct {
}

Service holds state for the rfq.Service.

func (*Service) Maker

func (s *Service) Maker(
	_ context.Context,
	_ *connect.BidiStream[v1.QuoteResponse, v1.QuoteRequest],
) error

Maker sends quotes to takers via a stream of QuoteResponse messages and receives a stream of QuoteRequest messages.

func (*Service) Taker

func (s *Service) Taker(
	_ context.Context,
	_ *connect.BidiStream[v1.QuoteRequest, v1.QuoteResponse],
) error

Taker requests quotes from makers via a stream of QuoteRequest messages and receives a stream of QuoteResponse messages.

func (*Service) WebTaker

func (s *Service) WebTaker(
	_ context.Context,
	_ *connect.Request[v1.QuoteRequest],
	_ *connect.ServerStream[v1.QuoteResponse],
) error

WebTaker requests quotes from makers via a single QuoteRequest message and receives a stream of QuoteResponse messages (for use by gRPC-web clients).