cardactiondispatch

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"`
	ActedAt     int64                  `json:"acted_at"`
}

type DecisionResult struct {
	Disposition  Disposition       `json:"disposition"`
	State        State             `json:"state"`
	RequesterUID string            `json:"requester_uid,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"`
	ClientToken string                 `json:"client_token,omitempty"`
	ActedAt     int64                  `json:"acted_at"`
	Inputs      map[string]interface{} `json:"inputs"`
	Data        map[string]interface{} `json:"data,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
	// 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
}

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

type State string

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