codegen

type ChannelExportRequest struct {
	FeatureNames []string `protobuf:"bytes,1,rep,name=feature_names,json=featureNames,proto3" json:"feature_names,omitempty"`
	RevisionId   int32    `protobuf:"varint,2,opt,name=revision_id,json=revisionId,proto3" json:"revision_id,omitempty"`
	Limit        *uint64  `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type ChannelExportResponse struct {
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Header []string       `protobuf:"bytes,2,rep,name=header,proto3" json:"header,omitempty"`
	Row    []*Value       `protobuf:"bytes,3,rep,name=row,proto3" json:"row,omitempty"`
	// contains filtered or unexported fields
}

type ChannelImportRequest struct {
	GroupName   string `protobuf:"bytes,1,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Revision    *int64 `protobuf:"varint,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	Row         []byte `protobuf:"bytes,4,opt,name=row,proto3" json:"row,omitempty"`
	// contains filtered or unexported fields
}

type ChannelJoinRequest struct {
	FeatureNames []string   `protobuf:"bytes,1,rep,name=feature_names,json=featureNames,proto3" json:"feature_names,omitempty"`
	EntityRow    *EntityRow `protobuf:"bytes,2,opt,name=entity_row,json=entityRow,proto3" json:"entity_row,omitempty"`
	// contains filtered or unexported fields
}

type ChannelJoinResponse struct {
	Status    *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Header    []string       `protobuf:"bytes,2,rep,name=header,proto3" json:"header,omitempty"`
	JoinedRow []*Value       `protobuf:"bytes,3,rep,name=joined_row,json=joinedRow,proto3" json:"joined_row,omitempty"`
	// contains filtered or unexported fields
}

type EntityRow struct {
	EntityKey string `protobuf:"bytes,1,opt,name=entity_key,json=entityKey,proto3" json:"entity_key,omitempty"`
	UnixTime  int64  `protobuf:"varint,2,opt,name=unix_time,json=unixTime,proto3" json:"unix_time,omitempty"`
	// contains filtered or unexported fields
}

type ExportRequest struct {
	FeatureNames   []string `protobuf:"bytes,1,rep,name=feature_names,json=featureNames,proto3" json:"feature_names,omitempty"`
	RevisionId     int32    `protobuf:"varint,2,opt,name=revision_id,json=revisionId,proto3" json:"revision_id,omitempty"`
	Limit          *uint64  `protobuf:"varint,3,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	OutputFilePath string   `protobuf:"bytes,4,opt,name=output_file_path,json=outputFilePath,proto3" json:"output_file_path,omitempty"`
	// contains filtered or unexported fields
}

type ExportResponse struct {
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

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

type ImportRequest struct {
	GroupName     string `protobuf:"bytes,1,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	Description   string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Revision      *int64 `protobuf:"varint,3,opt,name=revision,proto3,oneof" json:"revision,omitempty"`
	InputFilePath string `protobuf:"bytes,4,opt,name=input_file_path,json=inputFilePath,proto3" json:"input_file_path,omitempty"`
	Delimiter     string `protobuf:"bytes,5,opt,name=delimiter,proto3" json:"delimiter,omitempty"`
	// contains filtered or unexported fields
}

type ImportResponse struct {
	Status     *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	RevisionId int64          `protobuf:"varint,2,opt,name=revision_id,json=revisionId,proto3" json:"revision_id,omitempty"`
	// contains filtered or unexported fields
}

type JoinRequest struct {
	FeatureNames   []string `protobuf:"bytes,1,rep,name=feature_names,json=featureNames,proto3" json:"feature_names,omitempty"`
	InputFilePath  string   `protobuf:"bytes,2,opt,name=input_file_path,json=inputFilePath,proto3" json:"input_file_path,omitempty"`
	OutputFilePath string   `protobuf:"bytes,3,opt,name=output_file_path,json=outputFilePath,proto3" json:"output_file_path,omitempty"`
	// contains filtered or unexported fields
}

