bond

README

bond

A tiny monorepo-friendly core for typed contracts and temporal adapters.

Documentation

Index

• Constants
• Variables
• type Contract
  • func (c Contract[I, O]) Activity() string
  • func (c Contract[I, O]) Queue() string
  • func (c Contract[I, O]) Workflow() string
• type Handler
• type HandlerFunc
  • func (h HandlerFunc[I, O]) Handle(parent context.Context, input I) (O, error)
• type Priority
• type Strategy

Constants

const (
	Async Strategy = "async"
	Sync  Strategy = "sync"

	High Priority = "high"
	Low  Priority = "low"
)

Variables

var ErrTimeout = errors.New("timed out")

Types

type Contract

type Contract[I, O any] struct {
	Version  string   // example: "v1", "v2"
	Priority Priority // example: "high", "low"
	Strategy Strategy
	Domain   string
	Name     string
}

func (Contract[I, O]) Activity

func (c Contract[I, O]) Activity() string

func (Contract[I, O]) Queue

func (c Contract[I, O]) Queue() string

func (Contract[I, O]) Workflow

func (c Contract[I, O]) Workflow() string

type Handler

type Handler[Input, Output any] interface {
	Handle(context.Context, Input) (Output, error)
}

type HandlerFunc

type HandlerFunc[I, O any] func(context.Context, I) (O, error)

func (HandlerFunc[I, O]) Handle

func (h HandlerFunc[I, O]) Handle(parent context.Context, input I) (O, error)

type Priority

type Priority string

type Strategy

type Strategy string