domain

Documentation

Index

• Variables
• type Aggregate
  • func (a *Aggregate) PullEvents() []Event
  • func (a *Aggregate) PushEvents(events ...Event)
• type BasicService
• type Event
• type EventAction
  • func (e EventAction) String() string
• type ViewList

Variables

var EventActionMap = map[EventAction]string{
	UnknownAction:    "UNKNOWN",
	CreateAction:     "CREATE",
	UpdateAction:     "UPDATE",
	HardDeleteAction: "HARD_DELETE",
	SoftDeleteAction: "SOFT_DELETE",
}

var EventActionMapStr = map[string]EventAction{
	"UNKNOWN":     UnknownAction,
	"CREATE":      CreateAction,
	"UPDATE":      UpdateAction,
	"HARD_DELETE": HardDeleteAction,
	"SOFT_DELETE": SoftDeleteAction,
}

var (
	Validate *validator.Validate
)

Types

type Aggregate

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

func (*Aggregate) PullEvents

func (a *Aggregate) PullEvents() []Event

func (*Aggregate) PushEvents

func (a *Aggregate) PushEvents(events ...Event)

type BasicService

type BasicService[T any] interface {
	Create(ctx context.Context, args any) error
	Update(ctx context.Context, args any) error
	Delete(ctx context.Context, id string) error
	GetByID(ctx context.Context, id string) (T, error)
	List(ctx context.Context, cr storage.Criteria) ([]T, storage.PageToken, error)
}

type Event

type Event interface {
	GetKey() string
}

type EventAction

type EventAction int

const (
	UnknownAction EventAction = iota
	CreateAction
	UpdateAction
	HardDeleteAction
	SoftDeleteAction
)

func (EventAction) String

func (e EventAction) String() string

type ViewList

type ViewList struct {
	Items         any    `json:"items"`
	Count         int    `json:"count"`
	NextPageToken string `json:"next_page_token"`
}