pkg

Documentation

Index

• type Event
• type EventStatus
  • func (es EventStatus) String() string
• type Header

Types

type Event

type Event struct {
	ID               uuid.UUID    `db:"id"`
	CreatedTimestamp time.Time    `db:"created_timestamp"`
	UpdatedTimestamp sql.NullTime `db:"updated_timestamp"`
	Status           string       `db:"status"`
	Topic            string       `db:"topic"`
	Partition        int32        `db:"partition"`
	Key              string       `db:"key"`
	Message          []byte       `db:"message"`
	Headers          []Header     `db:"headers"`
	InstanceID       uuid.UUID    `db:"instance_id"`
}

type EventStatus

type EventStatus int8

const (
	PENDING EventStatus = iota
	SENT
)

func (EventStatus) String

func (es EventStatus) String() string

type Header

type Header struct {
	Key   string          `json:"key"`
	Value json.RawMessage `json:"value"`
}