v1

package
v0.4.461 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_metaprov_modelaapi_services_onlinefeaturestored_v1_onlinefeaturestored_proto protoreflect.FileDescriptor

Functions

func RegisterOnlineFeatureStoreServiceServer 

func RegisterOnlineFeatureStoreServiceServer(s *grpc.Server, srv OnlineFeatureStoreServiceServer)

Types

type CreateFeatureRequest 

type CreateFeatureRequest struct {
	Name           string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ns             string               `protobuf:"bytes,2,opt,name=ns,proto3" json:"ns,omitempty"`
	ConnectionName string               `protobuf:"bytes,3,opt,name=connectionName,proto3" json:"connectionName,omitempty"`
	Item           *v1alpha1.Connection `protobuf:"bytes,4,opt,name=item,proto3" json:"item,omitempty"`
	Secret         map[string][]byte    `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateFeatureRequest) Descriptor deprecated 

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

Deprecated: Use CreateFeatureRequest.ProtoReflect.Descriptor instead.

func (*CreateFeatureRequest) GetConnectionName 

func (x *CreateFeatureRequest) GetConnectionName() string

func (*CreateFeatureRequest) GetItem 

func (x *CreateFeatureRequest) GetItem() *v1alpha1.Connection

func (*CreateFeatureRequest) GetName 

func (x *CreateFeatureRequest) GetName() string

func (*CreateFeatureRequest) GetNs 

func (x *CreateFeatureRequest) GetNs() string

func (*CreateFeatureRequest) GetSecret 

func (x *CreateFeatureRequest) GetSecret() map[string][]byte

func (*CreateFeatureRequest) ProtoMessage 

func (*CreateFeatureRequest) ProtoMessage()

func (*CreateFeatureRequest) ProtoReflect 

func (x *CreateFeatureRequest) ProtoReflect() protoreflect.Message

func (*CreateFeatureRequest) Reset 

func (x *CreateFeatureRequest) Reset()

func (*CreateFeatureRequest) String 

func (x *CreateFeatureRequest) String() string

type CreateFeatureResponse 

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

func (*CreateFeatureResponse) Descriptor deprecated 

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

Deprecated: Use CreateFeatureResponse.ProtoReflect.Descriptor instead.

func (*CreateFeatureResponse) ProtoMessage 

func (*CreateFeatureResponse) ProtoMessage()

func (*CreateFeatureResponse) ProtoReflect 

func (x *CreateFeatureResponse) ProtoReflect() protoreflect.Message

func (*CreateFeatureResponse) Reset 

func (x *CreateFeatureResponse) Reset()

func (*CreateFeatureResponse) String 

func (x *CreateFeatureResponse) String() string

type DeleteFeatureRequest 

type DeleteFeatureRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ns   string `protobuf:"bytes,2,opt,name=ns,proto3" json:"ns,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFeatureRequest) Descriptor deprecated 

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

Deprecated: Use DeleteFeatureRequest.ProtoReflect.Descriptor instead.

func (*DeleteFeatureRequest) GetName 

func (x *DeleteFeatureRequest) GetName() string

func (*DeleteFeatureRequest) GetNs 

func (x *DeleteFeatureRequest) GetNs() string

func (*DeleteFeatureRequest) ProtoMessage 

func (*DeleteFeatureRequest) ProtoMessage()

func (*DeleteFeatureRequest) ProtoReflect 

func (x *DeleteFeatureRequest) ProtoReflect() protoreflect.Message

func (*DeleteFeatureRequest) Reset 

func (x *DeleteFeatureRequest) Reset()

func (*DeleteFeatureRequest) String 

func (x *DeleteFeatureRequest) String() string

type DeleteFeatureResponse 

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

func (*DeleteFeatureResponse) Descriptor deprecated 

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

Deprecated: Use DeleteFeatureResponse.ProtoReflect.Descriptor instead.

func (*DeleteFeatureResponse) ProtoMessage 

func (*DeleteFeatureResponse) ProtoMessage()

func (*DeleteFeatureResponse) ProtoReflect 

func (x *DeleteFeatureResponse) ProtoReflect() protoreflect.Message

func (*DeleteFeatureResponse) Reset 

func (x *DeleteFeatureResponse) Reset()

func (*DeleteFeatureResponse) String 

func (x *DeleteFeatureResponse) String() string

type EnrichRequest 

type EnrichRequest struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Record string `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*EnrichRequest) Descriptor deprecated 

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

Deprecated: Use EnrichRequest.ProtoReflect.Descriptor instead.

func (*EnrichRequest) GetId 

func (x *EnrichRequest) GetId() string

func (*EnrichRequest) GetRecord 

func (x *EnrichRequest) GetRecord() string

func (*EnrichRequest) ProtoMessage 

func (*EnrichRequest) ProtoMessage()

func (*EnrichRequest) ProtoReflect 

func (x *EnrichRequest) ProtoReflect() protoreflect.Message

func (*EnrichRequest) Reset 

func (x *EnrichRequest) Reset()

func (*EnrichRequest) String 

func (x *EnrichRequest) String() string

type EnrichResponse 

type EnrichResponse struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Record string `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*EnrichResponse) Descriptor deprecated 

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

