codegen

type ChannelExportRequest struct {

	// A list of feature full names.
	Features []string `protobuf:"bytes,1,rep,name=features,proto3" json:"features,omitempty"`
	// A unix milliseconds, export the feature value before this timestamp.
	UnixMilli int64 `protobuf:"varint,2,opt,name=unix_milli,json=unixMilli,proto3" json:"unix_milli,omitempty"`
	// Limit the size of export data.
	Limit *uint64 `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type ChannelExportResponse struct {

	// Header of export result.
	// It only appears in the first request.
	Header []string `protobuf:"bytes,1,rep,name=header,proto3" json:"header,omitempty"`
	// A single row of export result.
	Row []*Value `protobuf:"bytes,2,rep,name=row,proto3" json:"row,omitempty"`
	// contains filtered or unexported fields
}

type ChannelImportRequest struct {

	// The group to be imported from data source to offline store.
	// It only takes effect (and required) on the first request.
	Group *string `protobuf:"bytes,1,opt,name=group,proto3,oneof" json:"group,omitempty"`
	// The revision of the imported data, it only applies to
	// batch feature (not required).
	// For batch features, if revision is null, will use the
	// timestamp when it starts serving in online store; otherwise,
	// use the designated revision.
	// It only takes effect on the first request.
	Revision *int64 `protobuf:"varint,2,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	// Description of this import.
	// It only takes effect on the first request.
	Description *string `protobuf:"bytes,3,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// A single row of channel import.
	Row []byte `protobuf:"bytes,4,opt,name=row,proto3" json:"row,omitempty"`
	// contains filtered or unexported fields
}

type ChannelJoinRequest struct {

	// A list of feature full names, their feature values will be
	// joined and fetched from offline store.
	// It only takes effect (and required) on the first request.
	JoinFeatures []string `protobuf:"bytes,1,rep,name=join_features,json=joinFeatures,proto3" json:"join_features,omitempty"`
	// A list of names, could be label name or real-time feature names.
	// Those feature values will be passed from entity row.
	// It only takes effect (and required) on the first request.
	ExistedFeatures []string `protobuf:"bytes,2,rep,name=existed_features,json=existedFeatures,proto3" json:"existed_features,omitempty"`
	// An entity row.
	EntityRow *EntityRow `protobuf:"bytes,3,opt,name=entity_row,json=entityRow,proto3" json:"entity_row,omitempty"`
	// contains filtered or unexported fields
}

type ChannelJoinResponse struct {

	// Header of the `Join` response.
	// It only appears in the first request.
	Header []string `protobuf:"bytes,1,rep,name=header,proto3" json:"header,omitempty"`
	// A single row of joined results.
	JoinedRow []*Value `protobuf:"bytes,2,rep,name=joined_row,json=joinedRow,proto3" json:"joined_row,omitempty"`
	// contains filtered or unexported fields
}

type EntityRow struct {

	// An entity identifier, could represents device ID, user ID, etc.
	EntityKey string `protobuf:"bytes,1,opt,name=entity_key,json=entityKey,proto3" json:"entity_key,omitempty"`
	// A unix milliseconds, represents the record timestamp.
	UnixMilli int64 `protobuf:"varint,2,opt,name=unix_milli,json=unixMilli,proto3" json:"unix_milli,omitempty"`
	// A list of existing values, could be label or real-time features.
	Values []string `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type ExportRequest struct {

	// A list of feature full names.
	Features []string `protobuf:"bytes,1,rep,name=features,proto3" json:"features,omitempty"`
	// A unix milliseconds, export the feature value before this timestamp.
	UnixMilli int64 `protobuf:"varint,2,opt,name=unix_milli,json=unixMilli,proto3" json:"unix_milli,omitempty"`
	// File path of export result.
	OutputFile string `protobuf:"bytes,3,opt,name=output_file,json=outputFile,proto3" json:"output_file,omitempty"`
	// Limit the size of export data.
	Limit *uint64 `protobuf:"varint,4,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

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

type FeatureValueMap struct {
	Map map[string]*Value `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

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

type ImportRequest struct {

	// The group to be imported from data source to offline store.
	Group string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	// The revision of the imported data, it only applies to
	// batch feature (not required).
	// For batch features, if revision is null, will use the
	// timestamp when it starts serving in online store; otherwise,
	// use the designated revision.
	Revision *int64 `protobuf:"varint,2,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	// Description of this import.
	Description *string `protobuf:"bytes,3,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// The path of data source.
	InputFile string `protobuf:"bytes,4,opt,name=input_file,json=inputFile,proto3" json:"input_file,omitempty"`
	// Delimiter of data source
	Delimiter *string `protobuf:"bytes,5,opt,name=delimiter,proto3,oneof" json:"delimiter,omitempty"`
	// contains filtered or unexported fields
}

type ImportResponse struct {

	// The revision ID of this import, it only applies to batch feature.
	RevisionId int32 `protobuf:"varint,1,opt,name=revision_id,json=revisionId,proto3" json:"revision_id,omitempty"`
	// contains filtered or unexported fields
}

type JoinRequest struct {

	// A list of feature full names, their feature values will be
	// joined and fetched from offline store.
	Features []string `protobuf:"bytes,1,rep,name=features,proto3" json:"features,omitempty"`
	// File path of entity rows.
	InputFile string `protobuf:"bytes,2,opt,name=input_file,json=inputFile,proto3" json:"input_file,omitempty"`
	// File path of joined result.
	OutputFile string `protobuf:"bytes,3,opt,name=output_file,json=outputFile,proto3" json:"output_file,omitempty"`
	// contains filtered or unexported fields
}

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

type OnlineGetRequest struct {

	// An entity identifier, could be device ID, user ID, etc.
	EntityKey string `protobuf:"bytes,1,opt,name=entity_key,json=entityKey,proto3" json:"entity_key,omitempty"`
	// A list of feature full names.
	// A feature full name has the following format: <feature_group_name>.<feature_name>,
	// for example, txn_stats.count_7d
	Features []string `protobuf:"bytes,2,rep,name=features,proto3" json:"features,omitempty"`
	// contains filtered or unexported fields
}

type OnlineGetResponse struct {

	// The result of `OnlineGet`.
	Result *FeatureValueMap `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type OnlineMultiGetRequest struct {

	// A list of entity identifiers, could be device IDs, user IDs, etc.
	EntityKeys []string `protobuf:"bytes,1,rep,name=entity_keys,json=entityKeys,proto3" json:"entity_keys,omitempty"`
	// A list of feature full names.
	// A feature full name has the following format: <feature_group_name>.<feature_name>,
	// for example, txn_stats.count_7d
	Features []string `protobuf:"bytes,2,rep,name=features,proto3" json:"features,omitempty"`
	// contains filtered or unexported fields
}

type OnlineMultiGetResponse struct {

	// The result of `OnlineMultiGet`, mapping entity key to FeatureValueMap.
	Result map[string]*FeatureValueMap `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type OomAgentClient interface {
	// Get online features for an entity.
	OnlineGet(ctx context.Context, in *OnlineGetRequest, opts ...grpc.CallOption) (*OnlineGetResponse, error)
	// Get online features for multiple entities.
	OnlineMultiGet(ctx context.Context, in *OnlineMultiGetRequest, opts ...grpc.CallOption) (*OnlineMultiGetResponse, error)
	// Sync a certain revision of batch features from offline to online store.
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error)
	// Import features from external (batch and stream) data sources to offline store through channels.
	ChannelImport(ctx context.Context, opts ...grpc.CallOption) (OomAgent_ChannelImportClient, error)
	// Import features from external (batch and stream) data sources to offline store through files.
	Import(ctx context.Context, in *ImportRequest, opts ...grpc.CallOption) (*ImportResponse, error)
	// Push stream features from stream data source to both offline and online stores.
	Push(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*PushResponse, error)
	// Take snapshot for a stream feature group in offline store.
	Snapshot(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (*SnapshotResponse, error)
	// Point-in-Time Join features against labeled entity rows through channels.
	ChannelJoin(ctx context.Context, opts ...grpc.CallOption) (OomAgent_ChannelJoinClient, error)
	// Point-in-Time Join features against labeled entity rows through files.
	Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error)
	// Export certain features to a channel.
	ChannelExport(ctx context.Context, in *ChannelExportRequest, opts ...grpc.CallOption) (OomAgent_ChannelExportClient, error)
	// Export certain features to a file.
	Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (*ExportResponse, error)
	// Check if oomagent is ready to serve requests.
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

type OomAgentServer interface {
	// Get online features for an entity.
	OnlineGet(context.Context, *OnlineGetRequest) (*OnlineGetResponse, error)
	// Get online features for multiple entities.
	OnlineMultiGet(context.Context, *OnlineMultiGetRequest) (*OnlineMultiGetResponse, error)
	// Sync a certain revision of batch features from offline to online store.
	Sync(context.Context, *SyncRequest) (*SyncResponse, error)
	// Import features from external (batch and stream) data sources to offline store through channels.
	ChannelImport(OomAgent_ChannelImportServer) error
	// Import features from external (batch and stream) data sources to offline store through files.
	Import(context.Context, *ImportRequest) (*ImportResponse, error)
	// Push stream features from stream data source to both offline and online stores.
	Push(context.Context, *PushRequest) (*PushResponse, error)
	// Take snapshot for a stream feature group in offline store.
	Snapshot(context.Context, *SnapshotRequest) (*SnapshotResponse, error)
	// Point-in-Time Join features against labeled entity rows through channels.
	ChannelJoin(OomAgent_ChannelJoinServer) error
	// Point-in-Time Join features against labeled entity rows through files.
	Join(context.Context, *JoinRequest) (*JoinResponse, error)
	// Export certain features to a channel.
	ChannelExport(*ChannelExportRequest, OomAgent_ChannelExportServer) error
	// Export certain features to a file.
	Export(context.Context, *ExportRequest) (*ExportResponse, error)
	// Check if oomagent is ready to serve requests.
	HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// contains filtered or unexported methods
}

type OomAgent_ChannelExportClient interface {
	Recv() (*ChannelExportResponse, error)
	grpc.ClientStream
}

type OomAgent_ChannelExportServer interface {
	Send(*ChannelExportResponse) error
	grpc.ServerStream
}

type OomAgent_ChannelImportClient interface {
	Send(*ChannelImportRequest) error
	CloseAndRecv() (*ImportResponse, error)
	grpc.ClientStream
}

type OomAgent_ChannelImportServer interface {
	SendAndClose(*ImportResponse) error
	Recv() (*ChannelImportRequest, error)
	grpc.ServerStream
}

type OomAgent_ChannelJoinClient interface {
	Send(*ChannelJoinRequest) error
	Recv() (*ChannelJoinResponse, error)
	grpc.ClientStream
}

type OomAgent_ChannelJoinServer interface {
	Send(*ChannelJoinResponse) error
	Recv() (*ChannelJoinRequest, error)
	grpc.ServerStream
}

type PushRequest struct {

	// An entity identifier.
	EntityKey string `protobuf:"bytes,1,opt,name=entity_key,json=entityKey,proto3" json:"entity_key,omitempty"`
	// A streaming feature group.
	Group string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	// Feature values maps feature name to feature value.
	FeatureValues map[string]*Value `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

type SnapshotRequest struct {

	// A streaming feature group.
	Group string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

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

type SyncRequest struct {

	// The group to sync from offline store to online store.
	Group string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	// The revision to sync, it only applies to batch feature.
	// For batch feature: if null, will sync the latest revision;
	// otherwise, sync the designated revision.
	// For streaming feature, revision ID is not required, will always
	// sync the latest values.
	RevisionId *int32 `protobuf:"varint,2,opt,name=revision_id,json=revisionId,proto3,oneof" json:"revision_id,omitempty"`
	// PurgeDelay represents the seconds to sleep before purging
	// the previous revision in online store.
	// It only applies to batch feature group.
	PurgeDelay int32 `protobuf:"varint,3,opt,name=purge_delay,json=purgeDelay,proto3" json:"purge_delay,omitempty"`
	// contains filtered or unexported fields
}

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

type UnimplementedOomAgentServer struct {
}

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

type Value struct {

	// Types that are assignable to Value:
	//	*Value_Int64
	//	*Value_Double
	//	*Value_String_
	//	*Value_Bool
	//	*Value_UnixMilli
	//	*Value_Bytes
	Value isValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

type Value_Bool struct {
	// Represents a boolean value.
	Bool bool `protobuf:"varint,4,opt,name=bool,proto3,oneof"`
}

type Value_Bytes struct {
	// Represents a bytes value.
	Bytes []byte `protobuf:"bytes,6,opt,name=bytes,proto3,oneof"`
}

type Value_Double struct {
	// Represents a double value.
	Double float64 `protobuf:"fixed64,2,opt,name=double,proto3,oneof"`
}

type Value_Int64 struct {
	// Represents a int64 value.
	Int64 int64 `protobuf:"varint,1,opt,name=int64,proto3,oneof"`
}

type Value_String_ struct {
	// Represents a string value.
	String_ string `protobuf:"bytes,3,opt,name=string,proto3,oneof"`
}

type Value_UnixMilli struct {
	// Represents a unix milliseconds value.
	UnixMilli int64 `protobuf:"varint,5,opt,name=unix_milli,json=unixMilli,proto3,oneof"`
}