Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Interface ¶
type Interface interface { Get(ctx context.Context, key string) (LogState, error) Put(ctx context.Context, key string, state LogState) error }
Interface for state storage - we need to know if log is pending or finished
type LogState ¶
type LogState byte
We need to know where to get logs from. For pending logs it'll be fetched from the buffer For completed logs they'll be fetched from the s3 bucket
type NatsKV ¶
type NatsKV interface { Get(ctx context.Context, key string) (jetstream.KeyValueEntry, error) Put(ctx context.Context, key string, value []byte) (uint64, error) }
KV is type implicitly interfaced from NATS
Click to show internal directories.
Click to hide internal directories.