changelog

Documentation

Index

• type Client
  • func NewClient(client sqs.Client, queueUrl string) *Client
  • func (c *Client) EmitEvents(ctx context.Context, params Message) error
• type Event
• type Message
• type MessageParams
• type PackageCreateEvent
• type ParentPackage
• type Type
  • func (s Type) MarshalJSON() ([]byte, error)
  • func (s Type) String() string

Types

type Client

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

func NewClient

func NewClient(client sqs.Client, queueUrl string) *Client

func (*Client) EmitEvents

func (c *Client) EmitEvents(ctx context.Context, params Message) error

type Event

type Event struct {
	EventType   Type        `json:"eventType"`
	EventDetail interface{} `json:"eventDetail"`
	Timestamp   time.Time   `json:"timestamp"`
}

type Message

type Message struct {
	DatasetChangelogEventJob MessageParams `json:"DatasetChangelogEventJob"`
}

type MessageParams

type MessageParams struct {
	OrganizationId int64   `json:"organizationId"`
	DatasetId      int64   `json:"datasetId"`
	UserId         string  `json:"userId"`
	Events         []Event `json:"events"`
	TraceId        string  `json:"traceId"`
	Id             string  `json:"id"`
}

type PackageCreateEvent

type PackageCreateEvent struct {
	Id     int64  `json:"id"`
	Name   string `json:"name"`
	NodeId string `json:"nodeId"`
	// contains filtered or unexported fields
}

type ParentPackage

type ParentPackage struct {
	Id     int64  `json:"id"`
	Name   string `json:"name"`
	NodeId string `json:"nodeId"`
}

type Type

type Type int64

const (
	CreatePackage Type = iota
	DeletePackage
)

TODO: add other types based on API

func (Type) MarshalJSON

func (s Type) MarshalJSON() ([]byte, error)

func (Type) String

func (s Type) String() string