api

type BaseDriver struct{}

type ComplexKey struct {
	KeyGroup  []byte
	Key       []byte
	Namespace []byte
	UserKey   []byte
}

type Context interface {
	Emit(targetID uint32, data []byte) error
	EmitWatermark(targetID uint32, watermark uint64) error
	GetOrCreateStore(name string) (Store, error)
	Config() map[string]string
	Close() error
}

type Driver interface {
	Init(ctx Context, config map[string]string) error
	Process(ctx Context, sourceID uint32, data []byte) error
	ProcessWatermark(ctx Context, sourceID uint32, watermark uint64) error
	TakeCheckpoint(ctx Context, checkpointID uint64) error
	CheckHeartbeat(ctx Context) bool
	Close(ctx Context) error
	Exec(ctx Context, className string, modules []Module) error
	Custom(ctx Context, payload []byte) ([]byte, error)
}

type ErrorCode string

type Iterator interface {
	HasNext() (bool, error)
	Next() (key []byte, value []byte, ok bool, err error)
	Close() error
}

type Module struct {
	Name  string
	Bytes []byte
}

type SDKError struct {
	Code    ErrorCode
	Message string
}

type Store interface {
	PutState(key []byte, value []byte) error
	GetState(key []byte) (value []byte, found bool, err error)
	DeleteState(key []byte) error
	ListStates(startInclusive []byte, endExclusive []byte) ([][]byte, error)
	Put(key ComplexKey, value []byte) error
	Get(key ComplexKey) (value []byte, found bool, err error)
	Delete(key ComplexKey) error
	Merge(key ComplexKey, value []byte) error
	DeletePrefix(key ComplexKey) error
	ListComplex(
		keyGroup []byte,
		key []byte,
		namespace []byte,
		startInclusive []byte,
		endExclusive []byte,
	) ([][]byte, error)
	ScanComplex(keyGroup []byte, key []byte, namespace []byte) (Iterator, error)
	Close() error
}