runtime

type BackgroundErrorSource interface {
	BackgroundErrors() <-chan error
}

type BootstrapProcessor interface {
	Bootstrap(ctx context.Context, events EventClient, save func(context.Context) error) (afterCursor string, err error)
}

type Checkpoint struct {
	ClientID    string
	ContentType string
	Value       json.RawMessage
	Revision    string
	UpdatedAt   time.Time
}

type CheckpointClient interface {
	Get(ctx context.Context, clientID string) (Checkpoint, error)
	Put(ctx context.Context, clientID, contentType string, value json.RawMessage) (Checkpoint, error)
}

type CheckpointLease struct {
	Token      string
	Generation uint64
	ExpiresAt  time.Time
}

type Config struct {
	ClientID           string
	Kinds              []string
	EntryChannels      []string
	EntryContentTypes  []string
	EntryRoles         []string
	Scope              string
	AfterCursor        string
	Justification      string
	Detail             string
	CheckpointInterval time.Duration
	ReconnectMin       time.Duration
	ReconnectMax       time.Duration
	LeaseTTL           time.Duration
	OnReady            func(bool)
}

type EventClient interface {
	Subscribe(ctx context.Context, req SubscribeRequest) (EventStream, error)
}

type EventEnvelope struct {
	Event  string
	Kind   string
	Change string
	Data   json.RawMessage
	Cursor string
	Time   time.Time
}

type EventProcessor interface {
	ContentType() string
	Load(state json.RawMessage) error
	Handle(ctx context.Context, event EventEnvelope) error
	Snapshot() (json.RawMessage, error)
	Flush(ctx context.Context) error
}

type EventStream interface {
	Recv() (EventEnvelope, error)
}

type GRPCAuth struct {
	APIKey      string
	BearerToken string
	ClientID    string
}

type GRPCCheckpointClient struct {
	Client pb.AdminCheckpointServiceClient
	Auth   GRPCAuth
}

type GRPCDialConfig struct {
	TLS           bool
	CAFile        string
	AllowInsecure bool
	// MaxReceiveBytes raises the default receive allowance when a processor
	// accepts individual records larger than the service default.
	MaxReceiveBytes int
}

type GRPCEventClient struct {
	Client pb.EventStreamServiceClient
	Auth   GRPCAuth
}

type LeaseGenerationConsumer interface {
	SetLeaseGeneration(generation uint64) error
}

type LeasedCheckpointClient interface {
	CheckpointClient
	PutCAS(ctx context.Context, clientID, contentType string, value json.RawMessage, expectedRevision, leaseToken string) (Checkpoint, error)
	AcquireLease(ctx context.Context, clientID string, ttl time.Duration) (CheckpointLease, error)
	RenewLease(ctx context.Context, clientID, leaseToken string, ttl time.Duration) (CheckpointLease, error)
	ReleaseLease(ctx context.Context, clientID, leaseToken string) error
}

type Runtime struct {
	Events      EventClient
	Checkpoints CheckpointClient
	Processor   EventProcessor
	Config      Config
	// contains filtered or unexported fields
}

type SubscribeRequest struct {
	Kinds             []string
	Detail            string
	AfterCursor       string
	Scope             string
	Justification     string
	EntryChannels     []string
	EntryContentTypes []string
	EntryRoles        []string
	InitialState      string
}