core

package
v0.4.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 19, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ApplyFeatureSetResponse_Status_name = map[int32]string{
	0: "NO_CHANGE",
	1: "CREATED",
	2: "ERROR",
}
View Source 
var ApplyFeatureSetResponse_Status_value = map[string]int32{
	"NO_CHANGE": 0,
	"CREATED":   1,
	"ERROR":     2,
}
View Source 
var FeatureSetStatus_name = map[int32]string{
	0: "STATUS_INVALID",
	1: "STATUS_PENDING",
	2: "STATUS_READY",
}
View Source 
var FeatureSetStatus_value = map[string]int32{
	"STATUS_INVALID": 0,
	"STATUS_PENDING": 1,
	"STATUS_READY":   2,
}
View Source 
var SourceType_name = map[int32]string{
	0: "INVALID",
	1: "KAFKA",
}
View Source 
var SourceType_value = map[string]int32{
	"INVALID": 0,
	"KAFKA":   1,
}
View Source 
var Store_StoreType_name = map[int32]string{
	0: "INVALID",
	1: "REDIS",
	2: "BIGQUERY",
	3: "CASSANDRA",
}
View Source 
var Store_StoreType_value = map[string]int32{
	"INVALID":   0,
	"REDIS":     1,
	"BIGQUERY":  2,
	"CASSANDRA": 3,
}
View Source 
var UpdateStoreResponse_Status_name = map[int32]string{
	0: "NO_CHANGE",
	1: "UPDATED",
}
View Source 
var UpdateStoreResponse_Status_value = map[string]int32{
	"NO_CHANGE": 0,
	"UPDATED":   1,
}

Functions

func RegisterCoreServiceServer 

func RegisterCoreServiceServer(s *grpc.Server, srv CoreServiceServer)

Types

type ApplyFeatureSetRequest 

