event

type ARN ¶

type ARN struct {
	TargetID
	// contains filtered or unexported fields
}

ARN - SQS resource name representation.

func ParseARN(s string) (*ARN, error)

func (arn ARN) String() string

type ErrARNNotFound ¶

type ErrARNNotFound struct {
	ARN ARN
}

ErrARNNotFound - ARN not found error.

func (err ErrARNNotFound) Error() string

type ErrInvalidARN ¶

type ErrInvalidARN struct {
	ARN string
}

ErrInvalidARN - invalid ARN error.

func (err ErrInvalidARN) Error() string

type ErrUnknownRegion ¶

type ErrUnknownRegion struct {
	Region string
}

ErrUnknownRegion - unknown region error.

func (err ErrUnknownRegion) Error() string

type Event ¶

type Event struct {
	ProtocolVersion  string            `json:"protocolVersion"`
	GetObjectContext *GetObjectContext `json:"getObjectContext"`
	UserIdentity     Identity          `json:"userIdentity"`
	UserRequest      UserRequest       `json:"userRequest"`
}

Event represents lambda function event, this is undocumented in AWS S3. This structure bases itself on this structure but there is no binding.

{
  "xAmzRequestId": "a2871150-1df5-4dc9-ad9f-3da283ca1bf3",
  "getObjectContext": {
    "outputRoute": "...",
    "outputToken": "...",
    "inputS3Url": "<presignedURL>"
  },
  "configuration": { // not useful in MinIO
    "accessPointArn": "...",
    "supportingAccessPointArn": "...",
    "payload": ""
  },
  "userRequest": {
    "url": "...",
    "headers": {
      "Host": "...",
      "X-Amz-Content-SHA256": "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"
    }
  },
  "userIdentity": {
    "type": "IAMUser",
    "principalId": "AIDAJF5MO57RFXQCE5ZNC",
    "arn": "...",
    "accountId": "...",
    "accessKeyId": "AKIA3WNQJCXE2DYPAU7R"
  },
  "protocolVersion": "1.00"
}

type GetObjectContext ¶

type GetObjectContext struct {
	OutputRoute string `json:"outputRoute"`
	OutputToken string `json:"outputToken"`
	InputS3URL  string `json:"inputS3Url"`
}

GetObjectContext provides the necessary details to perform download of the object, and return back the processed response to the server.

type Identity ¶

type Identity struct {
	Type        string `json:"type"`
	PrincipalID string `json:"principalId"`
	AccessKeyID string `json:"accessKeyId"`
}

Identity represents access key who caused the event.

type Target ¶

type Target interface {
	ID() TargetID
	IsActive() (bool, error)
	Send(Event) (*http.Response, error)
	Stat() TargetStat
	Close() error
}

Target - lambda target interface

type TargetID ¶

type TargetID struct {
	ID   string
	Name string
}

TargetID - holds identification and name strings of notification target.

func (tid TargetID) MarshalJSON() ([]byte, error)

func (tid TargetID) String() string

func (tid TargetID) ToARN(region string) ARN

func (tid *TargetID) UnmarshalJSON(data []byte) error

type TargetIDResult ¶

type TargetIDResult struct {
	// ID where the remove or send were initiated.
	ID TargetID
	// Stores any error while removing a target or while sending an event.
	Err error
}

TargetIDResult returns result of Remove/Send operation, sets err if any for the associated TargetID

type TargetIDSet ¶

type TargetIDSet map[TargetID]struct{}

TargetIDSet - Set representation of TargetIDs.

func NewTargetIDSet(targetIDs ...TargetID) TargetIDSet

func (set TargetIDSet) Clone() TargetIDSet

func (set TargetIDSet) Difference(sset TargetIDSet) TargetIDSet

func (set TargetIDSet) IsEmpty() bool

func (set TargetIDSet) Union(sset TargetIDSet) TargetIDSet

type TargetList ¶

type TargetList struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

TargetList - holds list of targets indexed by target ID.

func NewTargetList() *TargetList

func (list *TargetList) Add(targets ...Target) error

func (list *TargetList) Empty() bool

func (list *TargetList) List(region string) []ARN

func (list *TargetList) Lookup(arnStr string) (Target, error)

func (list *TargetList) Remove(targetIDSet TargetIDSet)

func (list *TargetList) Send(event Event, id TargetID) (*http.Response, error)

func (list *TargetList) Stats() TargetStats

func (list *TargetList) TargetMap() map[TargetID]Target

func (list *TargetList) Targets() []Target

type TargetStat ¶

type TargetStat struct {
	ID             TargetID
	ActiveRequests int64
	TotalRequests  int64
	FailedRequests int64
}

TargetStat is the stats of a single target.

type TargetStats ¶

type TargetStats struct {
	TargetStats map[string]TargetStat
}

TargetStats is a collection of stats for multiple targets.

type UserRequest ¶

type UserRequest struct {
	URL     string      `json:"url"`
	Headers http.Header `json:"headers"`
}

UserRequest user request headers