callback

Documentation

Index

• type AdditionalPayload
• type CallbackApi
  • func NewCallbackApi(gitlabUrl, nodeUUID, secretFilePath string, client *http.Client) (*CallbackApi, error)
  • func (c *CallbackApi) SendFailure(ctx context.Context, callbackParams CallbackParams, indexDir string, ...)
  • func (c *CallbackApi) SendSuccess(ctx context.Context, callbackParams CallbackParams, indexDir string, ...)
• type CallbackBody
• type CallbackFunc
• type CallbackParams

Types

type AdditionalPayload

type AdditionalPayload struct {
	RepoStats *disk_stats.RepoStats `json:"repo_stats,omitempty"`
}

This might get new fields in the future when there will be new callback actions. Right now we add only RepoStats for the index action

type CallbackApi

type CallbackApi struct {
	GitlabURL string
	NodeUUID  string
	Secret    []byte
	Client    *http.Client
}

func NewCallbackApi

func NewCallbackApi(gitlabUrl, nodeUUID, secretFilePath string, client *http.Client) (*CallbackApi, error)

func (*CallbackApi) SendFailure

func (c *CallbackApi) SendFailure(ctx context.Context, callbackParams CallbackParams, indexDir string, repoID uint32, failureReason error)

func (*CallbackApi) SendSuccess

func (c *CallbackApi) SendSuccess(ctx context.Context, callbackParams CallbackParams, indexDir string, repoID uint32)

type CallbackBody

type CallbackBody struct {
	Name              string             `json:"name"`
	Success           bool               `json:"success"`
	Payload           any                `json:"payload"`
	AdditionalPayload *AdditionalPayload `json:"additional_payload,omitempty"`
	Error             string             `json:"error,omitempty"`
}

type CallbackFunc

type CallbackFunc struct {
	OnSuccess func(CallbackParams)
	OnFailure func(CallbackParams, error)
}

type CallbackParams

type CallbackParams struct {
	Name         string `json:"name"`
	RailsPayload any    `json:"payload"`
}