model

Documentation

Index

• type AwsControlRecord
• type AwsControlType
• type AwsEventBus
• type AwsEventHeaderRecord
• type AwsEventHeaderRecordPage
• type AwsEventRecord
• type AwsEventRecordPage
• type AwsEventStore
• type AwsGraphqlGateway
• type AwsGraphqlRequest
• type AwsGraphqlResponse
• type AwsObjectStore
• type AwsStateRecord
• type AwsStateRecordPage
• type AwsStateStore

Types

type AwsControlRecord

type AwsControlRecord struct {
	ControlGroup   string         `json:"control_group,omitempty"`
	ControlID      string         `json:"control_id,omitempty"`
	ControlIntent  uint64         `json:"control_intent,omitempty"`
	ControlType    AwsControlType `json:"control_type,omitempty"`
	ControlTime    int64          `json:"control_time,omitempty"`
	HandlerID      string         `json:"handler_id,omitempty"`
	HandlerVersion string         `json:"handler_version,omitempty"`
	HandlerTimeout uint64         `json:"handler_timeout,omitempty"`
	EventSource    string         `json:"event_source,omitempty"`
	EventID        string         `json:"event_id,omitempty"`
	Transaction    string         `json:"transaction,omitempty"`
}

type AwsControlType

type AwsControlType string

const (
	BlockControl   AwsControlType = "B"
	ConfirmControl AwsControlType = "C"
)

type AwsEventBus

type AwsEventBus interface {
	PublishEvent(ctx context.Context, event *AwsEventRecord)
}

type AwsEventHeaderRecord

type AwsEventHeaderRecord struct {
	EventSource *string `json:"event_source,omitempty"`
	EventID     *string `json:"event_id,omitempty"`
	EventClass  *string `json:"event_class,omitempty"`
	EventType   *string `json:"event_type,omitempty"`
	EventTime   *int64  `json:"event_time,omitempty"`
	EventDay    *string `json:"event_day,omitempty"`
	EventAuthor *string `json:"event_author,omitempty"`
}

type AwsEventHeaderRecordPage

type AwsEventHeaderRecordPage struct {
	Items     []*AwsEventHeaderRecord
	NextToken *string
}

type AwsEventRecord

type AwsEventRecord struct {
	EventSource     *string                 `json:"event_source,omitempty"`
	EventID         *string                 `json:"event_id,omitempty"`
	EventClass      *string                 `json:"event_class,omitempty"`
	EventType       *string                 `json:"event_type,omitempty"`
	EventTime       *int64                  `json:"event_time,omitempty"`
	EventDay        *string                 `json:"event_day,omitempty"`
	EventAuthor     *string                 `json:"event_author,omitempty"`
	EventData       *map[string]interface{} `json:"event_data,omitempty"`
	EntityID        *string                 `json:"entity_id,omitempty"`
	EntityType      *string                 `json:"entity_type,omitempty"`
	EntityState     *map[string]interface{} `json:"entity_state,omitempty"`
	EntityCreatedAt *int64                  `json:"entity_created_at,omitempty"`
	EntityCreatedBy *string                 `json:"entity_created_by,omitempty"`
	TriggerSource   *string                 `json:"trigger_source,omitempty"`
	TriggerID       *string                 `json:"trigger_id,omitempty"`
	Transaction     *string                 `json:"transaction,omitempty"`
	Reference       *string                 `json:"reference,omitempty"`
	ContentLocation string                  `json:"content_location,omitempty"`
	ContentType     string                  `json:"content_type,omitempty"`
	ContentEncoding string                  `json:"content_encoding,omitempty"`
	Content         []byte                  `json:"content,omitempty"`
}

type AwsEventRecordPage

type AwsEventRecordPage struct {
	Items     []*AwsEventRecord
	NextToken *string
}

type AwsEventStore

type AwsEventStore interface {
	CreateControlRecord(ctx context.Context, record *AwsControlRecord)
	CreateUncontrolledEventRecord(ctx context.Context, record *AwsEventRecord)
	CreateControlledEventRecord(ctx context.Context, event *AwsEventRecord, control *AwsControlRecord)

	GetControlRecords(ctx context.Context, group string) []*AwsControlRecord
	GetEventRecordByID(ctx context.Context, source string, id string) *AwsEventRecord
	GetLastEventRecord(ctx context.Context, source string) *AwsEventRecord

	GetEventHeaders(ctx context.Context, source string, after *string, before *string, nextToken *string, limit *int64) *AwsEventHeaderRecordPage
	GetSourceEvents(ctx context.Context, source string, after *time.Time, before *time.Time, nextToken *string, limit *int64) *AwsEventRecordPage
	GetDayEvents(ctx context.Context, day string, after *time.Time, before *time.Time, nextToken *string, limit *int64) *AwsEventRecordPage
	GetTypeEvents(ctx context.Context, typ string, after *time.Time, before *time.Time, nextToken *string, limit *int64) *AwsEventRecordPage
	GetAuthorEvents(ctx context.Context, author string, after *time.Time, before *time.Time, nextToken *string, limit *int64) *AwsEventRecordPage
	GetTransactionEvents(ctx context.Context, transaction string, after *time.Time, before *time.Time, nextToken *string, limit *int64) *AwsEventRecordPage
}

type AwsGraphqlGateway

type AwsGraphqlGateway interface {
	ExecuteGraphql(ctx context.Context, request *AwsGraphqlRequest) *AwsGraphqlResponse
}

type AwsGraphqlRequest

type AwsGraphqlRequest struct {
	Query     string                 `json:"query"`
	Variables map[string]interface{} `json:"variables"`
}

type AwsGraphqlResponse

type AwsGraphqlResponse struct {
	Data   map[string]interface{}   `json:"data"`
	Errors []map[string]interface{} `json:"errors"`
}

type AwsObjectStore

type AwsObjectStore interface {
	GetRawObject(ctx context.Context, id string) []byte
	SaveRawObject(ctx context.Context, id string, buffer []byte)
	GetJsonObject(ctx context.Context, id string, v interface{})
	SaveJsonObject(ctx context.Context, id string, v interface{})
}

type AwsStateRecord

type AwsStateRecord struct {
	Type      string                 `json:"type,omitempty"`
	ID        string                 `json:"id,omitempty"`
	Version   uint64                 `json:"version,omitempty"`
	State     map[string]interface{} `json:"state,omitempty"`
	UpdatedAt int64                  `json:"updated_at,omitempty"`
	UpdatedBy string                 `json:"updated_by,omitempty"`
	CreatedAt int64                  `json:"created_at,omitempty"`
	CreatedBy string                 `json:"created_by,omitempty"`

	ContentLocation string `json:"content_location,omitempty"`
	ContentType     string `json:"content_type,omitempty"`
	ContentEncoding string `json:"content_encoding,omitempty"`
	Content         []byte `json:"content,omitempty"`
}

type AwsStateRecordPage

type AwsStateRecordPage struct {
	Items     []*AwsStateRecord
	NextToken *string
}

type AwsStateStore

type AwsStateStore interface {
	UpdateState(ctx context.Context, state *AwsStateRecord)
	UpdateStates(ctx context.Context, state []*AwsStateRecord)
	GetStates(ctx context.Context, typ string, after *time.Time, nextToken *string, limit *int64) *AwsStateRecordPage
}