composefetcher

Documentation

Index

• Constants
• type ComposeClient
• type ComposeEventFetcher
  • func New(cfg Config) (*ComposeEventFetcher, error)
  • func (e *ComposeEventFetcher) FetchEvents(ctx context.Context, lastEvent *eventio.RawEvent) ([]eventio.RawEvent, error)
  • func (e *ComposeEventFetcher) Kind() string
• type Config

Constants

const (
	TimePrecisionOffset = -1 * time.Second
	DefaultFetchLimit   = 50
	Kind                = "compose"
)

const (
	DeploymentScaleMembersEvent = "deployment.scale.members"
)

Types

type ComposeClient

type ComposeClient interface {
	GetAuditEvents(params composeapi.AuditEventsParams) (*[]composeapi.AuditEvent, []error)
}

type ComposeEventFetcher

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

func New

func New(cfg Config) (*ComposeEventFetcher, error)

New creates a new EventFetcher for fetching compose events

func (*ComposeEventFetcher) FetchEvents

func (e *ComposeEventFetcher) FetchEvents(ctx context.Context, lastEvent *eventio.RawEvent) ([]eventio.RawEvent, error)

func (*ComposeEventFetcher) Kind

func (e *ComposeEventFetcher) Kind() string

type Config

type Config struct {
	// Logger overrides the default logger
	Logger lager.Logger
	// APIKey sets the API for querying events
	APIKey string
	// Client overrides the default compose client
	Client ComposeClient
	// FetchLimit sets the batch size for each http request
	FetchLimit int
}