target

Documentation

Index

• Constants
• type WebhookArgs
  • func (w WebhookArgs) Validate() error
• type WebhookTarget
  • func NewWebhookTarget(ctx context.Context, id string, args WebhookArgs, loggerOnce logger.LogOnce, ...) (*WebhookTarget, error)
  • func (target *WebhookTarget) Close() error
  • func (target *WebhookTarget) ID() event.TargetID
  • func (target *WebhookTarget) IsActive() (bool, error)
  • func (target *WebhookTarget) Send(eventData event.Event) (resp *http.Response, err error)
  • func (target *WebhookTarget) Stat() event.TargetStat

Constants

const (
	WebhookEndpoint   = "endpoint"
	WebhookAuthToken  = "auth_token"
	WebhookClientCert = "client_cert"
	WebhookClientKey  = "client_key"

	EnvWebhookEnable     = "MINIO_LAMBDA_WEBHOOK_ENABLE"
	EnvWebhookEndpoint   = "MINIO_LAMBDA_WEBHOOK_ENDPOINT"
	EnvWebhookAuthToken  = "MINIO_LAMBDA_WEBHOOK_AUTH_TOKEN"
	EnvWebhookClientCert = "MINIO_LAMBDA_WEBHOOK_CLIENT_CERT"
	EnvWebhookClientKey  = "MINIO_LAMBDA_WEBHOOK_CLIENT_KEY"
)

Webhook constants

Types

type WebhookArgs

type WebhookArgs struct {
	Enable     bool            `json:"enable"`
	Endpoint   xnet.URL        `json:"endpoint"`
	AuthToken  string          `json:"authToken"`
	Transport  *http.Transport `json:"-"`
	ClientCert string          `json:"clientCert"`
	ClientKey  string          `json:"clientKey"`
}

WebhookArgs - Webhook target arguments.

func (WebhookArgs) Validate

func (w WebhookArgs) Validate() error

Validate WebhookArgs fields

type WebhookTarget

type WebhookTarget struct {
	// contains filtered or unexported fields
}

WebhookTarget - Webhook target.

func NewWebhookTarget

func NewWebhookTarget(ctx context.Context, id string, args WebhookArgs, loggerOnce logger.LogOnce, transport *http.Transport) (*WebhookTarget, error)

NewWebhookTarget - creates new Webhook target.

func (*WebhookTarget) Close

func (target *WebhookTarget) Close() error

Close the target. Will cancel all active requests.

func (*WebhookTarget) ID

func (target *WebhookTarget) ID() event.TargetID

ID - returns target ID.

func (*WebhookTarget) IsActive

func (target *WebhookTarget) IsActive() (bool, error)

IsActive - Return true if target is up and active

func (*WebhookTarget) Send

func (target *WebhookTarget) Send(eventData event.Event) (resp *http.Response, err error)

Send - sends an event to the webhook.

func (*WebhookTarget) Stat

func (target *WebhookTarget) Stat() event.TargetStat

Stat - returns lamdba webhook target statistics such as current calls in progress, successfully completed functions failed functions.