helpers

package

v0.1.0 Latest Latest Go to latest Published: Sep 22, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/acs-dl/orchestrator-svc

Links

Open Source Insights

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 AmqpCfg ¶

func AmqpCfg(r *http.Request) *config.AmqpCfg

func CreateJsonSubmodulesBody ¶

func CreateJsonSubmodulesBody(submodules []string) ([]byte, error)

func CreateRefreshModulePayload ¶

func CreateRefreshModulePayload() (json.RawMessage, error)

func CtxAmqpCfg ¶

func CtxAmqpCfg(entry *config.AmqpCfg) func(context.Context) context.Context

func CtxLog ¶

func CtxLog(entry *logan.Entry) func(context.Context) context.Context

func CtxModulesQ ¶

func CtxModulesQ(entry data.ModuleQ) func(context.Context) context.Context

func CtxPublisher ¶

func CtxPublisher(entry *amqp.Publisher) func(context.Context) context.Context

func CtxRawDB ¶

func CtxRawDB(entry *sql.DB) func(context.Context) context.Context

func CtxRequestTransactionsQ ¶

func CtxRequestTransactionsQ(entry data.RequestTransactions) func(context.Context) context.Context

func CtxRequestsQ ¶

func CtxRequestsQ(entry data.RequestQ) func(context.Context) context.Context

func CtxSender ¶

func CtxSender(entry *sender.Sender) func(context.Context) context.Context

func CtxSubscriber ¶

func CtxSubscriber(entry *amqp.Subscriber) func(context.Context) context.Context

func HandleHttpResponseStatusCode ¶

func HandleHttpResponseStatusCode(response *data.ResponseParams, params data.RequestParams) (*data.ResponseParams, error)

func Log ¶

func Log(r *http.Request) *logan.Entry

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 MakeGetUserRequest(params data.RequestParams, counter int64) (*resources.User, error)

func MakeHttpRequest ¶

func MakeHttpRequest(params data.RequestParams) (*data.ResponseParams, error)

func MakeNoResponseRequest ¶

func MakeNoResponseRequest(params data.RequestParams) error

func ModulesQ ¶

func ModulesQ(r *http.Request) data.ModuleQ

func Publisher ¶

func Publisher(r *http.Request) *amqp.Publisher

func RawDB ¶

func RawDB(r *http.Request) *sql.DB

func RequestTransactionsQ ¶

func RequestTransactionsQ(r *http.Request) data.RequestTransactions

func RequestsQ ¶

func RequestsQ(r *http.Request) data.RequestQ

func RoundDuration ¶

func RoundDuration(durationString string) (time.Duration, error)

func Sender ¶

func Sender(r *http.Request) *sender.Sender

func Subscriber ¶

func Subscriber(r *http.Request) *amqp.Subscriber

func SumStringDurationWithDuration ¶

func SumStringDurationWithDuration(first string, secondDuration time.Duration) (time.Duration, error)

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL