committerpb

type IsoLevel int32

type NotificationRequest struct {
	TxStatusRequest *TxIDsBatch `protobuf:"bytes,1,opt,name=tx_status_request,json=txStatusRequest,proto3,oneof" json:"tx_status_request,omitempty"`
	// The timeout duration that applies to ALL the subscriptions in this request.
	// It is non-strict, i.e., it is possible to receive notifications for this request
	// after the timeout has passed.
	// If this field is not set or has a default value (zero), the default would be applied as
	// per the committer's configuration.
	Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

type NotificationResponse struct {
	TxStatusEvents []*TxStatus `protobuf:"bytes,1,rep,name=tx_status_events,json=txStatusEvents,proto3" json:"tx_status_events,omitempty"` // List of transaction status events.
	TimeoutTxIds   []string    `protobuf:"bytes,2,rep,name=timeout_tx_ids,json=timeoutTxIds,proto3" json:"timeout_tx_ids,omitempty"`       // List of timeout events.
	// contains filtered or unexported fields
}

type NotifierClient interface {
	OpenNotificationStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[NotificationRequest, NotificationResponse], error)
}

type NotifierServer interface {
	OpenNotificationStream(grpc.BidiStreamingServer[NotificationRequest, NotificationResponse]) error
	// contains filtered or unexported methods
}

type Notifier_OpenNotificationStreamClient = grpc.BidiStreamingClient[NotificationRequest, NotificationResponse]

type Notifier_OpenNotificationStreamServer = grpc.BidiStreamingServer[NotificationRequest, NotificationResponse]

type Query struct {
	View       *View             `protobuf:"bytes,1,opt,name=view,proto3,oneof" json:"view,omitempty"`
	Namespaces []*QueryNamespace `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

type QueryNamespace struct {
	NsId string   `protobuf:"bytes,1,opt,name=ns_id,json=nsId,proto3" json:"ns_id,omitempty"`
	Keys [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

type QueryServiceClient interface {
	GetRows(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Rows, error)
	BeginView(ctx context.Context, in *ViewParameters, opts ...grpc.CallOption) (*View, error)
	EndView(ctx context.Context, in *View, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetNamespacePolicies(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*applicationpb.NamespacePolicies, error)
	GetConfigTransaction(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*applicationpb.ConfigTransaction, error)
	GetTransactionStatus(ctx context.Context, in *TxStatusQuery, opts ...grpc.CallOption) (*TxStatusResponse, error)
}

type QueryServiceServer interface {
	GetRows(context.Context, *Query) (*Rows, error)
	BeginView(context.Context, *ViewParameters) (*View, error)
	EndView(context.Context, *View) (*emptypb.Empty, error)
	GetNamespacePolicies(context.Context, *emptypb.Empty) (*applicationpb.NamespacePolicies, error)
	GetConfigTransaction(context.Context, *emptypb.Empty) (*applicationpb.ConfigTransaction, error)
	GetTransactionStatus(context.Context, *TxStatusQuery) (*TxStatusResponse, error)
	// contains filtered or unexported methods
}

type Row struct {
	Key     []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Version uint64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type Rows struct {
	Namespaces []*RowsNamespace `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

type RowsNamespace struct {
	NsId string `protobuf:"bytes,1,opt,name=ns_id,json=nsId,proto3" json:"ns_id,omitempty"`
	Rows []*Row `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

type Status int32

type TxIDsBatch struct {
	TxIds []string `protobuf:"bytes,1,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"` // List of transaction IDs.
	// contains filtered or unexported fields
}

type TxRef struct {
	BlockNum uint64 `protobuf:"varint,1,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"` // The block number.
	TxNum    uint32 `protobuf:"varint,2,opt,name=tx_num,json=txNum,proto3" json:"tx_num,omitempty"`          // Transaction number within the block
	TxId     string `protobuf:"bytes,3,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`              // Transaction ID within the block.
	// contains filtered or unexported fields
}

type TxStatus struct {
	Ref    *TxRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Status Status `protobuf:"varint,2,opt,name=status,proto3,enum=committerpb.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type TxStatusBatch struct {
	Status []*TxStatus `protobuf:"bytes,1,rep,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type TxStatusQuery struct {
	View  *View    `protobuf:"bytes,1,opt,name=view,proto3,oneof" json:"view,omitempty"`
	TxIds []string `protobuf:"bytes,2,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"` // List of transaction IDs.
	// contains filtered or unexported fields
}

type TxStatusResponse struct {
	Statuses []*TxStatus `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedNotifierServer struct{}

type UnimplementedQueryServiceServer struct{}

type UnsafeNotifierServer interface {
	// contains filtered or unexported methods
}

type UnsafeQueryServiceServer interface {
	// contains filtered or unexported methods
}

type View struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type ViewParameters struct {
	IsoLevel            IsoLevel `protobuf:"varint,1,opt,name=iso_level,json=isoLevel,proto3,enum=committerpb.IsoLevel" json:"iso_level,omitempty"`        // View's isolation level. Defaults to serializable.
	NonDeferrable       bool     `protobuf:"varint,2,opt,name=non_deferrable,json=nonDeferrable,proto3" json:"non_deferrable,omitempty"`                   // Do not defer errors. Defaults deferrable.
	TimeoutMilliseconds uint64   `protobuf:"varint,3,opt,name=timeout_milliseconds,json=timeoutMilliseconds,proto3" json:"timeout_milliseconds,omitempty"` // View's timeout. Zero => maximal value
	// contains filtered or unexported fields
}