activity

Documentation

Index

• type Emitter
  • func NewEmitter(recorder Recorder, events provider.EventProvider) *Emitter
  • func (e *Emitter) Emit(ctx context.Context, input RecordInput) (*catalogdomain.ActivityEvent, error)
• type EntRecorder
  • func (r EntRecorder) RecordActivityEvent(ctx context.Context, input RecordInput) (catalogdomain.ActivityEvent, error)
• type RecordFunc
  • func (fn RecordFunc) RecordActivityEvent(ctx context.Context, input RecordInput) (catalogdomain.ActivityEvent, error)
• type RecordInput
• type Recorder

Types

type Emitter

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

func NewEmitter

func NewEmitter(recorder Recorder, events provider.EventProvider) *Emitter

func (*Emitter) Emit

func (e *Emitter) Emit(ctx context.Context, input RecordInput) (*catalogdomain.ActivityEvent, error)

type EntRecorder

type EntRecorder struct {
	Client *ent.Client
}

func (EntRecorder) RecordActivityEvent

func (r EntRecorder) RecordActivityEvent(ctx context.Context, input RecordInput) (catalogdomain.ActivityEvent, error)

type RecordFunc

type RecordFunc func(context.Context, RecordInput) (catalogdomain.ActivityEvent, error)

func (RecordFunc) RecordActivityEvent

func (fn RecordFunc) RecordActivityEvent(ctx context.Context, input RecordInput) (catalogdomain.ActivityEvent, error)

type RecordInput

type RecordInput struct {
	ProjectID uuid.UUID
	TicketID  *uuid.UUID
	AgentID   *uuid.UUID
	EventType activityevent.Type
	Message   string
	Metadata  map[string]any
	CreatedAt time.Time
}

type Recorder

type Recorder interface {
	RecordActivityEvent(ctx context.Context, input RecordInput) (catalogdomain.ActivityEvent, error)
}