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 (*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

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 (*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 (*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 (*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) ArchiveProject

                                func (*UnimplementedCoreServiceServer) CreateProject

                                func (*UnimplementedCoreServiceServer) GetFeastCoreVersion

                                func (*UnimplementedCoreServiceServer) GetFeatureSet

                                func (*UnimplementedCoreServiceServer) ListFeatureSets

                                func (*UnimplementedCoreServiceServer) ListProjects

                                func (*UnimplementedCoreServiceServer) ListStores

                                func (*UnimplementedCoreServiceServer) UpdateStore

                                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 (*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