config

Documentation

Index

• type Common
  • func NewCommon[C responsewriter.Client]() Common[C]
• type ErrorFunc
• type HandlerFunc
• type ProcessReceivedMessageFunc

Types

type Common

type Common[C responsewriter.Client] struct {
	LimitClientParallelRequests         int64
	LimitClientEndpointParallelRequests int64
	Ctx                                 context.Context
	Errors                              ErrorFunc
	PeriodicRunner                      periodic.Func
	MessagePool                         *pool.Pool
	GetToken                            client.GetTokenFunc
	MaxMessageSize                      uint32
	BlockwiseTransferTimeout            time.Duration
	BlockwiseSZX                        blockwise.SZX
	BlockwiseEnable                     bool
	ProcessReceivedMessage              ProcessReceivedMessageFunc[C]
	ReceivedMessageQueueSize            int
}

func NewCommon

func NewCommon[C responsewriter.Client]() Common[C]

type ErrorFunc

type ErrorFunc = func(error)

type HandlerFunc

type HandlerFunc[C responsewriter.Client] func(w *responsewriter.ResponseWriter[C], r *pool.Message)

type ProcessReceivedMessageFunc

type ProcessReceivedMessageFunc[C responsewriter.Client] func(req *pool.Message, cc C, handler HandlerFunc[C])