cardactiondispatch

type CallbackFormat string

type CardContext struct {
	TemplateID      string `json:"template_id,omitempty"`
	TemplateVersion string `json:"template_version,omitempty"`
	View            string `json:"view,omitempty"`
	PrincipalType   string `json:"principal_type,omitempty"`
	PrincipalID     string `json:"principal_id,omitempty"`
	SpaceID         string `json:"space_id,omitempty"`
}

type DecisionRequest struct {
	EventID     int64                  `json:"event_id,string"`
	ActionID    string                 `json:"action_id"`
	Decision    string                 `json:"decision"`
	OperatorUID string                 `json:"operator_uid"`
	DocID       string                 `json:"doc_id,omitempty"`
	RequestID   string                 `json:"request_id,omitempty"`
	Inputs      map[string]interface{} `json:"inputs"`
	Data        map[string]interface{} `json:"data,omitempty"`
	MessageID   string                 `json:"message_id"`
	ChannelID   string                 `json:"channel_id"`
	ChannelType uint8                  `json:"channel_type"`
	SpaceID     string                 `json:"space_id,omitempty"`
	// OperatorSpaceID carries the operator's trusted current Space to the
	// decision consumer alongside SpaceID (the card's origin Space), so the
	// consumer can attribute the click without conflating the two.
	OperatorSpaceID string `json:"operator_space_id,omitempty"`
	ActedAt         int64  `json:"acted_at"`
	// contains filtered or unexported fields
}

type DecisionResult struct {
	Disposition  Disposition `json:"disposition"`
	State        State       `json:"state"`
	RequesterUID string      `json:"requester_uid,omitempty"`
	// Authoritative decider identity. Docs is the source of truth for WHO
	// decided; for a duplicate/concurrent click that is the FIRST decider, not
	// the current clicker, so these win over the clicker for display. octo-server
	// resolves the decider's display name and operator Space name from these ids
	// internally (user service + active-membership check) — a caller never sends
	// display copy that overrides them. DecidedAt is the authoritative decision
	// timestamp/label produced by Docs.
	DeciderUID     string            `json:"decider_uid,omitempty"`
	DeciderSpaceID string            `json:"decider_space_id,omitempty"`
	DecidedAt      int64             `json:"decided_at,omitempty"`
	Display        map[string]string `json:"display,omitempty"`
}

type DeliveryError struct {
	Category string
	Status   int
	// contains filtered or unexported fields
}

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

type DispatcherConfig struct {
	LeaseDuration   time.Duration
	PollInterval    time.Duration
	ReclaimInterval time.Duration
	Metrics         *Metrics
	Logger          interface {
		Warn(string, ...zap.Field)
		Error(string, ...zap.Field)
	}
}

type Disposition string

type Event struct {
	EventID     int64  `json:"event_id"`
	SenderUID   string `json:"sender_uid"`
	Owner       string `json:"owner"`
	ActionType  string `json:"action_type"`
	MessageID   string `json:"message_id"`
	ChannelID   string `json:"channel_id"`
	ChannelType uint8  `json:"channel_type"`
	SpaceID     string `json:"space_id,omitempty"`
	ActionID    string `json:"action_id"`
	OperatorUID string `json:"operator_uid"`
	// OperatorSpaceID is the operator's TRUSTED current Space at click time —
	// the value SpaceMiddleware validated and pinned in the request context. It
	// is captured separately from SpaceID (the card/document authoritative origin
	// Space) and never relabels it: the two answer different questions and can
	// differ when the operator acts on a card that originates in another of their
	// Spaces. Empty when the click carried no server-verified Space.
	OperatorSpaceID string                 `json:"operator_space_id,omitempty"`
	ClientToken     string                 `json:"client_token,omitempty"`
	ActedAt         int64                  `json:"acted_at"`
	Inputs          map[string]interface{} `json:"inputs"`
	Data            map[string]interface{} `json:"data,omitempty"`
	Card            CardContext            `json:"card,omitempty"`
}

type Finalizer interface {
	Finalize(ctx context.Context, event Event, result DecisionResult) error
}

type FinalizerFunc func(context.Context, Event, DecisionResult) error

type FinalizerKey struct {
	Owner      string
	ActionType string
}

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

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

type Lease struct {
	Event   Event
	Token   string
	Attempt int
}

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

type NackOutcome string

type NotifyCapability struct {
	SenderUID string
	Owner     string
}

type QueueConfig struct {
	Prefix       string
	LiveTTL      time.Duration
	DLQRetention time.Duration
}

type QueueDepths struct {
	Ready  int64
	Leased int64
	DLQ    int64
}

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

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

type Resolution struct {
	Kind  ResolutionKind
	Route *Route
}

type ResolutionKind string

type Route struct {
	SenderUID      string
	Owner          string
	ActionType     string
	URL            string
	Timeout        time.Duration
	MaxAttempts    int
	BaseBackoff    time.Duration
	MaxBackoff     time.Duration
	MaxInFlight    int
	CallbackFormat CallbackFormat
	// contains filtered or unexported fields
}

type RouteSpec struct {
	SenderUID      string
	Owner          string
	ActionType     string
	URL            string
	SecretEnv      string
	NotifyTokenEnv string
	Timeout        time.Duration
	MaxAttempts    int
	BaseBackoff    time.Duration
	MaxBackoff     time.Duration
	MaxInFlight    int
	CallbackFormat CallbackFormat
}

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

type State string

type ValueStore interface {
	SetValue(value interface{}, key string)
	Value(key string) interface{}
}