v1

Documentation

Index

• type Logic
  • func New(ctx context.Context, c pub.Clock, d db.DB, k kv.KV, tokz *token.Tokenizer) (*Logic, error)
  • func (l *Logic) DeliverActivity(ctx context.Context, jid string, instanceID int64, activity ap.Activity) logic.Error
  • func (l *Logic) GetInstanceSelf(ctx context.Context) (*models.Instance, logic.Error)
  • func (l *Logic) GetOrCreateGeminiIdentity(ctx context.Context, hash string) (*models.GeminiIdentity, logic.Error)
  • func (l *Logic) ProcessActivity(ctx context.Context, jid string, instanceID int64, actorIRI *url.URL, ...) logic.Error
  • func (l *Logic) SetRunner(r runner.Runner)

Types

type Logic

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

Logic contains shared logic for the application.

func New

func New(ctx context.Context, c pub.Clock, d db.DB, k kv.KV, tokz *token.Tokenizer) (*Logic, error)

New created a new logic module.

func (*Logic) DeliverActivity

func (l *Logic) DeliverActivity(ctx context.Context, jid string, instanceID int64, activity ap.Activity) logic.Error

func (*Logic) GetInstanceSelf

func (l *Logic) GetInstanceSelf(ctx context.Context) (*models.Instance, logic.Error)

func (*Logic) GetOrCreateGeminiIdentity

func (l *Logic) GetOrCreateGeminiIdentity(ctx context.Context, hash string) (*models.GeminiIdentity, logic.Error)

func (*Logic) ProcessActivity

func (l *Logic) ProcessActivity(ctx context.Context, jid string, instanceID int64, actorIRI *url.URL, activity ap.Activity) logic.Error

func (*Logic) SetRunner

func (l *Logic) SetRunner(r runner.Runner)