activity

Documentation

Index

• Constants
• Variables
• type Actor
• type AppConfig
• type Filter
• type PagedActivity
• type Repository
• type Service
  • func NewService(appConfig AppConfig, repository Repository) *Service
  • func (s Service) List(ctx context.Context, filter Filter) (PagedActivity, error)
  • func (s Service) Log(ctx context.Context, action string, actor Actor, data any) error
• type StdoutRepository
  • func NewStdoutRepository(writer io.Writer) *StdoutRepository
  • func (r StdoutRepository) Insert(ctx context.Context, log *audit.Log) error
  • func (r StdoutRepository) List(ctx context.Context, filter Filter) ([]audit.Log, error)

Constants

const (
	SinkTypeDB     = "db"
	SinkTypeStdout = "stdout"
	SinkTypeNone   = "none"
)

Variables

var (
	ErrInvalidUUID   = errors.New("invalid syntax of uuid")
	ErrInvalidData   = errors.New("invalid log data")
	ErrInvalidFilter = errors.New("invalid activity filter")
	ErrNotFound      = errors.New("activities not found")
)

Types

type Actor

type Actor struct {
	ID    string
	Email string
}

type AppConfig

type AppConfig struct {
	Version string
}

type Filter

type Filter struct {
	Actor     string
	Action    string
	Data      map[string]string
	Metadata  map[string]string
	StartTime time.Time
	EndTime   time.Time
	Limit     int32
	Page      int32
}

type PagedActivity

type PagedActivity struct {
	Count      int32
	Activities []audit.Log
}

type Repository

type Repository interface {
	Insert(ctx context.Context, log *audit.Log) error
	List(ctx context.Context, filter Filter) ([]audit.Log, error)
}

type Service

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

func NewService

func NewService(appConfig AppConfig, repository Repository) *Service

func (Service) List

func (s Service) List(ctx context.Context, filter Filter) (PagedActivity, error)

func (Service) Log

func (s Service) Log(ctx context.Context, action string, actor Actor, data any) error

type StdoutRepository

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

func NewStdoutRepository

func NewStdoutRepository(writer io.Writer) *StdoutRepository

func (StdoutRepository) Insert

func (r StdoutRepository) Insert(ctx context.Context, log *audit.Log) error

func (StdoutRepository) List

func (r StdoutRepository) List(ctx context.Context, filter Filter) ([]audit.Log, error)