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 {
	FeatureFullNames []string   `protobuf:"bytes,1,rep,name=feature_full_names,json=featureFullNames,proto3" json:"feature_full_names,omitempty"`
	EntityRow        *EntityRow `protobuf:"bytes,2,opt,name=entity_row,json=entityRow,proto3" json:"entity_row,omitempty"`
	ValueNames       []string   `protobuf:"bytes,3,rep,name=value_names,json=valueNames,proto3" json:"value_names,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"`
	UnixMilli int64    `protobuf:"varint,2,opt,name=unix_milli,json=unixMilli,proto3" json:"unix_milli,omitempty"`
	Values    []string `protobuf:"bytes,3,rep,name=values,proto3" json:"values,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 HealthCheckRequest struct {
	// contains filtered or unexported fields
}

type HealthCheckResponse struct {
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// 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 {
	FeatureFullNames []string `protobuf:"bytes,1,rep,name=feature_full_names,json=featureFullNames,proto3" json:"feature_full_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"`
	FeatureFullNames []string `protobuf:"bytes,2,rep,name=feature_full_names,json=featureFullNames,proto3" json:"feature_full_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"`
	FeatureFullNames []string `protobuf:"bytes,2,rep,name=feature_full_names,json=featureFullNames,proto3" json:"feature_full_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 OomAgentClient 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) (OomAgent_ChannelImportClient, error)
	Import(ctx context.Context, in *ImportRequest, opts ...grpc.CallOption) (*ImportResponse, error)
	ChannelJoin(ctx context.Context, opts ...grpc.CallOption) (OomAgent_ChannelJoinClient, error)
	Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error)
	ChannelExport(ctx context.Context, in *ChannelExportRequest, opts ...grpc.CallOption) (OomAgent_ChannelExportClient, error)
	Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (*ExportResponse, error)
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

type OomAgentServer interface {
	OnlineGet(context.Context, *OnlineGetRequest) (*OnlineGetResponse, error)
	OnlineMultiGet(context.Context, *OnlineMultiGetRequest) (*OnlineMultiGetResponse, error)
	Sync(context.Context, *SyncRequest) (*SyncResponse, error)
	ChannelImport(OomAgent_ChannelImportServer) error
	Import(context.Context, *ImportRequest) (*ImportResponse, error)
	ChannelJoin(OomAgent_ChannelJoinServer) error
	Join(context.Context, *JoinRequest) (*JoinResponse, error)
	ChannelExport(*ChannelExportRequest, OomAgent_ChannelExportServer) error
	Export(context.Context, *ExportRequest) (*ExportResponse, error)
	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 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 UnimplementedOomAgentServer struct {
}

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

type Value struct {

	// The kind of value.
	//
	// Types that are assignable to Kind:
	//	*Value_NullValue
	//	*Value_Int64Value
	//	*Value_DoubleValue
	//	*Value_StringValue
	//	*Value_BoolValue
	//	*Value_UnixMilliValue
	//	*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,5,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

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

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

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

type Value_NullValue struct {
	// Represents a null value.
	NullValue structpb.NullValue `protobuf:"varint,1,opt,name=null_value,json=nullValue,proto3,enum=google.protobuf.NullValue,oneof"`
}

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

type Value_UnixMilliValue struct {
	// Represents a unix milliseconds value.
	UnixMilliValue int64 `protobuf:"varint,6,opt,name=unix_milli_value,json=unixMilliValue,proto3,oneof"`
}