type JoinResponse struct {
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type OnlineGetRequest struct {
	EntityKey    string   `protobuf:"bytes,1,opt,name=entity_key,json=entityKey,proto3" json:"entity_key,omitempty"`
	FeatureNames []string `protobuf:"bytes,2,rep,name=feature_names,json=featureNames,proto3" json:"feature_names,omitempty"`
	// contains filtered or unexported fields
}

type OnlineGetResponse struct {
	Status *status.Status   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Result *FeatureValueMap `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type OnlineMultiGetRequest struct {
	EntityKeys   []string `protobuf:"bytes,1,rep,name=entity_keys,json=entityKeys,proto3" json:"entity_keys,omitempty"`
	FeatureNames []string `protobuf:"bytes,2,rep,name=feature_names,json=featureNames,proto3" json:"feature_names,omitempty"`
	// contains filtered or unexported fields
}

type OnlineMultiGetResponse struct {
	Status *status.Status              `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Result map[string]*FeatureValueMap `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type OomDClient interface {
	OnlineGet(ctx context.Context, in *OnlineGetRequest, opts ...grpc.CallOption) (*OnlineGetResponse, error)
	OnlineMultiGet(ctx context.Context, in *OnlineMultiGetRequest, opts ...grpc.CallOption) (*OnlineMultiGetResponse, error)
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error)
	ChannelImport(ctx context.Context, opts ...grpc.CallOption) (OomD_ChannelImportClient, error)
	Import(ctx context.Context, in *ImportRequest, opts ...grpc.CallOption) (*ImportResponse, error)
	ChannelJoin(ctx context.Context, opts ...grpc.CallOption) (OomD_ChannelJoinClient, error)
	Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error)
	ChannelExport(ctx context.Context, in *ChannelExportRequest, opts ...grpc.CallOption) (OomD_ChannelExportClient, error)
	Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (*ExportResponse, error)
}

type OomDServer interface {
	OnlineGet(context.Context, *OnlineGetRequest) (*OnlineGetResponse, error)
	OnlineMultiGet(context.Context, *OnlineMultiGetRequest) (*OnlineMultiGetResponse, error)
	Sync(context.Context, *SyncRequest) (*SyncResponse, error)
	ChannelImport(OomD_ChannelImportServer) error
	Import(context.Context, *ImportRequest) (*ImportResponse, error)
	ChannelJoin(OomD_ChannelJoinServer) error
	Join(context.Context, *JoinRequest) (*JoinResponse, error)
	ChannelExport(*ChannelExportRequest, OomD_ChannelExportServer) error
	Export(context.Context, *ExportRequest) (*ExportResponse, error)
	// contains filtered or unexported methods
}

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

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

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

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

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

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

type SyncRequest struct {
	RevisionId int32 `protobuf:"varint,1,opt,name=revision_id,json=revisionId,proto3" json:"revision_id,omitempty"`
	PurgeDelay int32 `protobuf:"varint,2,opt,name=purge_delay,json=purgeDelay,proto3" json:"purge_delay,omitempty"`
	// contains filtered or unexported fields
}

type SyncResponse struct {
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedOomDServer struct {
}

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

type Value struct {

	// The kind of value.
	//
	// Types that are assignable to Kind:
	//	*Value_Int64Value
	//	*Value_DoubleValue
	//	*Value_StringValue
	//	*Value_BoolValue
	//	*Value_UnixTimestampValue
	//	*Value_BytesValue
	Kind isValue_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

type Value_BoolValue struct {
	// Represents a boolean value.
	BoolValue bool `protobuf:"varint,4,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type Value_BytesValue struct {
	// Represents a bytes value.
	BytesValue []byte `protobuf:"bytes,6,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type Value_DoubleValue struct {
	// Represents a double value.
	DoubleValue float64 `protobuf:"fixed64,2,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type Value_Int64Value struct {
	// Represents a int64 value.
	Int64Value int64 `protobuf:"varint,1,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

type Value_StringValue struct {
	// Represents a string value.
	StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type Value_UnixTimestampValue struct {
	// Represents a unix milliseconds value.
	UnixTimestampValue int64 `protobuf:"varint,5,opt,name=unix_timestamp_value,json=unixTimestampValue,proto3,oneof"`
}