type ApplyFeatureSetRequest struct {
	// Feature set version and source will be ignored
	FeatureSet           *FeatureSet `protobuf:"bytes,1,opt,name=feature_set,json=featureSet,proto3" json:"feature_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ApplyFeatureSetRequest) Descriptor 

func (*ApplyFeatureSetRequest) Descriptor() ([]byte, []int)

func (*ApplyFeatureSetRequest) GetFeatureSet 

func (m *ApplyFeatureSetRequest) GetFeatureSet() *FeatureSet

func (*ApplyFeatureSetRequest) ProtoMessage 

func (*ApplyFeatureSetRequest) ProtoMessage()

func (*ApplyFeatureSetRequest) Reset 

func (m *ApplyFeatureSetRequest) Reset()

func (*ApplyFeatureSetRequest) String 

func (m *ApplyFeatureSetRequest) String() string

func (*ApplyFeatureSetRequest) XXX_DiscardUnknown 

func (m *ApplyFeatureSetRequest) XXX_DiscardUnknown()

func (*ApplyFeatureSetRequest) XXX_Marshal 

func (m *ApplyFeatureSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplyFeatureSetRequest) XXX_Merge 

func (m *ApplyFeatureSetRequest) XXX_Merge(src proto.Message)

func (*ApplyFeatureSetRequest) XXX_Size 

func (m *ApplyFeatureSetRequest) XXX_Size() int

func (*ApplyFeatureSetRequest) XXX_Unmarshal 

func (m *ApplyFeatureSetRequest) XXX_Unmarshal(b []byte) error

type ApplyFeatureSetResponse 

type ApplyFeatureSetResponse struct {
	// Feature set response has been enriched with version and source information
	FeatureSet           *FeatureSet                    `protobuf:"bytes,1,opt,name=feature_set,json=featureSet,proto3" json:"feature_set,omitempty"`
	Status               ApplyFeatureSetResponse_Status `protobuf:"varint,2,opt,name=status,proto3,enum=feast.core.ApplyFeatureSetResponse_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*ApplyFeatureSetResponse) Descriptor 

func (*ApplyFeatureSetResponse) Descriptor() ([]byte, []int)

func (*ApplyFeatureSetResponse) GetFeatureSet 

func (m *ApplyFeatureSetResponse) GetFeatureSet() *FeatureSet

func (*ApplyFeatureSetResponse) GetStatus 

func (m *ApplyFeatureSetResponse) GetStatus() ApplyFeatureSetResponse_Status

func (*ApplyFeatureSetResponse) ProtoMessage 

func (*ApplyFeatureSetResponse) ProtoMessage()

func (*ApplyFeatureSetResponse) Reset 

func (m *ApplyFeatureSetResponse) Reset()

func (*ApplyFeatureSetResponse) String 

func (m *ApplyFeatureSetResponse) String() string

func (*ApplyFeatureSetResponse) XXX_DiscardUnknown 

func (m *ApplyFeatureSetResponse) XXX_DiscardUnknown()

func (*ApplyFeatureSetResponse) XXX_Marshal 

func (m *ApplyFeatureSetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplyFeatureSetResponse) XXX_Merge 

func (m *ApplyFeatureSetResponse) XXX_Merge(src proto.Message)

func (*ApplyFeatureSetResponse) XXX_Size 

func (m *ApplyFeatureSetResponse) XXX_Size() int

func (*ApplyFeatureSetResponse) XXX_Unmarshal 

func (m *ApplyFeatureSetResponse) XXX_Unmarshal(b []byte) error

type ApplyFeatureSetResponse_Status 

type ApplyFeatureSetResponse_Status int32
const (
	// Latest feature set version is consistent with provided feature set
	ApplyFeatureSetResponse_NO_CHANGE ApplyFeatureSetResponse_Status = 0
	// New feature set or feature set version created
	ApplyFeatureSetResponse_CREATED ApplyFeatureSetResponse_Status = 1
	// Error occurred while trying to apply changes
	ApplyFeatureSetResponse_ERROR ApplyFeatureSetResponse_Status = 2
)

func (ApplyFeatureSetResponse_Status) EnumDescriptor 

func (ApplyFeatureSetResponse_Status) EnumDescriptor() ([]byte, []int)

func (ApplyFeatureSetResponse_Status) String 

func (x ApplyFeatureSetResponse_Status) String() string

type ArchiveProjectRequest 

type ArchiveProjectRequest struct {
	// Name of project to be archived
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for the archival of a project

func (*ArchiveProjectRequest) Descriptor 

func (*ArchiveProjectRequest) Descriptor() ([]byte, []int)

func (*ArchiveProjectRequest) GetName 

func (m *ArchiveProjectRequest) GetName() string

func (*ArchiveProjectRequest) ProtoMessage 

func (*ArchiveProjectRequest) ProtoMessage()

func (*ArchiveProjectRequest) Reset 

func (m *ArchiveProjectRequest) Reset()

func (*ArchiveProjectRequest) String 

func (m *ArchiveProjectRequest) String() string

func (*ArchiveProjectRequest) XXX_DiscardUnknown 

func (m *ArchiveProjectRequest) XXX_DiscardUnknown()

func (*ArchiveProjectRequest) XXX_Marshal 

func (m *ArchiveProjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArchiveProjectRequest) XXX_Merge 

func (m *ArchiveProjectRequest) XXX_Merge(src proto.Message)

func (*ArchiveProjectRequest) XXX_Size 

func (m *ArchiveProjectRequest) XXX_Size() int

func (*ArchiveProjectRequest) XXX_Unmarshal 

func (m *ArchiveProjectRequest) XXX_Unmarshal(b []byte) error

type ArchiveProjectResponse 

type ArchiveProjectResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response for archival of a project

func (*ArchiveProjectResponse) Descriptor 

func (*ArchiveProjectResponse) Descriptor() ([]byte, []int)

func (*ArchiveProjectResponse) ProtoMessage 

func (*ArchiveProjectResponse) ProtoMessage()

func (*ArchiveProjectResponse) Reset 

func (m *ArchiveProjectResponse) Reset()

func (*ArchiveProjectResponse) String 

func (m *ArchiveProjectResponse) String() string

func (*ArchiveProjectResponse) XXX_DiscardUnknown 

func (m *ArchiveProjectResponse) XXX_DiscardUnknown()

func (*ArchiveProjectResponse) XXX_Marshal 

func (m *ArchiveProjectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArchiveProjectResponse) XXX_Merge 

func (m *ArchiveProjectResponse) XXX_Merge(src proto.Message)

func (*ArchiveProjectResponse) XXX_Size 

func (m *ArchiveProjectResponse) XXX_Size() int

func (*ArchiveProjectResponse) XXX_Unmarshal 

func (m *ArchiveProjectResponse) XXX_Unmarshal(b []byte) error

type CoreServiceClient 

type CoreServiceClient interface {
	// Retrieve version information about this Feast deployment
	GetFeastCoreVersion(ctx context.Context, in *GetFeastCoreVersionRequest, opts ...grpc.CallOption) (*GetFeastCoreVersionResponse, error)
	// Returns a specific feature set
	GetFeatureSet(ctx context.Context, in *GetFeatureSetRequest, opts ...grpc.CallOption) (*GetFeatureSetResponse, error)
	// Retrieve feature set details given a filter.
	//
	// Returns all feature sets matching that filter. If none are found,
	// an empty list will be returned.
	// If no filter is provided in the request, the response will contain all the feature
	// sets currently stored in the registry.
	ListFeatureSets(ctx context.Context, in *ListFeatureSetsRequest, opts ...grpc.CallOption) (*ListFeatureSetsResponse, error)
	// Retrieve store details given a filter.
	//
	// Returns all stores matching that filter. If none are found, an empty list will be returned.
	// If no filter is provided in the request, the response will contain all the stores currently
	// stored in the registry.
	ListStores(ctx context.Context, in *ListStoresRequest, opts ...grpc.CallOption) (*ListStoresResponse, error)
	// Create or update and existing feature set.
	//
	// This function is idempotent - it will not create a new feature set if schema does not change.
	// If an existing feature set is updated, core will advance the version number, which will be
	// returned in response.
	ApplyFeatureSet(ctx context.Context, in *ApplyFeatureSetRequest, opts ...grpc.CallOption) (*ApplyFeatureSetResponse, error)
	// Updates core with the configuration of the store.
	//
	// If the changes are valid, core will return the given store configuration in response, and
	// start or update the necessary feature population jobs for the updated store.
	UpdateStore(ctx context.Context, in *UpdateStoreRequest, opts ...grpc.CallOption) (*UpdateStoreResponse, error)
	// Creates a project. Projects serve as namespaces within which resources like features will be
	// created. Both feature set names as well as field names must be unique within a project. Project
	// names themselves must be globally unique.
	CreateProject(ctx context.Context, in *CreateProjectRequest, opts ...grpc.CallOption) (*CreateProjectResponse, error)
	// Archives a project. Archived projects will continue to exist and function, but won't be visible
	// through the Core API. Any existing ingestion or serving requests will continue to function,
	// but will result in warning messages being logged. It is not possible to unarchive a project
	// through the Core API
	ArchiveProject(ctx context.Context, in *ArchiveProjectRequest, opts ...grpc.CallOption) (*ArchiveProjectResponse, error)
	// Lists all projects active projects.
	ListProjects(ctx context.Context, in *ListProjectsRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error)
}

CoreServiceClient is the client API for CoreService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCoreServiceClient 

func NewCoreServiceClient(cc *grpc.ClientConn) CoreServiceClient

type CoreServiceServer 

type CoreServiceServer interface {
	// Retrieve version information about this Feast deployment
	GetFeastCoreVersion(context.Context, *GetFeastCoreVersionRequest) (*GetFeastCoreVersionResponse, error)
	// Returns a specific feature set
	GetFeatureSet(context.Context, *GetFeatureSetRequest) (*GetFeatureSetResponse, error)
	// Retrieve feature set details given a filter.
	//
	// Returns all feature sets matching that filter. If none are found,
	// an empty list will be returned.
	// If no filter is provided in the request, the response will contain all the feature
	// sets currently stored in the registry.
	ListFeatureSets(context.Context, *ListFeatureSetsRequest) (*ListFeatureSetsResponse, error)
	// Retrieve store details given a filter.
	//
	// Returns all stores matching that filter. If none are found, an empty list will be returned.
	// If no filter is provided in the request, the response will contain all the stores currently
	// stored in the registry.
	ListStores(context.Context, *ListStoresRequest) (*ListStoresResponse, error)
	// Create or update and existing feature set.
	//
	// This function is idempotent - it will not create a new feature set if schema does not change.
	// If an existing feature set is updated, core will advance the version number, which will be
	// returned in response.
	ApplyFeatureSet(context.Context, *ApplyFeatureSetRequest) (*ApplyFeatureSetResponse, error)
	// Updates core with the configuration of the store.
	//
	// If the changes are valid, core will return the given store configuration in response, and
	// start or update the necessary feature population jobs for the updated store.
	UpdateStore(context.Context, *UpdateStoreRequest) (*UpdateStoreResponse, error)
	// Creates a project. Projects serve as namespaces within which resources like features will be
	// created. Both feature set names as well as field names must be unique within a project. Project
	// names themselves must be globally unique.
	CreateProject(context.Context, *CreateProjectRequest) (*CreateProjectResponse, error)
	// Archives a project. Archived projects will continue to exist and function, but won't be visible
	// through the Core API. Any existing ingestion or serving requests will continue to function,
	// but will result in warning messages being logged. It is not possible to unarchive a project
	// through the Core API
	ArchiveProject(context.Context, *ArchiveProjectRequest) (*ArchiveProjectResponse, error)
	// Lists all projects active projects.
	ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)
}

CoreServiceServer is the server API for CoreService service.

type CreateProjectRequest 

type CreateProjectRequest struct {
	// Name of project (required)
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to create a project

func (*CreateProjectRequest) Descriptor 

func (*CreateProjectRequest) Descriptor() ([]byte, []int)

func (*CreateProjectRequest) GetName 

func (m *CreateProjectRequest) GetName() string

func (*CreateProjectRequest) ProtoMessage 

func (*CreateProjectRequest) ProtoMessage()

func (*CreateProjectRequest) Reset 

func (m *CreateProjectRequest) Reset()

func (*CreateProjectRequest) String 

func (m *CreateProjectRequest) String() string

func (*CreateProjectRequest) XXX_DiscardUnknown 

func (m *CreateProjectRequest) XXX_DiscardUnknown()

func (*CreateProjectRequest) XXX_Marshal 

func (m *CreateProjectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateProjectRequest) XXX_Merge 

func (m *CreateProjectRequest) XXX_Merge(src proto.Message)

func (*CreateProjectRequest) XXX_Size 

func (m *CreateProjectRequest) XXX_Size() int

func (*CreateProjectRequest) XXX_Unmarshal 

func (m *CreateProjectRequest) XXX_Unmarshal(b []byte) error

type CreateProjectResponse 

type CreateProjectResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response for creation of a project

func (*CreateProjectResponse) Descriptor 

func (*CreateProjectResponse) Descriptor() ([]byte, []int)

func (*CreateProjectResponse) ProtoMessage 

func (*CreateProjectResponse) ProtoMessage()

func (*CreateProjectResponse) Reset 

func (m *CreateProjectResponse) Reset()

func (*CreateProjectResponse) String 

func (m *CreateProjectResponse) String() string

func (*CreateProjectResponse) XXX_DiscardUnknown 

func (m *CreateProjectResponse) XXX_DiscardUnknown()

func (*CreateProjectResponse) XXX_Marshal 

func (m *CreateProjectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateProjectResponse) XXX_Merge 

func (m *CreateProjectResponse) XXX_Merge(src proto.Message)

func (*CreateProjectResponse) XXX_Size 

func (m *CreateProjectResponse) XXX_Size() int

func (*CreateProjectResponse) XXX_Unmarshal 

func (m *CreateProjectResponse) XXX_Unmarshal(b []byte) error

type EntitySpec 

type EntitySpec struct {
	// Name of the entity.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Value type of the feature.
	ValueType            types.ValueType_Enum `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=feast.types.ValueType_Enum" json:"value_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*EntitySpec) Descriptor 

func (*EntitySpec) Descriptor() ([]byte, []int)

func (*EntitySpec) GetName 

func (m *EntitySpec) GetName() string

func (*EntitySpec) GetValueType 

func (m *EntitySpec) GetValueType() types.ValueType_Enum

func (*EntitySpec) ProtoMessage 

func (*EntitySpec) ProtoMessage()

func (*EntitySpec) Reset 

func (m *EntitySpec) Reset()

func (*EntitySpec) String 

func (m *EntitySpec) String() string

func (*EntitySpec) XXX_DiscardUnknown 

func (m *EntitySpec) XXX_DiscardUnknown()

func (*EntitySpec) XXX_Marshal 

func (m *EntitySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EntitySpec) XXX_Merge 

func (m *EntitySpec) XXX_Merge(src proto.Message)

func (*EntitySpec) XXX_Size 

func (m *EntitySpec) XXX_Size() int

func (*EntitySpec) XXX_Unmarshal 

func (m *EntitySpec) XXX_Unmarshal(b []byte) error

type FeatureSet 

type FeatureSet struct {
	// User-specified specifications of this feature set.
	Spec *FeatureSetSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// System-populated metadata for this feature set.
	Meta                 *FeatureSetMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*FeatureSet) Descriptor 

func (*FeatureSet) Descriptor() ([]byte, []int)

func (*FeatureSet) GetMeta 

func (m *FeatureSet) GetMeta() *FeatureSetMeta

func (*FeatureSet) GetSpec 

func (m *FeatureSet) GetSpec() *FeatureSetSpec

func (*FeatureSet) ProtoMessage 

func (*FeatureSet) ProtoMessage()

func (*FeatureSet) Reset 

func (m *FeatureSet) Reset()

func (*FeatureSet) String 

func (m *FeatureSet) String() string

func (*FeatureSet) XXX_DiscardUnknown 

func (m *FeatureSet) XXX_DiscardUnknown()

func (*FeatureSet) XXX_Marshal 

func (m *FeatureSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeatureSet) XXX_Merge 

func (m *FeatureSet) XXX_Merge(src proto.Message)

func (*FeatureSet) XXX_Size 

func (m *FeatureSet) XXX_Size() int

func (*FeatureSet) XXX_Unmarshal 

func (m *FeatureSet) XXX_Unmarshal(b []byte) error

type FeatureSetMeta 

type FeatureSetMeta struct {
	// Created timestamp of this specific feature set.
	CreatedTimestamp *timestamp.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	// Status of the feature set.
	// Used to indicate whether the feature set is ready for consumption or ingestion.
	// Currently supports 2 states:
	// 1) STATUS_PENDING - A feature set is in pending state if Feast has not spun up the jobs
	// necessary to push rows for this feature set to stores subscribing to this feature set.
	// 2) STATUS_READY - Feature set is ready for consumption or ingestion
	Status               FeatureSetStatus `protobuf:"varint,2,opt,name=status,proto3,enum=feast.core.FeatureSetStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*FeatureSetMeta) Descriptor 

func (*FeatureSetMeta) Descriptor() ([]byte, []int)

func (*FeatureSetMeta) GetCreatedTimestamp 

func (m *FeatureSetMeta) GetCreatedTimestamp() *timestamp.Timestamp

func (*FeatureSetMeta) GetStatus 

func (m *FeatureSetMeta) GetStatus() FeatureSetStatus

func (*FeatureSetMeta) ProtoMessage 

func (*FeatureSetMeta) ProtoMessage()

func (*FeatureSetMeta) Reset 

func (m *FeatureSetMeta) Reset()

func (*FeatureSetMeta) String 

func (m *FeatureSetMeta) String() string

func (*FeatureSetMeta) XXX_DiscardUnknown 

func (m *FeatureSetMeta) XXX_DiscardUnknown()

func (*FeatureSetMeta) XXX_Marshal 

func (m *FeatureSetMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeatureSetMeta) XXX_Merge 

func (m *FeatureSetMeta) XXX_Merge(src proto.Message)

func (*FeatureSetMeta) XXX_Size 

func (m *FeatureSetMeta) XXX_Size() int

func (*FeatureSetMeta) XXX_Unmarshal 

func (m *FeatureSetMeta) XXX_Unmarshal(b []byte) error

type FeatureSetSpec 

type FeatureSetSpec struct {
	// Name of project that this feature set belongs to.
	Project string `protobuf:"bytes,7,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the feature set. Must be unique.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Feature set version.
	Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// List of entities contained within this featureSet.
	// This allows the feature to be used during joins between feature sets.
	// If the featureSet is ingested into a store that supports keys, this value
	// will be made a key.
	Entities []*EntitySpec `protobuf:"bytes,3,rep,name=entities,proto3" json:"entities,omitempty"`
	// List of features contained within this featureSet.
	Features []*FeatureSpec `protobuf:"bytes,4,rep,name=features,proto3" json:"features,omitempty"`
	// Features in this feature set will only be retrieved if they are found
	// after [time - max_age]. Missing or older feature values will be returned
	// as nulls and indicated to end user
	MaxAge *duration.Duration `protobuf:"bytes,5,opt,name=max_age,json=maxAge,proto3" json:"max_age,omitempty"`
	// Optional. Source on which feature rows can be found.
	// If not set, source will be set to the default value configured in Feast Core.
	Source               *Source  `protobuf:"bytes,6,opt,name=source,proto3" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FeatureSetSpec) Descriptor 

func (*FeatureSetSpec) Descriptor() ([]byte, []int)

func (*FeatureSetSpec) GetEntities 

func (m *FeatureSetSpec) GetEntities() []*EntitySpec

func (*FeatureSetSpec) GetFeatures 

func (m *FeatureSetSpec) GetFeatures() []*FeatureSpec

func (*FeatureSetSpec) GetMaxAge 

func (m *FeatureSetSpec) GetMaxAge() *duration.Duration

func (*FeatureSetSpec) GetName 

func (m *FeatureSetSpec) GetName() string

func (*FeatureSetSpec) GetProject 

func (m *FeatureSetSpec) GetProject() string

func (*FeatureSetSpec) GetSource 

func (m *FeatureSetSpec) GetSource() *Source

func (*FeatureSetSpec) GetVersion 

func (m *FeatureSetSpec) GetVersion() int32

func (*FeatureSetSpec) ProtoMessage 

func (*FeatureSetSpec) ProtoMessage()

func (*FeatureSetSpec) Reset 

func (m *FeatureSetSpec) Reset()

func (*FeatureSetSpec) String 

func (m *FeatureSetSpec) String() string

func (*FeatureSetSpec) XXX_DiscardUnknown 

func (m *FeatureSetSpec) XXX_DiscardUnknown()

func (*FeatureSetSpec) XXX_Marshal 

func (m *FeatureSetSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeatureSetSpec) XXX_Merge 

func (m *FeatureSetSpec) XXX_Merge(src proto.Message)

func (*FeatureSetSpec) XXX_Size 

func (m *FeatureSetSpec) XXX_Size() int

func (*FeatureSetSpec) XXX_Unmarshal 

func (m *FeatureSetSpec) XXX_Unmarshal(b []byte) error

type FeatureSetStatus 

type FeatureSetStatus int32
const (
	FeatureSetStatus_STATUS_INVALID FeatureSetStatus = 0
	FeatureSetStatus_STATUS_PENDING FeatureSetStatus = 1
	FeatureSetStatus_STATUS_READY   FeatureSetStatus = 2
)

func (FeatureSetStatus) EnumDescriptor 

func (FeatureSetStatus) EnumDescriptor() ([]byte, []int)

func (FeatureSetStatus) String 

func (x FeatureSetStatus) String() string

type FeatureSpec 

type FeatureSpec struct {
	// Name of the feature.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Value type of the feature.
	ValueType            types.ValueType_Enum `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=feast.types.ValueType_Enum" json:"value_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*FeatureSpec) Descriptor 

func (*FeatureSpec) Descriptor() ([]byte, []int)

func (*FeatureSpec) GetName 

func (m *FeatureSpec) GetName() string

func (*FeatureSpec) GetValueType 

func (m *FeatureSpec) GetValueType() types.ValueType_Enum

func (*FeatureSpec) ProtoMessage 

func (*FeatureSpec) ProtoMessage()

func (*FeatureSpec) Reset 

func (m *FeatureSpec) Reset()

func (*FeatureSpec) String 

func (m *FeatureSpec) String() string

func (*FeatureSpec) XXX_DiscardUnknown 

func (m *FeatureSpec) XXX_DiscardUnknown()

func (*FeatureSpec) XXX_Marshal 

func (m *FeatureSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeatureSpec) XXX_Merge 

func (m *FeatureSpec) XXX_Merge(src proto.Message)

func (*FeatureSpec) XXX_Size 

func (m *FeatureSpec) XXX_Size() int

func (*FeatureSpec) XXX_Unmarshal 

func (m *FeatureSpec) XXX_Unmarshal(b []byte) error

type GetFeastCoreVersionRequest 

type GetFeastCoreVersionRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetFeastCoreVersionRequest) Descriptor 

func (*GetFeastCoreVersionRequest) Descriptor() ([]byte, []int)

func (*GetFeastCoreVersionRequest) ProtoMessage 

func (*GetFeastCoreVersionRequest) ProtoMessage()

func (*GetFeastCoreVersionRequest) Reset 

func (m *GetFeastCoreVersionRequest) Reset()

func (*GetFeastCoreVersionRequest) String 

func (m *GetFeastCoreVersionRequest) String() string

func (*GetFeastCoreVersionRequest) XXX_DiscardUnknown 

func (m *GetFeastCoreVersionRequest) XXX_DiscardUnknown()

func (*GetFeastCoreVersionRequest) XXX_Marshal 

func (m *GetFeastCoreVersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetFeastCoreVersionRequest) XXX_Merge 

func (m *GetFeastCoreVersionRequest) XXX_Merge(src proto.Message)

func (*GetFeastCoreVersionRequest) XXX_Size 

func (m *GetFeastCoreVersionRequest) XXX_Size() int

func (*GetFeastCoreVersionRequest) XXX_Unmarshal 

func (m *GetFeastCoreVersionRequest) XXX_Unmarshal(b []byte) error

type GetFeastCoreVersionResponse 

type GetFeastCoreVersionResponse struct {
	Version              string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetFeastCoreVersionResponse) Descriptor 

func (*GetFeastCoreVersionResponse) Descriptor() ([]byte, []int)

func (*GetFeastCoreVersionResponse) GetVersion 

func (m *GetFeastCoreVersionResponse) GetVersion() string

func (*GetFeastCoreVersionResponse) ProtoMessage 

func (*GetFeastCoreVersionResponse) ProtoMessage()

func (*GetFeastCoreVersionResponse) Reset 

func (m *GetFeastCoreVersionResponse) Reset()

func (*GetFeastCoreVersionResponse) String 

func (m *GetFeastCoreVersionResponse) String() string

func (*GetFeastCoreVersionResponse) XXX_DiscardUnknown 

func (m *GetFeastCoreVersionResponse) XXX_DiscardUnknown()

func (*GetFeastCoreVersionResponse) XXX_Marshal 

func (m *GetFeastCoreVersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetFeastCoreVersionResponse) XXX_Merge 

func (m *GetFeastCoreVersionResponse) XXX_Merge(src proto.Message)

func (*GetFeastCoreVersionResponse) XXX_Size 

func (m *GetFeastCoreVersionResponse) XXX_Size() int

func (*GetFeastCoreVersionResponse) XXX_Unmarshal 

func (m *GetFeastCoreVersionResponse) XXX_Unmarshal(b []byte) error

type GetFeatureSetRequest 

type GetFeatureSetRequest struct {
	// Name of project the feature set belongs to (required)
	Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	// Name of feature set (required).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Version of feature set (optional). If omitted then latest feature set will be returned.
	Version              int32    `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for a single feature set

func (*GetFeatureSetRequest) Descriptor 

func (*GetFeatureSetRequest) Descriptor() ([]byte, []int)

func (*GetFeatureSetRequest) GetName 

func (m *GetFeatureSetRequest) GetName() string

func (*GetFeatureSetRequest) GetProject 

func (m *GetFeatureSetRequest) GetProject() string

func (*GetFeatureSetRequest) GetVersion 

func (m *GetFeatureSetRequest) GetVersion() int32

func (*GetFeatureSetRequest) ProtoMessage 

func (*GetFeatureSetRequest) ProtoMessage()

func (*GetFeatureSetRequest) Reset 

func (m *GetFeatureSetRequest) Reset()

func (*GetFeatureSetRequest) String 

func (m *GetFeatureSetRequest) String() string

func (*GetFeatureSetRequest) XXX_DiscardUnknown 

func (m *GetFeatureSetRequest) XXX_DiscardUnknown()

func (*GetFeatureSetRequest) XXX_Marshal 

func (m *GetFeatureSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetFeatureSetRequest) XXX_Merge 

func (m *GetFeatureSetRequest) XXX_Merge(src proto.Message)

func (*GetFeatureSetRequest) XXX_Size 

func (m *GetFeatureSetRequest) XXX_Size() int

func (*GetFeatureSetRequest) XXX_Unmarshal 

func (m *GetFeatureSetRequest) XXX_Unmarshal(b []byte) error

type GetFeatureSetResponse 

type GetFeatureSetResponse struct {
	FeatureSet           *FeatureSet `protobuf:"bytes,1,opt,name=feature_set,json=featureSet,proto3" json:"feature_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Response containing a single feature set

func (*GetFeatureSetResponse) Descriptor 

func (*GetFeatureSetResponse) Descriptor() ([]byte, []int)

func (*GetFeatureSetResponse) GetFeatureSet 

func (m *GetFeatureSetResponse) GetFeatureSet() *FeatureSet

func (*GetFeatureSetResponse) ProtoMessage 

func (*GetFeatureSetResponse) ProtoMessage()

func (*GetFeatureSetResponse) Reset 

func (m *GetFeatureSetResponse) Reset()

func (*GetFeatureSetResponse) String 

func (m *GetFeatureSetResponse) String() string

func (*GetFeatureSetResponse) XXX_DiscardUnknown 

func (m *GetFeatureSetResponse) XXX_DiscardUnknown()

func (*GetFeatureSetResponse) XXX_Marshal 

func (m *GetFeatureSetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetFeatureSetResponse) XXX_Merge 

func (m *GetFeatureSetResponse) XXX_Merge(src proto.Message)

func (*GetFeatureSetResponse) XXX_Size 

func (m *GetFeatureSetResponse) XXX_Size() int

func (*GetFeatureSetResponse) XXX_Unmarshal 

func (m *GetFeatureSetResponse) XXX_Unmarshal(b []byte) error

type KafkaSourceConfig 

type KafkaSourceConfig struct {
	// - bootstrapServers: [comma delimited value of host[:port]]
	BootstrapServers string `protobuf:"bytes,1,opt,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"`
	// - topics: [Kafka topic name. This value is provisioned by core and should not be set by the user.]
	Topic                string   `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KafkaSourceConfig) Descriptor 

func (*KafkaSourceConfig) Descriptor() ([]byte, []int)

func (*KafkaSourceConfig) GetBootstrapServers 

func (m *KafkaSourceConfig) GetBootstrapServers() string

func (*KafkaSourceConfig) GetTopic 

func (m *KafkaSourceConfig) GetTopic() string

func (*KafkaSourceConfig) ProtoMessage 

func (*KafkaSourceConfig) ProtoMessage()

func (*KafkaSourceConfig) Reset 

func (m *KafkaSourceConfig) Reset()

func (*KafkaSourceConfig) String 

func (m *KafkaSourceConfig) String() string

func (*KafkaSourceConfig) XXX_DiscardUnknown 

func (m *KafkaSourceConfig) XXX_DiscardUnknown()

func (*KafkaSourceConfig) XXX_Marshal 

func (m *KafkaSourceConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KafkaSourceConfig) XXX_Merge 

func (m *KafkaSourceConfig) XXX_Merge(src proto.Message)

func (*KafkaSourceConfig) XXX_Size 

func (m *KafkaSourceConfig) XXX_Size() int

func (*KafkaSourceConfig) XXX_Unmarshal 

func (m *KafkaSourceConfig) XXX_Unmarshal(b []byte) error

type ListFeatureSetsRequest 

type ListFeatureSetsRequest struct {
	Filter               *ListFeatureSetsRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

Retrieves details for all versions of a specific feature set

func (*ListFeatureSetsRequest) Descriptor 

func (*ListFeatureSetsRequest) Descriptor() ([]byte, []int)

func (*ListFeatureSetsRequest) GetFilter 

func (m *ListFeatureSetsRequest) GetFilter() *ListFeatureSetsRequest_Filter

func (*ListFeatureSetsRequest) ProtoMessage 

func (*ListFeatureSetsRequest) ProtoMessage()

func (*ListFeatureSetsRequest) Reset 

func (m *ListFeatureSetsRequest) Reset()

func (*ListFeatureSetsRequest) String 

func (m *ListFeatureSetsRequest) String() string

func (*ListFeatureSetsRequest) XXX_DiscardUnknown 

func (m *ListFeatureSetsRequest) XXX_DiscardUnknown()

func (*ListFeatureSetsRequest) XXX_Marshal 

func (m *ListFeatureSetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListFeatureSetsRequest) XXX_Merge 

func (m *ListFeatureSetsRequest) XXX_Merge(src proto.Message)

func (*ListFeatureSetsRequest) XXX_Size 

func (m *ListFeatureSetsRequest) XXX_Size() int

func (*ListFeatureSetsRequest) XXX_Unmarshal 

func (m *ListFeatureSetsRequest) XXX_Unmarshal(b []byte) error

type ListFeatureSetsRequest_Filter 

type ListFeatureSetsRequest_Filter struct {
	// Name of project that the feature sets belongs to. This can be one of
	// - [project_name]
	// - *
	// If an asterisk is provided, filtering on projects will be disabled. All projects will
	// be matched. It is NOT possible to provide an asterisk with a string in order to do
	// pattern matching.
	Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the desired feature set. Asterisks can be used as wildcards in the name.
	// Matching on names is only permitted if a specific project is defined. It is disallowed
	// If the project name is set to "*"
	// e.g.
	// - * can be used to match all feature sets
	// - my-feature-set* can be used to match all features prefixed by "my-feature-set"
	// - my-feature-set-6 can be used to select a single feature set
	FeatureSetName string `protobuf:"bytes,1,opt,name=feature_set_name,json=featureSetName,proto3" json:"feature_set_name,omitempty"`
	// Versions of the given feature sets that will be returned.
	// Valid options for version:
	//     "latest": only the latest version is returned.
	//     "*": Subscribe to all versions
	//     [version number]: pin to a specific version. Project and feature set name must be
	//                       explicitly defined if a specific version is pinned.
	FeatureSetVersion    string   `protobuf:"bytes,2,opt,name=feature_set_version,json=featureSetVersion,proto3" json:"feature_set_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListFeatureSetsRequest_Filter) Descriptor 

func (*ListFeatureSetsRequest_Filter) Descriptor() ([]byte, []int)

func (*ListFeatureSetsRequest_Filter) GetFeatureSetName 

func (m *ListFeatureSetsRequest_Filter) GetFeatureSetName() string

func (*ListFeatureSetsRequest_Filter) GetFeatureSetVersion 

func (m *ListFeatureSetsRequest_Filter) GetFeatureSetVersion() string

func (*ListFeatureSetsRequest_Filter) GetProject 

func (m *ListFeatureSetsRequest_Filter) GetProject() string

func (*ListFeatureSetsRequest_Filter) ProtoMessage 

func (*ListFeatureSetsRequest_Filter) ProtoMessage()

func (*ListFeatureSetsRequest_Filter) Reset 

func (m *ListFeatureSetsRequest_Filter) Reset()

func (*ListFeatureSetsRequest_Filter) String 

func (m *ListFeatureSetsRequest_Filter) String() string

func (*ListFeatureSetsRequest_Filter) XXX_DiscardUnknown 

func (m *ListFeatureSetsRequest_Filter) XXX_DiscardUnknown()

func (*ListFeatureSetsRequest_Filter) XXX_Marshal 

func (m *ListFeatureSetsRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListFeatureSetsRequest_Filter) XXX_Merge 

func (m *ListFeatureSetsRequest_Filter) XXX_Merge(src proto.Message)

func (*ListFeatureSetsRequest_Filter) XXX_Size 

func (m *ListFeatureSetsRequest_Filter) XXX_Size() int

func (*ListFeatureSetsRequest_Filter) XXX_Unmarshal 

func (m *ListFeatureSetsRequest_Filter) XXX_Unmarshal(b []byte) error

type ListFeatureSetsResponse 

type ListFeatureSetsResponse struct {
	FeatureSets          []*FeatureSet `protobuf:"bytes,1,rep,name=feature_sets,json=featureSets,proto3" json:"feature_sets,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListFeatureSetsResponse) Descriptor 

func (*ListFeatureSetsResponse) Descriptor() ([]byte, []int)

func (*ListFeatureSetsResponse) GetFeatureSets 

func (m *ListFeatureSetsResponse) GetFeatureSets() []*FeatureSet

func (*ListFeatureSetsResponse) ProtoMessage 

func (*ListFeatureSetsResponse) ProtoMessage()

func (*ListFeatureSetsResponse) Reset 

func (m *ListFeatureSetsResponse) Reset()

func (*ListFeatureSetsResponse) String 

func (m *ListFeatureSetsResponse) String() string

func (*ListFeatureSetsResponse) XXX_DiscardUnknown 

func (m *ListFeatureSetsResponse) XXX_DiscardUnknown()

func (*ListFeatureSetsResponse) XXX_Marshal 

func (m *ListFeatureSetsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListFeatureSetsResponse) XXX_Merge 

func (m *ListFeatureSetsResponse) XXX_Merge(src proto.Message)

func (*ListFeatureSetsResponse) XXX_Size 

func (m *ListFeatureSetsResponse) XXX_Size() int

func (*ListFeatureSetsResponse) XXX_Unmarshal 

func (m *ListFeatureSetsResponse) XXX_Unmarshal(b []byte) error

type ListProjectsRequest 

type ListProjectsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request for listing of projects

func (*ListProjectsRequest) Descriptor 

func (*ListProjectsRequest) Descriptor() ([]byte, []int)

func (*ListProjectsRequest) ProtoMessage 

func (*ListProjectsRequest) ProtoMessage()

func (*ListProjectsRequest) Reset 

func (m *ListProjectsRequest) Reset()

func (*ListProjectsRequest) String 

func (m *ListProjectsRequest) String() string

func (*ListProjectsRequest) XXX_DiscardUnknown 

func (m *ListProjectsRequest) XXX_DiscardUnknown()

func (*ListProjectsRequest) XXX_Marshal 

func (m *ListProjectsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListProjectsRequest) XXX_Merge 

func (m *ListProjectsRequest) XXX_Merge(src proto.Message)

func (*ListProjectsRequest) XXX_Size 

func (m *ListProjectsRequest) XXX_Size() int

func (*ListProjectsRequest) XXX_Unmarshal 

func (m *ListProjectsRequest) XXX_Unmarshal(b []byte) error

type ListProjectsResponse 

type ListProjectsResponse struct {
	// List of project names (archived projects are filtered out)
	Projects             []string `protobuf:"bytes,1,rep,name=projects,proto3" json:"projects,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response for listing of projects

func (*ListProjectsResponse) Descriptor 

func (*ListProjectsResponse) Descriptor() ([]byte, []int)

func (*ListProjectsResponse) GetProjects 

func (m *ListProjectsResponse) GetProjects() []string

func (*ListProjectsResponse) ProtoMessage 

func (*ListProjectsResponse) ProtoMessage()

func (*ListProjectsResponse) Reset 

func (m *ListProjectsResponse) Reset()

func (*ListProjectsResponse) String 

func (m *ListProjectsResponse) String() string

func (*ListProjectsResponse) XXX_DiscardUnknown 

func (m *ListProjectsResponse) XXX_DiscardUnknown()

func (*ListProjectsResponse) XXX_Marshal 

func (m *ListProjectsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListProjectsResponse) XXX_Merge 

func (m *ListProjectsResponse) XXX_Merge(src proto.Message)

func (*ListProjectsResponse) XXX_Size 

func (m *ListProjectsResponse) XXX_Size() int

func (*ListProjectsResponse) XXX_Unmarshal 

func (m *ListProjectsResponse) XXX_Unmarshal(b []byte) error

type ListStoresRequest 

type ListStoresRequest struct {
	Filter               *ListStoresRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ListStoresRequest) Descriptor 

func (*ListStoresRequest) Descriptor() ([]byte, []int)

func (*ListStoresRequest) GetFilter 

func (m *ListStoresRequest) GetFilter() *ListStoresRequest_Filter

func (*ListStoresRequest) ProtoMessage 

func (*ListStoresRequest) ProtoMessage()

func (*ListStoresRequest) Reset 

func (m *ListStoresRequest) Reset()

func (*ListStoresRequest) String 

func (m *ListStoresRequest) String() string

func (*ListStoresRequest) XXX_DiscardUnknown 

func (m *ListStoresRequest) XXX_DiscardUnknown()

func (*ListStoresRequest) XXX_Marshal 

func (m *ListStoresRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListStoresRequest) XXX_Merge 

func (m *ListStoresRequest) XXX_Merge(src proto.Message)

func (*ListStoresRequest) XXX_Size 

func (m *ListStoresRequest) XXX_Size() int

func (*ListStoresRequest) XXX_Unmarshal 

func (m *ListStoresRequest) XXX_Unmarshal(b []byte) error

type ListStoresRequest_Filter 

type ListStoresRequest_Filter struct {
	// Name of desired store. Regex is not supported in this query.
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListStoresRequest_Filter) Descriptor 

func (*ListStoresRequest_Filter) Descriptor() ([]byte, []int)

func (*ListStoresRequest_Filter) GetName 

func (m *ListStoresRequest_Filter) GetName() string

func (*ListStoresRequest_Filter) ProtoMessage 

func (*ListStoresRequest_Filter) ProtoMessage()

func (*ListStoresRequest_Filter) Reset 

func (m *ListStoresRequest_Filter) Reset()

func (*ListStoresRequest_Filter) String 

func (m *ListStoresRequest_Filter) String() string

func (*ListStoresRequest_Filter) XXX_DiscardUnknown 

func (m *ListStoresRequest_Filter) XXX_DiscardUnknown()

func (*ListStoresRequest_Filter) XXX_Marshal 

func (m *ListStoresRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListStoresRequest_Filter) XXX_Merge 

func (m *ListStoresRequest_Filter) XXX_Merge(src proto.Message)

func (*ListStoresRequest_Filter) XXX_Size 

func (m *ListStoresRequest_Filter) XXX_Size() int

func (*ListStoresRequest_Filter) XXX_Unmarshal 

func (m *ListStoresRequest_Filter) XXX_Unmarshal(b []byte) error

type ListStoresResponse 

type ListStoresResponse struct {
	Store                []*Store `protobuf:"bytes,1,rep,name=store,proto3" json:"store,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListStoresResponse) Descriptor 

func (*ListStoresResponse) Descriptor() ([]byte, []int)

func (*ListStoresResponse) GetStore 

func (m *ListStoresResponse) GetStore() []*Store

func (*ListStoresResponse) ProtoMessage 

func (*ListStoresResponse) ProtoMessage()

func (*ListStoresResponse) Reset 

func (m *ListStoresResponse) Reset()

func (*ListStoresResponse) String 

func (m *ListStoresResponse) String() string

func (*ListStoresResponse) XXX_DiscardUnknown 

func (m *ListStoresResponse) XXX_DiscardUnknown()

func (*ListStoresResponse) XXX_Marshal 

func (m *ListStoresResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListStoresResponse) XXX_Merge 

func (m *ListStoresResponse) XXX_Merge(src proto.Message)

func (*ListStoresResponse) XXX_Size 

func (m *ListStoresResponse) XXX_Size() int

func (*ListStoresResponse) XXX_Unmarshal 

func (m *ListStoresResponse) XXX_Unmarshal(b []byte) error

type Source 

type Source struct {
	// The kind of data source Feast should connect to in order to retrieve FeatureRow value
	Type SourceType `protobuf:"varint,1,opt,name=type,proto3,enum=feast.core.SourceType" json:"type,omitempty"`
	// Source specific configuration
	//
	// Types that are valid to be assigned to SourceConfig:
	//	*Source_KafkaSourceConfig
	SourceConfig         isSource_SourceConfig `protobuf_oneof:"source_config"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Source) Descriptor 

func (*Source) Descriptor() ([]byte, []int)

func (*Source) GetKafkaSourceConfig 

func (m *Source) GetKafkaSourceConfig() *KafkaSourceConfig

func (*Source) GetSourceConfig 

func (m *Source) GetSourceConfig() isSource_SourceConfig

func (*Source) GetType 

func (m *Source) GetType() SourceType

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) Reset 

func (m *Source) Reset()

func (*Source) String 

func (m *Source) String() string

func (*Source) XXX_DiscardUnknown 

func (m *Source) XXX_DiscardUnknown()

func (*Source) XXX_Marshal 

func (m *Source) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Source) XXX_Merge 

func (m *Source) XXX_Merge(src proto.Message)

func (*Source) XXX_OneofWrappers 

func (*Source) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Source) XXX_Size 

func (m *Source) XXX_Size() int

func (*Source) XXX_Unmarshal 

func (m *Source) XXX_Unmarshal(b []byte) error

type SourceType 

type SourceType int32
const (
	SourceType_INVALID SourceType = 0
	SourceType_KAFKA   SourceType = 1
)

func (SourceType) EnumDescriptor 

func (SourceType) EnumDescriptor() ([]byte, []int)

func (SourceType) String 

func (x SourceType) String() string

type Source_KafkaSourceConfig 

type Source_KafkaSourceConfig struct {
	KafkaSourceConfig *KafkaSourceConfig `protobuf:"bytes,2,opt,name=kafka_source_config,json=kafkaSourceConfig,proto3,oneof"`
}

type Store 

type Store struct {
	// Name of the store.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of store.
	Type Store_StoreType `protobuf:"varint,2,opt,name=type,proto3,enum=feast.core.Store_StoreType" json:"type,omitempty"`
	// Feature sets to subscribe to.
	Subscriptions []*Store_Subscription `protobuf:"bytes,4,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// Configuration to connect to the store. Required.
	//
	// Types that are valid to be assigned to Config:
	//	*Store_RedisConfig_
	//	*Store_BigqueryConfig
	//	*Store_CassandraConfig_
	Config               isStore_Config `protobuf_oneof:"config"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Store provides a location where Feast reads and writes feature values. Feature values will be written to the Store in the form of FeatureRow elements. The way FeatureRow is encoded and decoded when it is written to and read from the Store depends on the type of the Store.

For example, a FeatureRow will materialize as a row in a table in BigQuery but it will materialize as a key, value pair element in Redis.

func (*Store) Descriptor 

func (*Store) Descriptor() ([]byte, []int)

func (*Store) GetBigqueryConfig 

func (m *Store) GetBigqueryConfig() *Store_BigQueryConfig

func (*Store) GetCassandraConfig 

func (m *Store) GetCassandraConfig() *Store_CassandraConfig

func (*Store) GetConfig 

func (m *Store) GetConfig() isStore_Config

func (*Store) GetName 

func (m *Store) GetName() string

func (*Store) GetRedisConfig 

func (m *Store) GetRedisConfig() *Store_RedisConfig

func (*Store) GetSubscriptions 

func (m *Store) GetSubscriptions() []*Store_Subscription

func (*Store) GetType 

func (m *Store) GetType() Store_StoreType

func (*Store) ProtoMessage 

func (*Store) ProtoMessage()

func (*Store) Reset 

func (m *Store) Reset()

func (*Store) String 

func (m *Store) String() string

func (*Store) XXX_DiscardUnknown 

func (m *Store) XXX_DiscardUnknown()

func (*Store) XXX_Marshal 

func (m *Store) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Store) XXX_Merge 

func (m *Store) XXX_Merge(src proto.Message)

func (*Store) XXX_OneofWrappers 

func (*Store) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Store) XXX_Size 

func (m *Store) XXX_Size() int

func (*Store) XXX_Unmarshal 

func (m *Store) XXX_Unmarshal(b []byte) error

type Store_BigQueryConfig 

type Store_BigQueryConfig struct {
	ProjectId            string   `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	DatasetId            string   `protobuf:"bytes,2,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Store_BigQueryConfig) Descriptor 

func (*Store_BigQueryConfig) Descriptor() ([]byte, []int)

func (*Store_BigQueryConfig) GetDatasetId 

func (m *Store_BigQueryConfig) GetDatasetId() string

func (*Store_BigQueryConfig) GetProjectId 

func (m *Store_BigQueryConfig) GetProjectId() string

func (*Store_BigQueryConfig) ProtoMessage 

func (*Store_BigQueryConfig) ProtoMessage()

func (*Store_BigQueryConfig) Reset 

func (m *Store_BigQueryConfig) Reset()

func (*Store_BigQueryConfig) String 

func (m *Store_BigQueryConfig) String() string

func (*Store_BigQueryConfig) XXX_DiscardUnknown 

func (m *Store_BigQueryConfig) XXX_DiscardUnknown()

func (*Store_BigQueryConfig) XXX_Marshal 

func (m *Store_BigQueryConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Store_BigQueryConfig) XXX_Merge 

func (m *Store_BigQueryConfig) XXX_Merge(src proto.Message)

func (*Store_BigQueryConfig) XXX_Size 

func (m *Store_BigQueryConfig) XXX_Size() int

func (*Store_BigQueryConfig) XXX_Unmarshal 

func (m *Store_BigQueryConfig) XXX_Unmarshal(b []byte) error

type Store_BigqueryConfig 

type Store_BigqueryConfig struct {
	BigqueryConfig *Store_BigQueryConfig `protobuf:"bytes,12,opt,name=bigquery_config,json=bigqueryConfig,proto3,oneof"`
}

type Store_CassandraConfig 

type Store_CassandraConfig struct {
	Host                 string   `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port                 int32    `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Store_CassandraConfig) Descriptor 

func (*Store_CassandraConfig) Descriptor() ([]byte, []int)

func (*Store_CassandraConfig) GetHost 

func (m *Store_CassandraConfig) GetHost() string

func (*Store_CassandraConfig) GetPort 

func (m *Store_CassandraConfig) GetPort() int32

func (*Store_CassandraConfig) ProtoMessage 

func (*Store_CassandraConfig) ProtoMessage()

func (*Store_CassandraConfig) Reset 

func (m *Store_CassandraConfig) Reset()

func (*Store_CassandraConfig) String 

func (m *Store_CassandraConfig) String() string

func (*Store_CassandraConfig) XXX_DiscardUnknown 

func (m *Store_CassandraConfig) XXX_DiscardUnknown()

func (*Store_CassandraConfig) XXX_Marshal 

func (m *Store_CassandraConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Store_CassandraConfig) XXX_Merge 

func (m *Store_CassandraConfig) XXX_Merge(src proto.Message)

func (*Store_CassandraConfig) XXX_Size 

func (m *Store_CassandraConfig) XXX_Size() int

func (*Store_CassandraConfig) XXX_Unmarshal 

func (m *Store_CassandraConfig) XXX_Unmarshal(b []byte) error

type Store_CassandraConfig_ 

type Store_CassandraConfig_ struct {
	CassandraConfig *Store_CassandraConfig `protobuf:"bytes,13,opt,name=cassandra_config,json=cassandraConfig,proto3,oneof"`
}

type Store_RedisConfig 

type Store_RedisConfig struct {
	Host                 string   `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port                 int32    `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Store_RedisConfig) Descriptor 

func (*Store_RedisConfig) Descriptor() ([]byte, []int)

func (*Store_RedisConfig) GetHost 

func (m *Store_RedisConfig) GetHost() string

func (*Store_RedisConfig) GetPort 

func (m *Store_RedisConfig) GetPort() int32

func (*Store_RedisConfig) ProtoMessage 

func (*Store_RedisConfig) ProtoMessage()

func (*Store_RedisConfig) Reset 

func (m *Store_RedisConfig) Reset()

func (*Store_RedisConfig) String 

func (m *Store_RedisConfig) String() string

func (*Store_RedisConfig) XXX_DiscardUnknown 

func (m *Store_RedisConfig) XXX_DiscardUnknown()

func (*Store_RedisConfig) XXX_Marshal 

func (m *Store_RedisConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Store_RedisConfig) XXX_Merge 

func (m *Store_RedisConfig) XXX_Merge(src proto.Message)

func (*Store_RedisConfig) XXX_Size 

func (m *Store_RedisConfig) XXX_Size() int

func (*Store_RedisConfig) XXX_Unmarshal 

func (m *Store_RedisConfig) XXX_Unmarshal(b []byte) error

type Store_RedisConfig_ 

type Store_RedisConfig_ struct {
	RedisConfig *Store_RedisConfig `protobuf:"bytes,11,opt,name=redis_config,json=redisConfig,proto3,oneof"`
}

type Store_StoreType 

type Store_StoreType int32
const (
	Store_INVALID Store_StoreType = 0
	// Redis stores a FeatureRow element as a key, value pair.
	//
	// The Redis data types used (https://redis.io/topics/data-types):
	// - key: STRING
	// - value: STRING
	//
	// Encodings:
	// - key: byte array of RedisKey (refer to feast.storage.RedisKey)
	// - value: byte array of FeatureRow (refer to feast.types.FeatureRow)
	//
	Store_REDIS Store_StoreType = 1
	// BigQuery stores a FeatureRow element as a row in a BigQuery table.
	//
	// Table name is derived from the feature set name and version as:
	// [feature_set_name]_v[feature_set_version]
	//
	// For example:
	// A feature row for feature set "driver" and version "1" will be written
	// to table "driver_v1".
	//
	// The entities and features in a FeatureSetSpec corresponds to the
	// fields in the BigQuery table (these make up the BigQuery schema).
	// The name of the entity spec and feature spec corresponds to the column
	// names, and the value_type of entity spec and feature spec corresponds
	// to BigQuery standard SQL data type of the column.
	//
	// The following BigQuery fields are reserved for Feast internal use.
	// Ingestion of entity or feature spec with names identical
	// to the following field names will raise an exception during ingestion.
	//
	//   column_name       | column_data_type | description
	// ====================|==================|================================
	// - event_timestamp   | TIMESTAMP        | event time of the FeatureRow
	// - created_timestamp | TIMESTAMP        | processing time of the ingestion of the FeatureRow
	// - job_id            | STRING           | identifier for the job that writes the FeatureRow to the corresponding BigQuery table
	//
	// BigQuery table created will be partitioned by the field "event_timestamp"
	// of the FeatureRow (https://cloud.google.com/bigquery/docs/partitioned-tables).
	//
	// Since newer version of feature set can introduce breaking, non backward-
	// compatible BigQuery schema updates, incrementing the version of a
	// feature set will result in the creation of a new empty BigQuery table
	// with the new schema.
	//
	// The following table shows how ValueType in Feast is mapped to
	// BigQuery Standard SQL data types
	// (https://cloud.google.com/bigquery/docs/reference/standard-sql/data-types):
	//
	// BYTES       : BYTES
	// STRING      : STRING
	// INT32       : INT64
	// INT64       : IN64
	// DOUBLE      : FLOAT64
	// FLOAT       : FLOAT64
	// BOOL        : BOOL
	// BYTES_LIST  : ARRAY
	// STRING_LIST : ARRAY
	// INT32_LIST  : ARRAY
	// INT64_LIST  : ARRAY
	// DOUBLE_LIST : ARRAY
	// FLOAT_LIST  : ARRAY
	// BOOL_LIST   : ARRAY
	//
	// The column mode in BigQuery is set to "Nullable" such that unset Value
	// in a FeatureRow corresponds to NULL value in BigQuery.
	//
	Store_BIGQUERY Store_StoreType = 2
	// Unsupported in Feast 0.3
	Store_CASSANDRA Store_StoreType = 3
)

func (Store_StoreType) EnumDescriptor 

func (Store_StoreType) EnumDescriptor() ([]byte, []int)

func (Store_StoreType) String 

func (x Store_StoreType) String() string

type Store_Subscription 

type Store_Subscription struct {
	// Name of project that the feature sets belongs to. This can be one of
	// - [project_name]
	// - *
	// If an asterisk is provided, filtering on projects will be disabled. All projects will
	// be matched. It is NOT possible to provide an asterisk with a string in order to do
	// pattern matching.
	Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the desired feature set. Asterisks can be used as wildcards in the name.
	// Matching on names is only permitted if a specific project is defined. It is disallowed
	// If the project name is set to "*"
	// e.g.
	// - * can be used to match all feature sets
	// - my-feature-set* can be used to match all features prefixed by "my-feature-set"
	// - my-feature-set-6 can be used to select a single feature set
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Versions of the given feature sets that will be returned.
	// Valid options for version:
	//     "latest": only the latest version is returned.
	//     "*": Subscribe to all versions
	//     [version number]: pin to a specific version. Project and feature set name must be
	//                       explicitly defined if a specific version is pinned.
	Version              string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Store_Subscription) Descriptor 

func (*Store_Subscription) Descriptor() ([]byte, []int)

func (*Store_Subscription) GetName 

func (m *Store_Subscription) GetName() string

func (*Store_Subscription) GetProject 

func (m *Store_Subscription) GetProject() string

func (*Store_Subscription) GetVersion 

func (m *Store_Subscription) GetVersion() string

func (*Store_Subscription) ProtoMessage 

func (*Store_Subscription) ProtoMessage()

func (*Store_Subscription) Reset 

func (m *Store_Subscription) Reset()

func (*Store_Subscription) String 

func (m *Store_Subscription) String() string

func (*Store_Subscription) XXX_DiscardUnknown 

func (m *Store_Subscription) XXX_DiscardUnknown()

func (*Store_Subscription) XXX_Marshal 

func (m *Store_Subscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Store_Subscription) XXX_Merge 

func (m *Store_Subscription) XXX_Merge(src proto.Message)

func (*Store_Subscription) XXX_Size 

func (m *Store_Subscription) XXX_Size() int

func (*Store_Subscription) XXX_Unmarshal 

func (m *Store_Subscription) XXX_Unmarshal(b []byte) error

type UnimplementedCoreServiceServer 

type UnimplementedCoreServiceServer struct {
}

UnimplementedCoreServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCoreServiceServer) ApplyFeatureSet 

func (*UnimplementedCoreServiceServer) ApplyFeatureSet(ctx context.Context, req *ApplyFeatureSetRequest) (*ApplyFeatureSetResponse, error)

func (*UnimplementedCoreServiceServer) ArchiveProject 

func (*UnimplementedCoreServiceServer) ArchiveProject(ctx context.Context, req *ArchiveProjectRequest) (*ArchiveProjectResponse, error)

func (*UnimplementedCoreServiceServer) CreateProject 

func (*UnimplementedCoreServiceServer) CreateProject(ctx context.Context, req *CreateProjectRequest) (*CreateProjectResponse, error)

func (*UnimplementedCoreServiceServer) GetFeastCoreVersion 

func (*UnimplementedCoreServiceServer) GetFeastCoreVersion(ctx context.Context, req *GetFeastCoreVersionRequest) (*GetFeastCoreVersionResponse, error)

func (*UnimplementedCoreServiceServer) GetFeatureSet 

func (*UnimplementedCoreServiceServer) GetFeatureSet(ctx context.Context, req *GetFeatureSetRequest) (*GetFeatureSetResponse, error)

func (*UnimplementedCoreServiceServer) ListFeatureSets 

func (*UnimplementedCoreServiceServer) ListFeatureSets(ctx context.Context, req *ListFeatureSetsRequest) (*ListFeatureSetsResponse, error)

func (*UnimplementedCoreServiceServer) ListProjects 

func (*UnimplementedCoreServiceServer) ListProjects(ctx context.Context, req *ListProjectsRequest) (*ListProjectsResponse, error)

func (*UnimplementedCoreServiceServer) ListStores 

func (*UnimplementedCoreServiceServer) ListStores(ctx context.Context, req *ListStoresRequest) (*ListStoresResponse, error)

func (*UnimplementedCoreServiceServer) UpdateStore 

func (*UnimplementedCoreServiceServer) UpdateStore(ctx context.Context, req *UpdateStoreRequest) (*UpdateStoreResponse, error)

type UpdateStoreRequest 

type UpdateStoreRequest struct {
	Store                *Store   `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateStoreRequest) Descriptor 

func (*UpdateStoreRequest) Descriptor() ([]byte, []int)

func (*UpdateStoreRequest) GetStore 

func (m *UpdateStoreRequest) GetStore() *Store

func (*UpdateStoreRequest) ProtoMessage 

func (*UpdateStoreRequest) ProtoMessage()

func (*UpdateStoreRequest) Reset 

func (m *UpdateStoreRequest) Reset()

func (*UpdateStoreRequest) String 

func (m *UpdateStoreRequest) String() string

func (*UpdateStoreRequest) XXX_DiscardUnknown 

func (m *UpdateStoreRequest) XXX_DiscardUnknown()

func (*UpdateStoreRequest) XXX_Marshal 

func (m *UpdateStoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateStoreRequest) XXX_Merge 

func (m *UpdateStoreRequest) XXX_Merge(src proto.Message)

func (*UpdateStoreRequest) XXX_Size 

func (m *UpdateStoreRequest) XXX_Size() int

func (*UpdateStoreRequest) XXX_Unmarshal 

func (m *UpdateStoreRequest) XXX_Unmarshal(b []byte) error

type UpdateStoreResponse 

type UpdateStoreResponse struct {
	Store                *Store                     `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
	Status               UpdateStoreResponse_Status `protobuf:"varint,2,opt,name=status,proto3,enum=feast.core.UpdateStoreResponse_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*UpdateStoreResponse) Descriptor 

func (*UpdateStoreResponse) Descriptor() ([]byte, []int)

func (*UpdateStoreResponse) GetStatus 

func (m *UpdateStoreResponse) GetStatus() UpdateStoreResponse_Status

func (*UpdateStoreResponse) GetStore 

func (m *UpdateStoreResponse) GetStore() *Store

func (*UpdateStoreResponse) ProtoMessage 

func (*UpdateStoreResponse) ProtoMessage()

func (*UpdateStoreResponse) Reset 

func (m *UpdateStoreResponse) Reset()

func (*UpdateStoreResponse) String 

func (m *UpdateStoreResponse) String() string

func (*UpdateStoreResponse) XXX_DiscardUnknown 

func (m *UpdateStoreResponse) XXX_DiscardUnknown()

func (*UpdateStoreResponse) XXX_Marshal 

func (m *UpdateStoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateStoreResponse) XXX_Merge 

func (m *UpdateStoreResponse) XXX_Merge(src proto.Message)

func (*UpdateStoreResponse) XXX_Size 

func (m *UpdateStoreResponse) XXX_Size() int

func (*UpdateStoreResponse) XXX_Unmarshal 

func (m *UpdateStoreResponse) XXX_Unmarshal(b []byte) error

type UpdateStoreResponse_Status 

type UpdateStoreResponse_Status int32
const (
	// Existing store config matching the given store id is identical to the given store config.
	UpdateStoreResponse_NO_CHANGE UpdateStoreResponse_Status = 0
	// New store created or existing config updated.
	UpdateStoreResponse_UPDATED UpdateStoreResponse_Status = 1
)

func (UpdateStoreResponse_Status) EnumDescriptor 

func (UpdateStoreResponse_Status) EnumDescriptor() ([]byte, []int)

func (UpdateStoreResponse_Status) String 

func (x UpdateStoreResponse_Status) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.