base

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

type AccessContextOption func(accessContext *AccessContext)

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

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

type BoundValue interface {
	Format() BoundValueFormat
	Copy() BoundValue
	SetData(newData []byte, setting config.ColumnEncryptionSetting) error
	GetData(setting config.ColumnEncryptionSetting) ([]byte, error)
	Encode() ([]byte, error)
	GetType() byte
}

type BoundValueFormat uint16

type Callback interface {
	Call() error
}

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

type ClientIDObservable interface {
	AddClientIDObserver(ClientIDObserver)
}

type ClientIDObservableManager interface {
	ClientIDObservable
	ClientIDObserver
}

type ClientIDObserver interface {
	OnNewClientID(clientID []byte)
}

type ClientSession interface {
	Context() context.Context
	ClientConnection() net.Conn
	DatabaseConnection() net.Conn

	PreparedStatementRegistry() PreparedStatementRegistry
	SetPreparedStatementRegistry(registry PreparedStatementRegistry)

	ProtocolState() interface{}
	SetProtocolState(state interface{})
	GetData(string) (interface{}, bool)
	SetData(string, interface{})
	DeleteData(string)
	HasData(string) bool
}

type ColumnDecryptionNotifier interface {
	SubscribeOnAllColumnsDecryption(subscriber DecryptionSubscriber)
	Unsubscribe(DecryptionSubscriber)
}

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

type ColumnInfo interface {
	Index() int
	Alias() string
	IsBinaryFormat() bool
	DataBinarySize() int
	DataBinaryType() byte
	OriginBinaryType() byte
}

type Cursor interface {
	Name() string
	PreparedStatement() PreparedStatement
}

type DataProcessor interface {
	Process(data []byte, context *DataProcessorContext) ([]byte, error)
}

type DataProcessorContext struct {
	Keystore keystore.DataEncryptorKeyStore
	Context  context.Context
}

type DecryptProcessor struct{}

type DecryptionSubscriber interface {
	OnColumn(context.Context, []byte) (context.Context, []byte, error)
	ID() string
}

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

type EncodingValue interface {
	// AssBinary returns value encoded in a binary format
	AsBinary() []byte
	// AsText returns value encoded in a text format
	AsText() []byte
}

type EncodingValueFactory interface {
	// NewStringValue creates a value that encodes as a str
	NewStringValue(str []byte) EncodingValue
	// NewBytesValue creates a value that encodes as bytes
	NewBytesValue(bytes []byte) EncodingValue
	// NewInt32Value creates a value that encodes as int32
	NewInt32Value(intVal int32, strVal []byte) EncodingValue
	// NewInt64Value creates a value that encodes as int64
	NewInt64Value(intVal int64, strVal []byte) EncodingValue
}

type ExtendedDataProcessor interface {
	DataProcessor
	MatchDataSignature([]byte) bool
}

type OnQueryObject interface {
	Statement() (sqlparser.Statement, error)
	Query() string
}

type PoisonRecordCallbackStorage interface {
	Callback
	AddCallback(callback Callback)
	HasCallbacks() bool
}

type PreparedStatement interface {
	Name() string
	Query() sqlparser.Statement
	QueryText() string
	ParamsNum() int
}

type PreparedStatementRegistry interface {
	AddStatement(statement PreparedStatement) error
	DeleteStatement(name string) error
	StatementByName(name string) (PreparedStatement, error)

	AddCursor(cursor Cursor) error
	DeleteCursor(name string) error
	CursorByName(name string) (Cursor, error)
}

type ProcessorFunc func([]byte, *DataProcessorContext) ([]byte, error)

type ProcessorWrapper interface {
	Wrap(DataProcessor) DataProcessor
}

type Proxy interface {
	QueryObservable
	ClientIDObservable
	ProxyClientConnection(context.Context, chan<- ProxyError)
	ProxyDatabaseConnection(context.Context, chan<- ProxyError)
}

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

type ProxyFactory interface {
	New(clientID []byte, clientSession ClientSession) (Proxy, error)
}

type ProxySetting interface {
	PoisonRecordCallbackStorage() PoisonRecordCallbackStorage
	SQLParser() *sqlparser.Parser
	KeyStore() keystore.DecryptionKeyStore
	TableSchemaStore() config.TableSchemaStore
	Censor() acracensor.AcraCensorInterface
	TLSConnectionWrapper() TLSConnectionWrapper
}

type QueryObservable interface {
	AddQueryObserver(QueryObserver)
	RegisteredObserversCount() int
}

type QueryObserver interface {
	ID() string
	// Simple queries and prepared statements during preparation stage. SQL is modifiable.
	OnQuery(ctx context.Context, data OnQueryObject) (OnQueryObject, bool, error)
	// Prepared statement parameters during execution stage. Parameter values are modifiable.
	OnBind(ctx context.Context, statement sqlparser.Statement, values []BoundValue) ([]BoundValue, bool, error)
}

type QueryObserverManager interface {
	QueryObserver
	QueryObservable
}

type TLSConnectionWrapper interface {
	WrapDBConnection(ctx context.Context, conn net.Conn) (net.Conn, error)
	WrapClientConnection(ctx context.Context, conn net.Conn) (wrappedConnection net.Conn, clientID []byte, err error)
	UseConnectionClientID() bool
}