Deprecated: Use EnrichResponse.ProtoReflect.Descriptor instead.

func (*EnrichResponse) GetId 

func (x *EnrichResponse) GetId() string

func (*EnrichResponse) GetRecord 

func (x *EnrichResponse) GetRecord() string

func (*EnrichResponse) ProtoMessage 

func (*EnrichResponse) ProtoMessage()

func (*EnrichResponse) ProtoReflect 

func (x *EnrichResponse) ProtoReflect() protoreflect.Message

func (*EnrichResponse) Reset 

func (x *EnrichResponse) Reset()

func (*EnrichResponse) String 

func (x *EnrichResponse) String() string

type GetFeatureRequest 

type GetFeatureRequest struct {
	Name string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ns   string             `protobuf:"bytes,2,opt,name=ns,proto3" json:"ns,omitempty"`
	Item *v1alpha11.Feature `protobuf:"bytes,3,opt,name=item,proto3" json:"item,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFeatureRequest) Descriptor deprecated 

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

Deprecated: Use GetFeatureRequest.ProtoReflect.Descriptor instead.

func (*GetFeatureRequest) GetItem 

func (x *GetFeatureRequest) GetItem() *v1alpha11.Feature

func (*GetFeatureRequest) GetName 

func (x *GetFeatureRequest) GetName() string

func (*GetFeatureRequest) GetNs 

func (x *GetFeatureRequest) GetNs() string

func (*GetFeatureRequest) ProtoMessage 

func (*GetFeatureRequest) ProtoMessage()

func (*GetFeatureRequest) ProtoReflect 

func (x *GetFeatureRequest) ProtoReflect() protoreflect.Message

func (*GetFeatureRequest) Reset 

func (x *GetFeatureRequest) Reset()

func (*GetFeatureRequest) String 

func (x *GetFeatureRequest) String() string

type GetFeatureResponse 

type GetFeatureResponse struct {
	Item *v1alpha11.Feature `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFeatureResponse) Descriptor deprecated 

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

Deprecated: Use GetFeatureResponse.ProtoReflect.Descriptor instead.

func (*GetFeatureResponse) GetItem 

func (x *GetFeatureResponse) GetItem() *v1alpha11.Feature

func (*GetFeatureResponse) ProtoMessage 

func (*GetFeatureResponse) ProtoMessage()

func (*GetFeatureResponse) ProtoReflect 

func (x *GetFeatureResponse) ProtoReflect() protoreflect.Message

func (*GetFeatureResponse) Reset 

func (x *GetFeatureResponse) Reset()

func (*GetFeatureResponse) String 

func (x *GetFeatureResponse) String() string

type ListFeaturesRequest 

type ListFeaturesRequest struct {
	Ns string `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFeaturesRequest) Descriptor deprecated 

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

Deprecated: Use ListFeaturesRequest.ProtoReflect.Descriptor instead.

func (*ListFeaturesRequest) GetNs 

func (x *ListFeaturesRequest) GetNs() string

func (*ListFeaturesRequest) ProtoMessage 

func (*ListFeaturesRequest) ProtoMessage()

func (*ListFeaturesRequest) ProtoReflect 

func (x *ListFeaturesRequest) ProtoReflect() protoreflect.Message

func (*ListFeaturesRequest) Reset 

func (x *ListFeaturesRequest) Reset()

func (*ListFeaturesRequest) String 

func (x *ListFeaturesRequest) String() string

type ListFeaturesResponse 

type ListFeaturesResponse struct {
	Items *v1alpha11.FeatureList `protobuf:"bytes,1,opt,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFeaturesResponse) Descriptor deprecated 

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

Deprecated: Use ListFeaturesResponse.ProtoReflect.Descriptor instead.

func (*ListFeaturesResponse) GetItems 

func (x *ListFeaturesResponse) GetItems() *v1alpha11.FeatureList

func (*ListFeaturesResponse) ProtoMessage 

func (*ListFeaturesResponse) ProtoMessage()

func (*ListFeaturesResponse) ProtoReflect 

func (x *ListFeaturesResponse) ProtoReflect() protoreflect.Message

func (*ListFeaturesResponse) Reset 

func (x *ListFeaturesResponse) Reset()

func (*ListFeaturesResponse) String 

func (x *ListFeaturesResponse) String() string

type OnlineFeatureStoreServiceClient 

type OnlineFeatureStoreServiceClient interface {
	CreateFeature(ctx context.Context, in *CreateFeatureRequest, opts ...grpc.CallOption) (*CreateFeatureResponse, error)
	DeleteFeature(ctx context.Context, in *DeleteFeatureRequest, opts ...grpc.CallOption) (*DeleteFeatureResponse, error)
	ListFeatures(ctx context.Context, in *ListFeaturesRequest, opts ...grpc.CallOption) (*ListFeaturesResponse, error)
	GetFeature(ctx context.Context, in *GetFeatureRequest, opts ...grpc.CallOption) (*GetFeatureResponse, error)
	UpdateFeature(ctx context.Context, in *UpdateFeatureRequest, opts ...grpc.CallOption) (*UpdateFeatureResponse, error)
	Enrich(ctx context.Context, in *EnrichRequest, opts ...grpc.CallOption) (*EnrichResponse, error)
}

OnlineFeatureStoreServiceClient is the client API for OnlineFeatureStoreService service.

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

func NewOnlineFeatureStoreServiceClient 

func NewOnlineFeatureStoreServiceClient(cc grpc.ClientConnInterface) OnlineFeatureStoreServiceClient

type OnlineFeatureStoreServiceServer 

type OnlineFeatureStoreServiceServer interface {
	CreateFeature(context.Context, *CreateFeatureRequest) (*CreateFeatureResponse, error)
	DeleteFeature(context.Context, *DeleteFeatureRequest) (*DeleteFeatureResponse, error)
	ListFeatures(context.Context, *ListFeaturesRequest) (*ListFeaturesResponse, error)
	GetFeature(context.Context, *GetFeatureRequest) (*GetFeatureResponse, error)
	UpdateFeature(context.Context, *UpdateFeatureRequest) (*UpdateFeatureResponse, error)
	Enrich(context.Context, *EnrichRequest) (*EnrichResponse, error)
}

OnlineFeatureStoreServiceServer is the server API for OnlineFeatureStoreService service.

type UnimplementedOnlineFeatureStoreServiceServer 

type UnimplementedOnlineFeatureStoreServiceServer struct {
}

UnimplementedOnlineFeatureStoreServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedOnlineFeatureStoreServiceServer) CreateFeature 

