Documentation ¶
Index ¶
- func AmqpCfg(r *http.Request) *config.AmqpCfg
- func CreateJsonSubmodulesBody(submodules []string) ([]byte, error)
- func CreateRefreshModulePayload() (json.RawMessage, error)
- func CtxAmqpCfg(entry *config.AmqpCfg) func(context.Context) context.Context
- func CtxLog(entry *logan.Entry) func(context.Context) context.Context
- func CtxModulesQ(entry data.ModuleQ) func(context.Context) context.Context
- func CtxPublisher(entry *amqp.Publisher) func(context.Context) context.Context
- func CtxRawDB(entry *sql.DB) func(context.Context) context.Context
- func CtxRequestTransactionsQ(entry data.RequestTransactions) func(context.Context) context.Context
- func CtxRequestsQ(entry data.RequestQ) func(context.Context) context.Context
- func CtxSender(entry *sender.Sender) func(context.Context) context.Context
- func CtxSubscriber(entry *amqp.Subscriber) func(context.Context) context.Context
- func HandleHttpResponseStatusCode(response *data.ResponseParams, params data.RequestParams) (*data.ResponseParams, error)
- func Log(r *http.Request) *logan.Entry
- func MakeCheckSubmoduleRequest(params data.RequestParams) (*resources.LinkResponse, error)
- func MakeGetEstimatedTimeRequest(params data.RequestParams) (*resources.EstimatedTimeResponse, error)
- func MakeGetRoleRequest(params data.RequestParams) (*resources.RoleResponse, error)
- func MakeGetRolesRequest(params data.RequestParams) (*data.ModuleRolesResponse, error)
- func MakeGetUserRequest(params data.RequestParams, counter int64) (*resources.User, error)
- func MakeHttpRequest(params data.RequestParams) (*data.ResponseParams, error)
- func MakeNoResponseRequest(params data.RequestParams) error
- func ModulesQ(r *http.Request) data.ModuleQ
- func Publisher(r *http.Request) *amqp.Publisher
- func RawDB(r *http.Request) *sql.DB
- func RequestTransactionsQ(r *http.Request) data.RequestTransactions
- func RequestsQ(r *http.Request) data.RequestQ
- func RoundDuration(durationString string) (time.Duration, error)
- func Sender(r *http.Request) *sender.Sender
- func Subscriber(r *http.Request) *amqp.Subscriber
- func SumStringDurationWithDuration(first string, secondDuration time.Duration) (time.Duration, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateRefreshModulePayload ¶
func CreateRefreshModulePayload() (json.RawMessage, error)
func CtxRequestTransactionsQ ¶
func CtxSubscriber ¶
func HandleHttpResponseStatusCode ¶
func HandleHttpResponseStatusCode(response *data.ResponseParams, params data.RequestParams) (*data.ResponseParams, error)
func MakeCheckSubmoduleRequest ¶
func MakeCheckSubmoduleRequest(params data.RequestParams) (*resources.LinkResponse, error)
func MakeGetEstimatedTimeRequest ¶
func MakeGetEstimatedTimeRequest(params data.RequestParams) (*resources.EstimatedTimeResponse, error)
func MakeGetRoleRequest ¶
func MakeGetRoleRequest(params data.RequestParams) (*resources.RoleResponse, error)
func MakeGetRolesRequest ¶
func MakeGetRolesRequest(params data.RequestParams) (*data.ModuleRolesResponse, error)
func MakeGetUserRequest ¶
func MakeHttpRequest ¶
func MakeHttpRequest(params data.RequestParams) (*data.ResponseParams, error)
func MakeNoResponseRequest ¶
func MakeNoResponseRequest(params data.RequestParams) error
func RequestTransactionsQ ¶
func RequestTransactionsQ(r *http.Request) data.RequestTransactions
func Subscriber ¶
func Subscriber(r *http.Request) *amqp.Subscriber
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.