runtime

type Checkpoint struct {
	ClientID    string
	ContentType string
	Value       json.RawMessage
	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 Config struct {
	ClientID           string
	Kinds              []string
	EntryChannels      []string
	EntryContentTypes  []string
	EntryRoles         []string
	Scope              string
	AfterCursor        string
	Justification      string
	CheckpointInterval time.Duration
	ReconnectMin       time.Duration
	ReconnectMax       time.Duration
}

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

type EventEnvelope struct {
	Event  string
	Kind   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 GRPCEventClient struct {
	Client pb.EventStreamServiceClient
	Auth   GRPCAuth
}

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
}