func (*UnimplementedOnlineFeatureStoreServiceServer) CreateFeature(context.Context, *CreateFeatureRequest) (*CreateFeatureResponse, error)

func (*UnimplementedOnlineFeatureStoreServiceServer) DeleteFeature 

func (*UnimplementedOnlineFeatureStoreServiceServer) DeleteFeature(context.Context, *DeleteFeatureRequest) (*DeleteFeatureResponse, error)

func (*UnimplementedOnlineFeatureStoreServiceServer) Enrich 

func (*UnimplementedOnlineFeatureStoreServiceServer) Enrich(context.Context, *EnrichRequest) (*EnrichResponse, error)

func (*UnimplementedOnlineFeatureStoreServiceServer) GetFeature 

func (*UnimplementedOnlineFeatureStoreServiceServer) GetFeature(context.Context, *GetFeatureRequest) (*GetFeatureResponse, error)

func (*UnimplementedOnlineFeatureStoreServiceServer) ListFeatures 

func (*UnimplementedOnlineFeatureStoreServiceServer) ListFeatures(context.Context, *ListFeaturesRequest) (*ListFeaturesResponse, error)

func (*UnimplementedOnlineFeatureStoreServiceServer) UpdateFeature 

func (*UnimplementedOnlineFeatureStoreServiceServer) UpdateFeature(context.Context, *UpdateFeatureRequest) (*UpdateFeatureResponse, error)

type UpdateFeatureRequest 

type UpdateFeatureRequest struct {
	Item       *v1alpha11.Feature   `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	Connection *v1alpha1.Connection `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte    `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateFeatureRequest) Descriptor deprecated 

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

Deprecated: Use UpdateFeatureRequest.ProtoReflect.Descriptor instead.

func (*UpdateFeatureRequest) GetConnection 

func (x *UpdateFeatureRequest) GetConnection() *v1alpha1.Connection

func (*UpdateFeatureRequest) GetItem 

func (x *UpdateFeatureRequest) GetItem() *v1alpha11.Feature

func (*UpdateFeatureRequest) GetSecret 

func (x *UpdateFeatureRequest) GetSecret() map[string][]byte

func (*UpdateFeatureRequest) ProtoMessage 

func (*UpdateFeatureRequest) ProtoMessage()

func (*UpdateFeatureRequest) ProtoReflect 

func (x *UpdateFeatureRequest) ProtoReflect() protoreflect.Message

func (*UpdateFeatureRequest) Reset 

func (x *UpdateFeatureRequest) Reset()

func (*UpdateFeatureRequest) String 

func (x *UpdateFeatureRequest) String() string

type UpdateFeatureResponse 

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

func (*UpdateFeatureResponse) Descriptor deprecated 

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

Deprecated: Use UpdateFeatureResponse.ProtoReflect.Descriptor instead.

func (*UpdateFeatureResponse) ProtoMessage 

func (*UpdateFeatureResponse) ProtoMessage()

func (*UpdateFeatureResponse) ProtoReflect 

func (x *UpdateFeatureResponse) ProtoReflect() protoreflect.Message

func (*UpdateFeatureResponse) Reset 

func (x *UpdateFeatureResponse) Reset()

func (*UpdateFeatureResponse) String 

func (x *UpdateFeatureResponse) 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.