config

Documentation

Index

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

Types

type Common

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

func NewCommon

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

type ErrorFunc

type ErrorFunc = func(error)

type GoPoolFunc

type GoPoolFunc[C responsewriter.Client] func(processReqFunc ProcessRequestFunc[C], req *pool.Message, cc C, handler HandlerFunc[C]) error

type HandlerFunc

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

type ProcessRequestFunc

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