Documentation ¶
Overview ¶
Package stub is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package stub is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package stub is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package stub is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package stub is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package stub is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package stub is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package stub is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterAuthenticationHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterAuthenticationHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AuthenticationClient) error
- func RegisterAuthenticationHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterAuthenticationHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AuthenticationServer) error
- func RegisterAuthenticationServer(s grpc.ServiceRegistrar, srv AuthenticationServer)
- func RegisterDataSourceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterDataSourceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DataSourceClient) error
- func RegisterDataSourceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterDataSourceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DataSourceServer) error
- func RegisterDataSourceServer(s grpc.ServiceRegistrar, srv DataSourceServer)
- func RegisterExtensionHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterExtensionHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ExtensionClient) error
- func RegisterExtensionHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterExtensionHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ExtensionServer) error
- func RegisterExtensionServer(s grpc.ServiceRegistrar, srv ExtensionServer)
- func RegisterGenericServer(s grpc.ServiceRegistrar, srv GenericServer)
- func RegisterNamespaceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterNamespaceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client NamespaceClient) error
- func RegisterNamespaceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterNamespaceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server NamespaceServer) error
- func RegisterNamespaceServer(s grpc.ServiceRegistrar, srv NamespaceServer)
- func RegisterRecordHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterRecordHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RecordClient) error
- func RegisterRecordHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterRecordHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RecordServer) error
- func RegisterRecordServer(s grpc.ServiceRegistrar, srv RecordServer)
- func RegisterResourceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterResourceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ResourceClient) error
- func RegisterResourceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterResourceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ResourceServer) error
- func RegisterResourceServer(s grpc.ServiceRegistrar, srv ResourceServer)
- func RegisterUserHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterUserHandlerClient(ctx context.Context, mux *runtime.ServeMux, client UserClient) error
- func RegisterUserHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterUserHandlerServer(ctx context.Context, mux *runtime.ServeMux, server UserServer) error
- func RegisterUserServer(s grpc.ServiceRegistrar, srv UserServer)
- func RegisterWatchHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterWatchHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WatchClient) error
- func RegisterWatchHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterWatchHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WatchServer) error
- func RegisterWatchServer(s grpc.ServiceRegistrar, srv WatchServer)
- type ApplyRecordRequest
- func (*ApplyRecordRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyRecordRequest) GetAnnotations() map[string]string
- func (x *ApplyRecordRequest) GetNamespace() string
- func (x *ApplyRecordRequest) GetRecord() *model.Record
- func (x *ApplyRecordRequest) GetRecords() []*model.Record
- func (x *ApplyRecordRequest) GetResource() string
- func (x *ApplyRecordRequest) GetToken() string
- func (*ApplyRecordRequest) ProtoMessage()
- func (x *ApplyRecordRequest) ProtoReflect() protoreflect.Message
- func (x *ApplyRecordRequest) Reset()
- func (x *ApplyRecordRequest) String() string
- type ApplyRecordResponse
- func (*ApplyRecordResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyRecordResponse) GetRecord() *model.Record
- func (x *ApplyRecordResponse) GetRecords() []*model.Record
- func (*ApplyRecordResponse) ProtoMessage()
- func (x *ApplyRecordResponse) ProtoReflect() protoreflect.Message
- func (x *ApplyRecordResponse) Reset()
- func (x *ApplyRecordResponse) String() string
- type AuthenticationClient
- type AuthenticationRequest
- func (*AuthenticationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AuthenticationRequest) GetPassword() string
- func (x *AuthenticationRequest) GetTerm() model.TokenTerm
- func (x *AuthenticationRequest) GetUsername() string
- func (*AuthenticationRequest) ProtoMessage()
- func (x *AuthenticationRequest) ProtoReflect() protoreflect.Message
- func (x *AuthenticationRequest) Reset()
- func (x *AuthenticationRequest) String() string
- type AuthenticationResponse
- func (*AuthenticationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AuthenticationResponse) GetToken() *model.Token
- func (*AuthenticationResponse) ProtoMessage()
- func (x *AuthenticationResponse) ProtoReflect() protoreflect.Message
- func (x *AuthenticationResponse) Reset()
- func (x *AuthenticationResponse) String() string
- type AuthenticationServer
- type CreateDataSourceRequest
- func (*CreateDataSourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDataSourceRequest) GetDataSources() []*model.DataSource
- func (x *CreateDataSourceRequest) GetToken() string
- func (*CreateDataSourceRequest) ProtoMessage()
- func (x *CreateDataSourceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateDataSourceRequest) Reset()
- func (x *CreateDataSourceRequest) String() string
- type CreateDataSourceResponse
- func (*CreateDataSourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDataSourceResponse) GetDataSources() []*model.DataSource
- func (*CreateDataSourceResponse) ProtoMessage()
- func (x *CreateDataSourceResponse) ProtoReflect() protoreflect.Message
- func (x *CreateDataSourceResponse) Reset()
- func (x *CreateDataSourceResponse) String() string
- type CreateExtensionRequest
- func (*CreateExtensionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateExtensionRequest) GetExtensions() []*model.Extension
- func (x *CreateExtensionRequest) GetToken() string
- func (*CreateExtensionRequest) ProtoMessage()
- func (x *CreateExtensionRequest) ProtoReflect() protoreflect.Message
- func (x *CreateExtensionRequest) Reset()
- func (x *CreateExtensionRequest) String() string
- type CreateExtensionResponse
- func (*CreateExtensionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateExtensionResponse) GetExtensions() []*model.Extension
- func (*CreateExtensionResponse) ProtoMessage()
- func (x *CreateExtensionResponse) ProtoReflect() protoreflect.Message
- func (x *CreateExtensionResponse) Reset()
- func (x *CreateExtensionResponse) String() string
- type CreateNamespaceRequest
- func (*CreateNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateNamespaceRequest) GetNamespaces() []*model.Namespace
- func (x *CreateNamespaceRequest) GetToken() string
- func (*CreateNamespaceRequest) ProtoMessage()
- func (x *CreateNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateNamespaceRequest) Reset()
- func (x *CreateNamespaceRequest) String() string
- type CreateNamespaceResponse
- func (*CreateNamespaceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateNamespaceResponse) GetNamespaces() []*model.Namespace
- func (*CreateNamespaceResponse) ProtoMessage()
- func (x *CreateNamespaceResponse) ProtoReflect() protoreflect.Message
- func (x *CreateNamespaceResponse) Reset()
- func (x *CreateNamespaceResponse) String() string
- type CreateRecordRequest
- func (*CreateRecordRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateRecordRequest) GetAnnotations() map[string]string
- func (x *CreateRecordRequest) GetNamespace() string
- func (x *CreateRecordRequest) GetRecord() *model.Record
- func (x *CreateRecordRequest) GetRecords() []*model.Record
- func (x *CreateRecordRequest) GetResource() string
- func (x *CreateRecordRequest) GetToken() string
- func (*CreateRecordRequest) ProtoMessage()
- func (x *CreateRecordRequest) ProtoReflect() protoreflect.Message
- func (x *CreateRecordRequest) Reset()
- func (x *CreateRecordRequest) String() string
- type CreateRecordResponse
- func (*CreateRecordResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateRecordResponse) GetInserted() []bool
- func (x *CreateRecordResponse) GetRecord() *model.Record
- func (x *CreateRecordResponse) GetRecords() []*model.Record
- func (*CreateRecordResponse) ProtoMessage()
- func (x *CreateRecordResponse) ProtoReflect() protoreflect.Message
- func (x *CreateRecordResponse) Reset()
- func (x *CreateRecordResponse) String() string
- type CreateRequest
- func (*CreateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateRequest) GetAnnotations() map[string]string
- func (x *CreateRequest) GetIgnoreIfExists() bool
- func (x *CreateRequest) GetItems() []*anypb.Any
- func (x *CreateRequest) GetNamespace() string
- func (x *CreateRequest) GetResource() string
- func (x *CreateRequest) GetToken() string
- func (*CreateRequest) ProtoMessage()
- func (x *CreateRequest) ProtoReflect() protoreflect.Message
- func (x *CreateRequest) Reset()
- func (x *CreateRequest) String() string
- type CreateResourceRequest
- func (*CreateResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateResourceRequest) GetAnnotations() map[string]string
- func (x *CreateResourceRequest) GetDoMigration() bool
- func (x *CreateResourceRequest) GetForceMigration() bool
- func (x *CreateResourceRequest) GetResources() []*model.Resource
- func (x *CreateResourceRequest) GetToken() string
- func (*CreateResourceRequest) ProtoMessage()
- func (x *CreateResourceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateResourceRequest) Reset()
- func (x *CreateResourceRequest) String() string
- type CreateResourceResponse
- func (*CreateResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateResourceResponse) GetResources() []*model.Resource
- func (*CreateResourceResponse) ProtoMessage()
- func (x *CreateResourceResponse) ProtoReflect() protoreflect.Message
- func (x *CreateResourceResponse) Reset()
- func (x *CreateResourceResponse) String() string
- type CreateResponse
- func (*CreateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateResponse) GetInserted() []bool
- func (x *CreateResponse) GetItems() []*anypb.Any
- func (*CreateResponse) ProtoMessage()
- func (x *CreateResponse) ProtoReflect() protoreflect.Message
- func (x *CreateResponse) Reset()
- func (x *CreateResponse) String() string
- type CreateUserRequest
- func (*CreateUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateUserRequest) GetToken() string
- func (x *CreateUserRequest) GetUser() *model.User
- func (x *CreateUserRequest) GetUsers() []*model.User
- func (*CreateUserRequest) ProtoMessage()
- func (x *CreateUserRequest) ProtoReflect() protoreflect.Message
- func (x *CreateUserRequest) Reset()
- func (x *CreateUserRequest) String() string
- type CreateUserResponse
- func (*CreateUserResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateUserResponse) GetUser() *model.User
- func (x *CreateUserResponse) GetUsers() []*model.User
- func (*CreateUserResponse) ProtoMessage()
- func (x *CreateUserResponse) ProtoReflect() protoreflect.Message
- func (x *CreateUserResponse) Reset()
- func (x *CreateUserResponse) String() string
- type DataSourceClient
- type DataSourceServer
- type DeleteDataSourceRequest
- func (*DeleteDataSourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteDataSourceRequest) GetIds() []string
- func (x *DeleteDataSourceRequest) GetToken() string
- func (*DeleteDataSourceRequest) ProtoMessage()
- func (x *DeleteDataSourceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteDataSourceRequest) Reset()
- func (x *DeleteDataSourceRequest) String() string
- type DeleteDataSourceResponse
- type DeleteExtensionRequest
- func (*DeleteExtensionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteExtensionRequest) GetIds() []string
- func (x *DeleteExtensionRequest) GetToken() string
- func (*DeleteExtensionRequest) ProtoMessage()
- func (x *DeleteExtensionRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteExtensionRequest) Reset()
- func (x *DeleteExtensionRequest) String() string
- type DeleteExtensionResponse
- type DeleteNamespaceRequest
- func (*DeleteNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteNamespaceRequest) GetIds() []string
- func (x *DeleteNamespaceRequest) GetToken() string
- func (*DeleteNamespaceRequest) ProtoMessage()
- func (x *DeleteNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteNamespaceRequest) Reset()
- func (x *DeleteNamespaceRequest) String() string
- type DeleteNamespaceResponse
- func (*DeleteNamespaceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteNamespaceResponse) GetNamespaces() []*model.Namespace
- func (*DeleteNamespaceResponse) ProtoMessage()
- func (x *DeleteNamespaceResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteNamespaceResponse) Reset()
- func (x *DeleteNamespaceResponse) String() string
- type DeleteRecordRequest
- func (*DeleteRecordRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRecordRequest) GetAnnotations() map[string]string
- func (x *DeleteRecordRequest) GetId() string
- func (x *DeleteRecordRequest) GetIds() []string
- func (x *DeleteRecordRequest) GetNamespace() string
- func (x *DeleteRecordRequest) GetResource() string
- func (x *DeleteRecordRequest) GetToken() string
- func (*DeleteRecordRequest) ProtoMessage()
- func (x *DeleteRecordRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRecordRequest) Reset()
- func (x *DeleteRecordRequest) String() string
- type DeleteRecordResponse
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRequest) GetAnnotations() map[string]string
- func (x *DeleteRequest) GetId() []string
- func (x *DeleteRequest) GetIds() []string
- func (x *DeleteRequest) GetNamespace() string
- func (x *DeleteRequest) GetResource() string
- func (x *DeleteRequest) GetToken() string
- func (*DeleteRequest) ProtoMessage()
- func (x *DeleteRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRequest) Reset()
- func (x *DeleteRequest) String() string
- type DeleteResourceRequest
- func (*DeleteResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteResourceRequest) GetAnnotations() map[string]string
- func (x *DeleteResourceRequest) GetDoMigration() bool
- func (x *DeleteResourceRequest) GetForceMigration() bool
- func (x *DeleteResourceRequest) GetIds() []string
- func (x *DeleteResourceRequest) GetToken() string
- func (*DeleteResourceRequest) ProtoMessage()
- func (x *DeleteResourceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteResourceRequest) Reset()
- func (x *DeleteResourceRequest) String() string
- type DeleteResourceResponse
- type DeleteResponse
- type DeleteUserRequest
- func (*DeleteUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteUserRequest) GetId() string
- func (x *DeleteUserRequest) GetIds() []string
- func (x *DeleteUserRequest) GetToken() string
- func (*DeleteUserRequest) ProtoMessage()
- func (x *DeleteUserRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteUserRequest) Reset()
- func (x *DeleteUserRequest) String() string
- type DeleteUserResponse
- type ExtensionClient
- type ExtensionServer
- type GenericClient
- type GenericServer
- type GetDataSourceRequest
- func (*GetDataSourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDataSourceRequest) GetId() string
- func (x *GetDataSourceRequest) GetToken() string
- func (*GetDataSourceRequest) ProtoMessage()
- func (x *GetDataSourceRequest) ProtoReflect() protoreflect.Message
- func (x *GetDataSourceRequest) Reset()
- func (x *GetDataSourceRequest) String() string
- type GetDataSourceResponse
- func (*GetDataSourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDataSourceResponse) GetDataSource() *model.DataSource
- func (*GetDataSourceResponse) ProtoMessage()
- func (x *GetDataSourceResponse) ProtoReflect() protoreflect.Message
- func (x *GetDataSourceResponse) Reset()
- func (x *GetDataSourceResponse) String() string
- type GetExtensionRequest
- func (*GetExtensionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetExtensionRequest) GetId() string
- func (x *GetExtensionRequest) GetToken() string
- func (*GetExtensionRequest) ProtoMessage()
- func (x *GetExtensionRequest) ProtoReflect() protoreflect.Message
- func (x *GetExtensionRequest) Reset()
- func (x *GetExtensionRequest) String() string
- type GetExtensionResponse
- func (*GetExtensionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetExtensionResponse) GetExtension() *model.Extension
- func (*GetExtensionResponse) ProtoMessage()
- func (x *GetExtensionResponse) ProtoReflect() protoreflect.Message
- func (x *GetExtensionResponse) Reset()
- func (x *GetExtensionResponse) String() string
- type GetNamespaceRequest
- func (*GetNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespaceRequest) GetId() string
- func (x *GetNamespaceRequest) GetToken() string
- func (*GetNamespaceRequest) ProtoMessage()
- func (x *GetNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *GetNamespaceRequest) Reset()
- func (x *GetNamespaceRequest) String() string
- type GetNamespaceResponse
- func (*GetNamespaceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespaceResponse) GetNamespace() *model.Namespace
- func (*GetNamespaceResponse) ProtoMessage()
- func (x *GetNamespaceResponse) ProtoReflect() protoreflect.Message
- func (x *GetNamespaceResponse) Reset()
- func (x *GetNamespaceResponse) String() string
- type GetRecordRequest
- func (*GetRecordRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRecordRequest) GetAnnotations() map[string]string
- func (x *GetRecordRequest) GetId() string
- func (x *GetRecordRequest) GetNamespace() string
- func (x *GetRecordRequest) GetResource() string
- func (x *GetRecordRequest) GetToken() string
- func (*GetRecordRequest) ProtoMessage()
- func (x *GetRecordRequest) ProtoReflect() protoreflect.Message
- func (x *GetRecordRequest) Reset()
- func (x *GetRecordRequest) String() string
- type GetRecordResponse
- func (*GetRecordResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetRecordResponse) GetRecord() *model.Record
- func (*GetRecordResponse) ProtoMessage()
- func (x *GetRecordResponse) ProtoReflect() protoreflect.Message
- func (x *GetRecordResponse) Reset()
- func (x *GetRecordResponse) String() string
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRequest) GetAnnotations() map[string]string
- func (x *GetRequest) GetId() string
- func (x *GetRequest) GetNamespace() string
- func (x *GetRequest) GetResource() string
- func (x *GetRequest) GetToken() string
- func (*GetRequest) ProtoMessage()
- func (x *GetRequest) ProtoReflect() protoreflect.Message
- func (x *GetRequest) Reset()
- func (x *GetRequest) String() string
- type GetResourceByNameRequest
- func (*GetResourceByNameRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetResourceByNameRequest) GetAnnotations() map[string]string
- func (x *GetResourceByNameRequest) GetName() string
- func (x *GetResourceByNameRequest) GetNamespace() string
- func (x *GetResourceByNameRequest) GetToken() string
- func (*GetResourceByNameRequest) ProtoMessage()
- func (x *GetResourceByNameRequest) ProtoReflect() protoreflect.Message
- func (x *GetResourceByNameRequest) Reset()
- func (x *GetResourceByNameRequest) String() string
- type GetResourceByNameResponse
- func (*GetResourceByNameResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetResourceByNameResponse) GetResource() *model.Resource
- func (*GetResourceByNameResponse) ProtoMessage()
- func (x *GetResourceByNameResponse) ProtoReflect() protoreflect.Message
- func (x *GetResourceByNameResponse) Reset()
- func (x *GetResourceByNameResponse) String() string
- type GetResourceRequest
- func (*GetResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetResourceRequest) GetAnnotations() map[string]string
- func (x *GetResourceRequest) GetId() string
- func (x *GetResourceRequest) GetToken() string
- func (*GetResourceRequest) ProtoMessage()
- func (x *GetResourceRequest) ProtoReflect() protoreflect.Message
- func (x *GetResourceRequest) Reset()
- func (x *GetResourceRequest) String() string
- type GetResourceResponse
- func (*GetResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetResourceResponse) GetResource() *model.Resource
- func (*GetResourceResponse) ProtoMessage()
- func (x *GetResourceResponse) ProtoReflect() protoreflect.Message
- func (x *GetResourceResponse) Reset()
- func (x *GetResourceResponse) String() string
- type GetResponse
- type GetSystemResourceRequest
- func (*GetSystemResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSystemResourceRequest) GetAnnotations() map[string]string
- func (x *GetSystemResourceRequest) GetName() string
- func (x *GetSystemResourceRequest) GetToken() string
- func (*GetSystemResourceRequest) ProtoMessage()
- func (x *GetSystemResourceRequest) ProtoReflect() protoreflect.Message
- func (x *GetSystemResourceRequest) Reset()
- func (x *GetSystemResourceRequest) String() string
- type GetSystemResourceResponse
- func (*GetSystemResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSystemResourceResponse) GetResource() *model.Resource
- func (*GetSystemResourceResponse) ProtoMessage()
- func (x *GetSystemResourceResponse) ProtoReflect() protoreflect.Message
- func (x *GetSystemResourceResponse) Reset()
- func (x *GetSystemResourceResponse) String() string
- type GetUserRequest
- func (*GetUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetUserRequest) GetId() string
- func (x *GetUserRequest) GetToken() string
- func (*GetUserRequest) ProtoMessage()
- func (x *GetUserRequest) ProtoReflect() protoreflect.Message
- func (x *GetUserRequest) Reset()
- func (x *GetUserRequest) String() string
- type GetUserResponse
- type ListDataSourceRequest
- func (*ListDataSourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListDataSourceRequest) GetToken() string
- func (*ListDataSourceRequest) ProtoMessage()
- func (x *ListDataSourceRequest) ProtoReflect() protoreflect.Message
- func (x *ListDataSourceRequest) Reset()
- func (x *ListDataSourceRequest) String() string
- type ListDataSourceResponse
- func (*ListDataSourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListDataSourceResponse) GetContent() []*model.DataSource
- func (*ListDataSourceResponse) ProtoMessage()
- func (x *ListDataSourceResponse) ProtoReflect() protoreflect.Message
- func (x *ListDataSourceResponse) Reset()
- func (x *ListDataSourceResponse) String() string
- type ListEntitiesRequest
- func (*ListEntitiesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListEntitiesRequest) GetId() string
- func (x *ListEntitiesRequest) GetToken() string
- func (*ListEntitiesRequest) ProtoMessage()
- func (x *ListEntitiesRequest) ProtoReflect() protoreflect.Message
- func (x *ListEntitiesRequest) Reset()
- func (x *ListEntitiesRequest) String() string
- type ListEntitiesResponse
- func (*ListEntitiesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListEntitiesResponse) GetCatalogs() []*model.DataSourceCatalog
- func (*ListEntitiesResponse) ProtoMessage()
- func (x *ListEntitiesResponse) ProtoReflect() protoreflect.Message
- func (x *ListEntitiesResponse) Reset()
- func (x *ListEntitiesResponse) String() string
- type ListExtensionRequest
- func (*ListExtensionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListExtensionRequest) GetToken() string
- func (*ListExtensionRequest) ProtoMessage()
- func (x *ListExtensionRequest) ProtoReflect() protoreflect.Message
- func (x *ListExtensionRequest) Reset()
- func (x *ListExtensionRequest) String() string
- type ListExtensionResponse
- func (*ListExtensionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListExtensionResponse) GetContent() []*model.Extension
- func (*ListExtensionResponse) ProtoMessage()
- func (x *ListExtensionResponse) ProtoReflect() protoreflect.Message
- func (x *ListExtensionResponse) Reset()
- func (x *ListExtensionResponse) String() string
- type ListNamespaceRequest
- func (*ListNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListNamespaceRequest) GetToken() string
- func (*ListNamespaceRequest) ProtoMessage()
- func (x *ListNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *ListNamespaceRequest) Reset()
- func (x *ListNamespaceRequest) String() string
- type ListNamespaceResponse
- func (*ListNamespaceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListNamespaceResponse) GetContent() []*model.Namespace
- func (*ListNamespaceResponse) ProtoMessage()
- func (x *ListNamespaceResponse) ProtoReflect() protoreflect.Message
- func (x *ListNamespaceResponse) Reset()
- func (x *ListNamespaceResponse) String() string
- type ListRecordRequest
- func (*ListRecordRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListRecordRequest) GetAnnotations() map[string]string
- func (x *ListRecordRequest) GetFilters() map[string]string
- func (x *ListRecordRequest) GetLimit() uint32
- func (x *ListRecordRequest) GetNamespace() string
- func (x *ListRecordRequest) GetOffset() uint64
- func (x *ListRecordRequest) GetResolveReferences() []string
- func (x *ListRecordRequest) GetResource() string
- func (x *ListRecordRequest) GetToken() string
- func (x *ListRecordRequest) GetUseHistory() bool
- func (*ListRecordRequest) ProtoMessage()
- func (x *ListRecordRequest) ProtoReflect() protoreflect.Message
- func (x *ListRecordRequest) Reset()
- func (x *ListRecordRequest) String() string
- type ListRecordResponse
- func (*ListRecordResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListRecordResponse) GetContent() []*model.Record
- func (x *ListRecordResponse) GetTotal() uint32
- func (*ListRecordResponse) ProtoMessage()
- func (x *ListRecordResponse) ProtoReflect() protoreflect.Message
- func (x *ListRecordResponse) Reset()
- func (x *ListRecordResponse) String() string
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListRequest) GetAnnotations() map[string]string
- func (x *ListRequest) GetFilters() map[string]string
- func (x *ListRequest) GetLimit() uint32
- func (x *ListRequest) GetNamespace() string
- func (x *ListRequest) GetOffset() uint64
- func (x *ListRequest) GetResolveReferences() []string
- func (x *ListRequest) GetResource() string
- func (x *ListRequest) GetToken() string
- func (x *ListRequest) GetUseHistory() bool
- func (*ListRequest) ProtoMessage()
- func (x *ListRequest) ProtoReflect() protoreflect.Message
- func (x *ListRequest) Reset()
- func (x *ListRequest) String() string
- type ListResourceRequest
- func (*ListResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListResourceRequest) GetAnnotations() map[string]string
- func (x *ListResourceRequest) GetToken() string
- func (*ListResourceRequest) ProtoMessage()
- func (x *ListResourceRequest) ProtoReflect() protoreflect.Message
- func (x *ListResourceRequest) Reset()
- func (x *ListResourceRequest) String() string
- type ListResourceResponse
- func (*ListResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListResourceResponse) GetResources() []*model.Resource
- func (*ListResourceResponse) ProtoMessage()
- func (x *ListResourceResponse) ProtoReflect() protoreflect.Message
- func (x *ListResourceResponse) Reset()
- func (x *ListResourceResponse) String() string
- type ListResponse
- func (*ListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListResponse) GetContent() []*anypb.Any
- func (x *ListResponse) GetTotal() uint32
- func (*ListResponse) ProtoMessage()
- func (x *ListResponse) ProtoReflect() protoreflect.Message
- func (x *ListResponse) Reset()
- func (x *ListResponse) String() string
- type ListUserRequest
- func (*ListUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListUserRequest) GetLimit() uint32
- func (x *ListUserRequest) GetOffset() uint64
- func (x *ListUserRequest) GetToken() string
- func (*ListUserRequest) ProtoMessage()
- func (x *ListUserRequest) ProtoReflect() protoreflect.Message
- func (x *ListUserRequest) Reset()
- func (x *ListUserRequest) String() string
- type ListUserResponse
- type NamespaceClient
- type NamespaceServer
- type PrepareResourceFromEntityRequest
- func (*PrepareResourceFromEntityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PrepareResourceFromEntityRequest) GetCatalog() string
- func (x *PrepareResourceFromEntityRequest) GetEntity() string
- func (x *PrepareResourceFromEntityRequest) GetId() string
- func (x *PrepareResourceFromEntityRequest) GetToken() string
- func (*PrepareResourceFromEntityRequest) ProtoMessage()
- func (x *PrepareResourceFromEntityRequest) ProtoReflect() protoreflect.Message
- func (x *PrepareResourceFromEntityRequest) Reset()
- func (x *PrepareResourceFromEntityRequest) String() string
- type PrepareResourceFromEntityResponse
- func (*PrepareResourceFromEntityResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PrepareResourceFromEntityResponse) GetResource() *model.Resource
- func (*PrepareResourceFromEntityResponse) ProtoMessage()
- func (x *PrepareResourceFromEntityResponse) ProtoReflect() protoreflect.Message
- func (x *PrepareResourceFromEntityResponse) Reset()
- func (x *PrepareResourceFromEntityResponse) String() string
- type PrepareResourceMigrationPlanRequest
- func (*PrepareResourceMigrationPlanRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PrepareResourceMigrationPlanRequest) GetAnnotations() map[string]string
- func (x *PrepareResourceMigrationPlanRequest) GetPrepareFromDataSource() bool
- func (x *PrepareResourceMigrationPlanRequest) GetResources() []*model.Resource
- func (x *PrepareResourceMigrationPlanRequest) GetToken() string
- func (*PrepareResourceMigrationPlanRequest) ProtoMessage()
- func (x *PrepareResourceMigrationPlanRequest) ProtoReflect() protoreflect.Message
- func (x *PrepareResourceMigrationPlanRequest) Reset()
- func (x *PrepareResourceMigrationPlanRequest) String() string
- type PrepareResourceMigrationPlanResponse
- func (*PrepareResourceMigrationPlanResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PrepareResourceMigrationPlanResponse) GetPlans() []*model.ResourceMigrationPlan
- func (*PrepareResourceMigrationPlanResponse) ProtoMessage()
- func (x *PrepareResourceMigrationPlanResponse) ProtoReflect() protoreflect.Message
- func (x *PrepareResourceMigrationPlanResponse) Reset()
- func (x *PrepareResourceMigrationPlanResponse) String() string
- type ReadStreamRequest
- func (*ReadStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadStreamRequest) GetAnnotations() map[string]string
- func (x *ReadStreamRequest) GetLimit() uint32
- func (x *ReadStreamRequest) GetNamespace() string
- func (x *ReadStreamRequest) GetOffset() uint64
- func (x *ReadStreamRequest) GetPackRecords() bool
- func (x *ReadStreamRequest) GetQuery() *model.BooleanExpression
- func (x *ReadStreamRequest) GetResolveReferences() []string
- func (x *ReadStreamRequest) GetResource() string
- func (x *ReadStreamRequest) GetToken() string
- func (x *ReadStreamRequest) GetUseHistory() bool
- func (x *ReadStreamRequest) GetUseTransaction() bool
- func (*ReadStreamRequest) ProtoMessage()
- func (x *ReadStreamRequest) ProtoReflect() protoreflect.Message
- func (x *ReadStreamRequest) Reset()
- func (x *ReadStreamRequest) String() string
- type RecordClient
- type RecordServer
- type Record_ReadStreamClient
- type Record_ReadStreamServer
- type Record_WriteStreamClient
- type Record_WriteStreamServer
- type RenewTokenRequest
- func (*RenewTokenRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RenewTokenRequest) GetTerm() model.TokenTerm
- func (x *RenewTokenRequest) GetToken() string
- func (*RenewTokenRequest) ProtoMessage()
- func (x *RenewTokenRequest) ProtoReflect() protoreflect.Message
- func (x *RenewTokenRequest) Reset()
- func (x *RenewTokenRequest) String() string
- type RenewTokenResponse
- func (*RenewTokenResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RenewTokenResponse) GetToken() *model.Token
- func (*RenewTokenResponse) ProtoMessage()
- func (x *RenewTokenResponse) ProtoReflect() protoreflect.Message
- func (x *RenewTokenResponse) Reset()
- func (x *RenewTokenResponse) String() string
- type ResourceClient
- type ResourceServer
- type SearchRecordRequest
- func (*SearchRecordRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchRecordRequest) GetAnnotations() map[string]string
- func (x *SearchRecordRequest) GetLimit() uint32
- func (x *SearchRecordRequest) GetNamespace() string
- func (x *SearchRecordRequest) GetOffset() uint64
- func (x *SearchRecordRequest) GetQuery() *model.BooleanExpression
- func (x *SearchRecordRequest) GetResolveReferences() []string
- func (x *SearchRecordRequest) GetResource() string
- func (x *SearchRecordRequest) GetToken() string
- func (x *SearchRecordRequest) GetUseHistory() bool
- func (*SearchRecordRequest) ProtoMessage()
- func (x *SearchRecordRequest) ProtoReflect() protoreflect.Message
- func (x *SearchRecordRequest) Reset()
- func (x *SearchRecordRequest) String() string
- type SearchRecordResponse
- func (*SearchRecordResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SearchRecordResponse) GetContent() []*model.Record
- func (x *SearchRecordResponse) GetTotal() uint32
- func (*SearchRecordResponse) ProtoMessage()
- func (x *SearchRecordResponse) ProtoReflect() protoreflect.Message
- func (x *SearchRecordResponse) Reset()
- func (x *SearchRecordResponse) String() string
- type SearchRequest
- func (*SearchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchRequest) GetAnnotations() map[string]string
- func (x *SearchRequest) GetLimit() uint32
- func (x *SearchRequest) GetNamespace() string
- func (x *SearchRequest) GetOffset() uint64
- func (x *SearchRequest) GetQuery() *model.BooleanExpression
- func (x *SearchRequest) GetResolveReferences() []string
- func (x *SearchRequest) GetResource() string
- func (x *SearchRequest) GetToken() string
- func (x *SearchRequest) GetUseHistory() bool
- func (*SearchRequest) ProtoMessage()
- func (x *SearchRequest) ProtoReflect() protoreflect.Message
- func (x *SearchRequest) Reset()
- func (x *SearchRequest) String() string
- type SearchResponse
- func (*SearchResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SearchResponse) GetContent() []*anypb.Any
- func (x *SearchResponse) GetTotal() uint32
- func (*SearchResponse) ProtoMessage()
- func (x *SearchResponse) ProtoReflect() protoreflect.Message
- func (x *SearchResponse) Reset()
- func (x *SearchResponse) String() string
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatusRequest) GetId() string
- func (x *StatusRequest) GetToken() string
- func (*StatusRequest) ProtoMessage()
- func (x *StatusRequest) ProtoReflect() protoreflect.Message
- func (x *StatusRequest) Reset()
- func (x *StatusRequest) String() string
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatusResponse) GetConnectionAlreadyInitiated() bool
- func (x *StatusResponse) GetTestConnection() bool
- func (*StatusResponse) ProtoMessage()
- func (x *StatusResponse) ProtoReflect() protoreflect.Message
- func (x *StatusResponse) Reset()
- func (x *StatusResponse) String() string
- type UnimplementedAuthenticationServer
- type UnimplementedDataSourceServer
- func (UnimplementedDataSourceServer) Create(context.Context, *CreateDataSourceRequest) (*CreateDataSourceResponse, error)
- func (UnimplementedDataSourceServer) Delete(context.Context, *DeleteDataSourceRequest) (*DeleteDataSourceResponse, error)
- func (UnimplementedDataSourceServer) Get(context.Context, *GetDataSourceRequest) (*GetDataSourceResponse, error)
- func (UnimplementedDataSourceServer) List(context.Context, *ListDataSourceRequest) (*ListDataSourceResponse, error)
- func (UnimplementedDataSourceServer) ListEntities(context.Context, *ListEntitiesRequest) (*ListEntitiesResponse, error)
- func (UnimplementedDataSourceServer) PrepareResourceFromEntity(context.Context, *PrepareResourceFromEntityRequest) (*PrepareResourceFromEntityResponse, error)
- func (UnimplementedDataSourceServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)
- func (UnimplementedDataSourceServer) Update(context.Context, *UpdateDataSourceRequest) (*UpdateDataSourceResponse, error)
- type UnimplementedExtensionServer
- func (UnimplementedExtensionServer) Create(context.Context, *CreateExtensionRequest) (*CreateExtensionResponse, error)
- func (UnimplementedExtensionServer) Delete(context.Context, *DeleteExtensionRequest) (*DeleteExtensionResponse, error)
- func (UnimplementedExtensionServer) Get(context.Context, *GetExtensionRequest) (*GetExtensionResponse, error)
- func (UnimplementedExtensionServer) List(context.Context, *ListExtensionRequest) (*ListExtensionResponse, error)
- func (UnimplementedExtensionServer) Update(context.Context, *UpdateExtensionRequest) (*UpdateExtensionResponse, error)
- type UnimplementedGenericServer
- func (UnimplementedGenericServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)
- func (UnimplementedGenericServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
- func (UnimplementedGenericServer) Get(context.Context, *GetRequest) (*GetResponse, error)
- func (UnimplementedGenericServer) List(context.Context, *ListRequest) (*ListResponse, error)
- func (UnimplementedGenericServer) Search(context.Context, *SearchRequest) (*SearchResponse, error)
- func (UnimplementedGenericServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
- func (UnimplementedGenericServer) UpdateMulti(context.Context, *UpdateMultiRequest) (*UpdateMultiResponse, error)
- type UnimplementedNamespaceServer
- func (UnimplementedNamespaceServer) Create(context.Context, *CreateNamespaceRequest) (*CreateNamespaceResponse, error)
- func (UnimplementedNamespaceServer) Delete(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
- func (UnimplementedNamespaceServer) Get(context.Context, *GetNamespaceRequest) (*GetNamespaceResponse, error)
- func (UnimplementedNamespaceServer) List(context.Context, *ListNamespaceRequest) (*ListNamespaceResponse, error)
- func (UnimplementedNamespaceServer) Update(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)
- type UnimplementedRecordServer
- func (UnimplementedRecordServer) Apply(context.Context, *ApplyRecordRequest) (*ApplyRecordResponse, error)
- func (UnimplementedRecordServer) Create(context.Context, *CreateRecordRequest) (*CreateRecordResponse, error)
- func (UnimplementedRecordServer) Delete(context.Context, *DeleteRecordRequest) (*DeleteRecordResponse, error)
- func (UnimplementedRecordServer) Get(context.Context, *GetRecordRequest) (*GetRecordResponse, error)
- func (UnimplementedRecordServer) List(context.Context, *ListRecordRequest) (*ListRecordResponse, error)
- func (UnimplementedRecordServer) ReadStream(*ReadStreamRequest, Record_ReadStreamServer) error
- func (UnimplementedRecordServer) Search(context.Context, *SearchRecordRequest) (*SearchRecordResponse, error)
- func (UnimplementedRecordServer) Update(context.Context, *UpdateRecordRequest) (*UpdateRecordResponse, error)
- func (UnimplementedRecordServer) UpdateMulti(context.Context, *UpdateMultiRecordRequest) (*UpdateMultiRecordResponse, error)
- func (UnimplementedRecordServer) WriteStream(Record_WriteStreamServer) error
- type UnimplementedResourceServer
- func (UnimplementedResourceServer) Create(context.Context, *CreateResourceRequest) (*CreateResourceResponse, error)
- func (UnimplementedResourceServer) Delete(context.Context, *DeleteResourceRequest) (*DeleteResourceResponse, error)
- func (UnimplementedResourceServer) Get(context.Context, *GetResourceRequest) (*GetResourceResponse, error)
- func (UnimplementedResourceServer) GetByName(context.Context, *GetResourceByNameRequest) (*GetResourceByNameResponse, error)
- func (UnimplementedResourceServer) GetSystemResource(context.Context, *GetSystemResourceRequest) (*GetSystemResourceResponse, error)
- func (UnimplementedResourceServer) List(context.Context, *ListResourceRequest) (*ListResourceResponse, error)
- func (UnimplementedResourceServer) PrepareResourceMigrationPlan(context.Context, *PrepareResourceMigrationPlanRequest) (*PrepareResourceMigrationPlanResponse, error)
- func (UnimplementedResourceServer) Update(context.Context, *UpdateResourceRequest) (*UpdateResourceResponse, error)
- type UnimplementedUserServer
- func (UnimplementedUserServer) Create(context.Context, *CreateUserRequest) (*CreateUserResponse, error)
- func (UnimplementedUserServer) Delete(context.Context, *DeleteUserRequest) (*DeleteUserResponse, error)
- func (UnimplementedUserServer) Get(context.Context, *GetUserRequest) (*GetUserResponse, error)
- func (UnimplementedUserServer) List(context.Context, *ListUserRequest) (*ListUserResponse, error)
- func (UnimplementedUserServer) Update(context.Context, *UpdateUserRequest) (*UpdateUserResponse, error)
- type UnimplementedWatchServer
- type UnsafeAuthenticationServer
- type UnsafeDataSourceServer
- type UnsafeExtensionServer
- type UnsafeGenericServer
- type UnsafeNamespaceServer
- type UnsafeRecordServer
- type UnsafeResourceServer
- type UnsafeUserServer
- type UnsafeWatchServer
- type UpdateDataSourceRequest
- func (*UpdateDataSourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDataSourceRequest) GetDataSources() []*model.DataSource
- func (x *UpdateDataSourceRequest) GetToken() string
- func (*UpdateDataSourceRequest) ProtoMessage()
- func (x *UpdateDataSourceRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateDataSourceRequest) Reset()
- func (x *UpdateDataSourceRequest) String() string
- type UpdateDataSourceResponse
- func (*UpdateDataSourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDataSourceResponse) GetDataSources() []*model.DataSource
- func (*UpdateDataSourceResponse) ProtoMessage()
- func (x *UpdateDataSourceResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateDataSourceResponse) Reset()
- func (x *UpdateDataSourceResponse) String() string
- type UpdateExtensionRequest
- func (*UpdateExtensionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateExtensionRequest) GetExtensions() []*model.Extension
- func (x *UpdateExtensionRequest) GetToken() string
- func (*UpdateExtensionRequest) ProtoMessage()
- func (x *UpdateExtensionRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateExtensionRequest) Reset()
- func (x *UpdateExtensionRequest) String() string
- type UpdateExtensionResponse
- func (*UpdateExtensionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateExtensionResponse) GetExtensions() []*model.Extension
- func (*UpdateExtensionResponse) ProtoMessage()
- func (x *UpdateExtensionResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateExtensionResponse) Reset()
- func (x *UpdateExtensionResponse) String() string
- type UpdateMultiRecordRequest
- func (*UpdateMultiRecordRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateMultiRecordRequest) GetAnnotations() map[string]string
- func (x *UpdateMultiRecordRequest) GetNamespace() string
- func (x *UpdateMultiRecordRequest) GetProperties() map[string]*structpb.Value
- func (x *UpdateMultiRecordRequest) GetQuery() *model.BooleanExpression
- func (x *UpdateMultiRecordRequest) GetResource() string
- func (x *UpdateMultiRecordRequest) GetToken() string
- func (*UpdateMultiRecordRequest) ProtoMessage()
- func (x *UpdateMultiRecordRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateMultiRecordRequest) Reset()
- func (x *UpdateMultiRecordRequest) String() string
- type UpdateMultiRecordResponse
- func (*UpdateMultiRecordResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateMultiRecordResponse) GetRecord() *model.Record
- func (x *UpdateMultiRecordResponse) GetRecords() []*model.Record
- func (*UpdateMultiRecordResponse) ProtoMessage()
- func (x *UpdateMultiRecordResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateMultiRecordResponse) Reset()
- func (x *UpdateMultiRecordResponse) String() string
- type UpdateMultiRequest
- func (*UpdateMultiRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateMultiRequest) GetAnnotations() map[string]string
- func (x *UpdateMultiRequest) GetNamespace() string
- func (x *UpdateMultiRequest) GetProperties() map[string]*structpb.Value
- func (x *UpdateMultiRequest) GetQuery() *model.BooleanExpression
- func (x *UpdateMultiRequest) GetResource() string
- func (x *UpdateMultiRequest) GetToken() string
- func (*UpdateMultiRequest) ProtoMessage()
- func (x *UpdateMultiRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateMultiRequest) Reset()
- func (x *UpdateMultiRequest) String() string
- type UpdateMultiResponse
- func (*UpdateMultiResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateMultiResponse) GetItems() []*anypb.Any
- func (*UpdateMultiResponse) ProtoMessage()
- func (x *UpdateMultiResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateMultiResponse) Reset()
- func (x *UpdateMultiResponse) String() string
- type UpdateNamespaceRequest
- func (*UpdateNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateNamespaceRequest) GetNamespaces() []*model.Namespace
- func (x *UpdateNamespaceRequest) GetToken() string
- func (*UpdateNamespaceRequest) ProtoMessage()
- func (x *UpdateNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateNamespaceRequest) Reset()
- func (x *UpdateNamespaceRequest) String() string
- type UpdateNamespaceResponse
- func (*UpdateNamespaceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateNamespaceResponse) GetNamespaces() []*model.Namespace
- func (*UpdateNamespaceResponse) ProtoMessage()
- func (x *UpdateNamespaceResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateNamespaceResponse) Reset()
- func (x *UpdateNamespaceResponse) String() string
- type UpdateRecordRequest
- func (*UpdateRecordRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateRecordRequest) GetAnnotations() map[string]string
- func (x *UpdateRecordRequest) GetNamespace() string
- func (x *UpdateRecordRequest) GetRecord() *model.Record
- func (x *UpdateRecordRequest) GetRecords() []*model.Record
- func (x *UpdateRecordRequest) GetResource() string
- func (x *UpdateRecordRequest) GetToken() string
- func (*UpdateRecordRequest) ProtoMessage()
- func (x *UpdateRecordRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateRecordRequest) Reset()
- func (x *UpdateRecordRequest) String() string
- type UpdateRecordResponse
- func (*UpdateRecordResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateRecordResponse) GetRecord() *model.Record
- func (x *UpdateRecordResponse) GetRecords() []*model.Record
- func (*UpdateRecordResponse) ProtoMessage()
- func (x *UpdateRecordResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateRecordResponse) Reset()
- func (x *UpdateRecordResponse) String() string
- type UpdateRequest
- func (*UpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateRequest) GetAnnotations() map[string]string
- func (x *UpdateRequest) GetCheckVersion() bool
- func (x *UpdateRequest) GetItems() []*anypb.Any
- func (x *UpdateRequest) GetNamespace() string
- func (x *UpdateRequest) GetResource() string
- func (x *UpdateRequest) GetToken() string
- func (*UpdateRequest) ProtoMessage()
- func (x *UpdateRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateRequest) Reset()
- func (x *UpdateRequest) String() string
- type UpdateResourceRequest
- func (*UpdateResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateResourceRequest) GetAnnotations() map[string]string
- func (x *UpdateResourceRequest) GetDoMigration() bool
- func (x *UpdateResourceRequest) GetForceMigration() bool
- func (x *UpdateResourceRequest) GetResources() []*model.Resource
- func (x *UpdateResourceRequest) GetToken() string
- func (*UpdateResourceRequest) ProtoMessage()
- func (x *UpdateResourceRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateResourceRequest) Reset()
- func (x *UpdateResourceRequest) String() string
- type UpdateResourceResponse
- func (*UpdateResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateResourceResponse) GetResources() []*model.Resource
- func (*UpdateResourceResponse) ProtoMessage()
- func (x *UpdateResourceResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateResourceResponse) Reset()
- func (x *UpdateResourceResponse) String() string
- type UpdateResponse
- type UpdateUserRequest
- func (*UpdateUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateUserRequest) GetToken() string
- func (x *UpdateUserRequest) GetUser() *model.User
- func (x *UpdateUserRequest) GetUsers() []*model.User
- func (*UpdateUserRequest) ProtoMessage()
- func (x *UpdateUserRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateUserRequest) Reset()
- func (x *UpdateUserRequest) String() string
- type UpdateUserResponse
- func (*UpdateUserResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateUserResponse) GetUser() *model.User
- func (x *UpdateUserResponse) GetUsers() []*model.User
- func (*UpdateUserResponse) ProtoMessage()
- func (x *UpdateUserResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateUserResponse) Reset()
- func (x *UpdateUserResponse) String() string
- type UserClient
- type UserServer
- type WatchClient
- type WatchRequest
- func (*WatchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchRequest) GetSelector() *model.EventSelector
- func (x *WatchRequest) GetToken() string
- func (*WatchRequest) ProtoMessage()
- func (x *WatchRequest) ProtoReflect() protoreflect.Message
- func (x *WatchRequest) Reset()
- func (x *WatchRequest) String() string
- type WatchServer
- type Watch_WatchClient
- type Watch_WatchServer
- type WriteStreamResponse
- func (*WriteStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WriteStreamResponse) GetCreated() []bool
- func (x *WriteStreamResponse) GetSuccess() []bool
- func (x *WriteStreamResponse) GetUpdated() []bool
- func (*WriteStreamResponse) ProtoMessage()
- func (x *WriteStreamResponse) ProtoReflect() protoreflect.Message
- func (x *WriteStreamResponse) Reset()
- func (x *WriteStreamResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var Authentication_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stub.Authentication", HandlerType: (*AuthenticationServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Authenticate", Handler: _Authentication_Authenticate_Handler, }, { MethodName: "RenewToken", Handler: _Authentication_RenewToken_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "stub/authentication.proto", }
Authentication_ServiceDesc is the grpc.ServiceDesc for Authentication service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var DataSource_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stub.DataSource", HandlerType: (*DataSourceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _DataSource_Create_Handler, }, { MethodName: "List", Handler: _DataSource_List_Handler, }, { MethodName: "Update", Handler: _DataSource_Update_Handler, }, { MethodName: "Delete", Handler: _DataSource_Delete_Handler, }, { MethodName: "Get", Handler: _DataSource_Get_Handler, }, { MethodName: "Status", Handler: _DataSource_Status_Handler, }, { MethodName: "ListEntities", Handler: _DataSource_ListEntities_Handler, }, { MethodName: "PrepareResourceFromEntity", Handler: _DataSource_PrepareResourceFromEntity_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "stub/data-source.proto", }
DataSource_ServiceDesc is the grpc.ServiceDesc for DataSource service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Extension_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stub.Extension", HandlerType: (*ExtensionServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "List", Handler: _Extension_List_Handler, }, { MethodName: "Get", Handler: _Extension_Get_Handler, }, { MethodName: "Create", Handler: _Extension_Create_Handler, }, { MethodName: "Update", Handler: _Extension_Update_Handler, }, { MethodName: "Delete", Handler: _Extension_Delete_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "stub/extension.proto", }
Extension_ServiceDesc is the grpc.ServiceDesc for Extension service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_stub_authentication_proto protoreflect.FileDescriptor
var File_stub_data_source_proto protoreflect.FileDescriptor
var File_stub_extension_proto protoreflect.FileDescriptor
var File_stub_generic_proto protoreflect.FileDescriptor
var File_stub_namespace_proto protoreflect.FileDescriptor
var File_stub_openapi_proto protoreflect.FileDescriptor
var File_stub_record_proto protoreflect.FileDescriptor
var File_stub_resource_proto protoreflect.FileDescriptor
var File_stub_user_proto protoreflect.FileDescriptor
var File_stub_watch_proto protoreflect.FileDescriptor
var Generic_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stub.Generic", HandlerType: (*GenericServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _Generic_Create_Handler, }, { MethodName: "Update", Handler: _Generic_Update_Handler, }, { MethodName: "UpdateMulti", Handler: _Generic_UpdateMulti_Handler, }, { MethodName: "Delete", Handler: _Generic_Delete_Handler, }, { MethodName: "List", Handler: _Generic_List_Handler, }, { MethodName: "Search", Handler: _Generic_Search_Handler, }, { MethodName: "Get", Handler: _Generic_Get_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "stub/generic.proto", }
Generic_ServiceDesc is the grpc.ServiceDesc for Generic service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Namespace_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stub.Namespace", HandlerType: (*NamespaceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _Namespace_Create_Handler, }, { MethodName: "List", Handler: _Namespace_List_Handler, }, { MethodName: "Update", Handler: _Namespace_Update_Handler, }, { MethodName: "Delete", Handler: _Namespace_Delete_Handler, }, { MethodName: "Get", Handler: _Namespace_Get_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "stub/namespace.proto", }
Namespace_ServiceDesc is the grpc.ServiceDesc for Namespace service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Record_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stub.Record", HandlerType: (*RecordServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _Record_Create_Handler, }, { MethodName: "Update", Handler: _Record_Update_Handler, }, { MethodName: "Apply", Handler: _Record_Apply_Handler, }, { MethodName: "UpdateMulti", Handler: _Record_UpdateMulti_Handler, }, { MethodName: "Delete", Handler: _Record_Delete_Handler, }, { MethodName: "List", Handler: _Record_List_Handler, }, { MethodName: "Search", Handler: _Record_Search_Handler, }, { MethodName: "Get", Handler: _Record_Get_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ReadStream", Handler: _Record_ReadStream_Handler, ServerStreams: true, }, { StreamName: "WriteStream", Handler: _Record_WriteStream_Handler, ClientStreams: true, }, }, Metadata: "stub/record.proto", }
Record_ServiceDesc is the grpc.ServiceDesc for Record service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Resource_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stub.Resource", HandlerType: (*ResourceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _Resource_Create_Handler, }, { MethodName: "Update", Handler: _Resource_Update_Handler, }, { MethodName: "Delete", Handler: _Resource_Delete_Handler, }, { MethodName: "List", Handler: _Resource_List_Handler, }, { MethodName: "PrepareResourceMigrationPlan", Handler: _Resource_PrepareResourceMigrationPlan_Handler, }, { MethodName: "Get", Handler: _Resource_Get_Handler, }, { MethodName: "GetByName", Handler: _Resource_GetByName_Handler, }, { MethodName: "GetSystemResource", Handler: _Resource_GetSystemResource_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "stub/resource.proto", }
Resource_ServiceDesc is the grpc.ServiceDesc for Resource service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var User_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stub.User", HandlerType: (*UserServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _User_Create_Handler, }, { MethodName: "Update", Handler: _User_Update_Handler, }, { MethodName: "Delete", Handler: _User_Delete_Handler, }, { MethodName: "List", Handler: _User_List_Handler, }, { MethodName: "Get", Handler: _User_Get_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "stub/user.proto", }
User_ServiceDesc is the grpc.ServiceDesc for User service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Watch_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stub.Watch", HandlerType: (*WatchServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Watch", Handler: _Watch_Watch_Handler, ServerStreams: true, }, }, Metadata: "stub/watch.proto", }
Watch_ServiceDesc is the grpc.ServiceDesc for Watch service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAuthenticationHandler ¶
func RegisterAuthenticationHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterAuthenticationHandler registers the http handlers for service Authentication to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterAuthenticationHandlerClient ¶
func RegisterAuthenticationHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AuthenticationClient) error
RegisterAuthenticationHandlerClient registers the http handlers for service Authentication to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AuthenticationClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AuthenticationClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AuthenticationClient" to call the correct interceptors.
func RegisterAuthenticationHandlerFromEndpoint ¶
func RegisterAuthenticationHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterAuthenticationHandlerFromEndpoint is same as RegisterAuthenticationHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterAuthenticationHandlerServer ¶
func RegisterAuthenticationHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AuthenticationServer) error
RegisterAuthenticationHandlerServer registers the http handlers for service Authentication to "mux". UnaryRPC :call AuthenticationServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAuthenticationHandlerFromEndpoint instead.
func RegisterAuthenticationServer ¶
func RegisterAuthenticationServer(s grpc.ServiceRegistrar, srv AuthenticationServer)
func RegisterDataSourceHandler ¶
func RegisterDataSourceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterDataSourceHandler registers the http handlers for service DataSource to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterDataSourceHandlerClient ¶
func RegisterDataSourceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DataSourceClient) error
RegisterDataSourceHandlerClient registers the http handlers for service DataSource to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DataSourceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DataSourceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DataSourceClient" to call the correct interceptors.
func RegisterDataSourceHandlerFromEndpoint ¶
func RegisterDataSourceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterDataSourceHandlerFromEndpoint is same as RegisterDataSourceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterDataSourceHandlerServer ¶
func RegisterDataSourceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DataSourceServer) error
RegisterDataSourceHandlerServer registers the http handlers for service DataSource to "mux". UnaryRPC :call DataSourceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDataSourceHandlerFromEndpoint instead.
func RegisterDataSourceServer ¶
func RegisterDataSourceServer(s grpc.ServiceRegistrar, srv DataSourceServer)
func RegisterExtensionHandler ¶
func RegisterExtensionHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterExtensionHandler registers the http handlers for service Extension to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterExtensionHandlerClient ¶
func RegisterExtensionHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ExtensionClient) error
RegisterExtensionHandlerClient registers the http handlers for service Extension to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ExtensionClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ExtensionClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ExtensionClient" to call the correct interceptors.
func RegisterExtensionHandlerFromEndpoint ¶
func RegisterExtensionHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterExtensionHandlerFromEndpoint is same as RegisterExtensionHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterExtensionHandlerServer ¶
func RegisterExtensionHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ExtensionServer) error
RegisterExtensionHandlerServer registers the http handlers for service Extension to "mux". UnaryRPC :call ExtensionServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterExtensionHandlerFromEndpoint instead.
func RegisterExtensionServer ¶
func RegisterExtensionServer(s grpc.ServiceRegistrar, srv ExtensionServer)
func RegisterGenericServer ¶
func RegisterGenericServer(s grpc.ServiceRegistrar, srv GenericServer)
func RegisterNamespaceHandler ¶
func RegisterNamespaceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterNamespaceHandler registers the http handlers for service Namespace to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterNamespaceHandlerClient ¶
func RegisterNamespaceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client NamespaceClient) error
RegisterNamespaceHandlerClient registers the http handlers for service Namespace to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "NamespaceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "NamespaceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "NamespaceClient" to call the correct interceptors.
func RegisterNamespaceHandlerFromEndpoint ¶
func RegisterNamespaceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterNamespaceHandlerFromEndpoint is same as RegisterNamespaceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterNamespaceHandlerServer ¶
func RegisterNamespaceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server NamespaceServer) error
RegisterNamespaceHandlerServer registers the http handlers for service Namespace to "mux". UnaryRPC :call NamespaceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterNamespaceHandlerFromEndpoint instead.
func RegisterNamespaceServer ¶
func RegisterNamespaceServer(s grpc.ServiceRegistrar, srv NamespaceServer)
func RegisterRecordHandler ¶
RegisterRecordHandler registers the http handlers for service Record to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterRecordHandlerClient ¶
func RegisterRecordHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RecordClient) error
RegisterRecordHandlerClient registers the http handlers for service Record to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RecordClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RecordClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RecordClient" to call the correct interceptors.
func RegisterRecordHandlerFromEndpoint ¶
func RegisterRecordHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterRecordHandlerFromEndpoint is same as RegisterRecordHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterRecordHandlerServer ¶
func RegisterRecordHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RecordServer) error
RegisterRecordHandlerServer registers the http handlers for service Record to "mux". UnaryRPC :call RecordServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRecordHandlerFromEndpoint instead.
func RegisterRecordServer ¶
func RegisterRecordServer(s grpc.ServiceRegistrar, srv RecordServer)
func RegisterResourceHandler ¶
func RegisterResourceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterResourceHandler registers the http handlers for service Resource to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterResourceHandlerClient ¶
func RegisterResourceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ResourceClient) error
RegisterResourceHandlerClient registers the http handlers for service Resource to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ResourceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ResourceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ResourceClient" to call the correct interceptors.
func RegisterResourceHandlerFromEndpoint ¶
func RegisterResourceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterResourceHandlerFromEndpoint is same as RegisterResourceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterResourceHandlerServer ¶
func RegisterResourceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ResourceServer) error
RegisterResourceHandlerServer registers the http handlers for service Resource to "mux". UnaryRPC :call ResourceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterResourceHandlerFromEndpoint instead.
func RegisterResourceServer ¶
func RegisterResourceServer(s grpc.ServiceRegistrar, srv ResourceServer)
func RegisterUserHandler ¶
RegisterUserHandler registers the http handlers for service User to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterUserHandlerClient ¶
RegisterUserHandlerClient registers the http handlers for service User to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "UserClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "UserClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "UserClient" to call the correct interceptors.
func RegisterUserHandlerFromEndpoint ¶
func RegisterUserHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterUserHandlerFromEndpoint is same as RegisterUserHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterUserHandlerServer ¶
RegisterUserHandlerServer registers the http handlers for service User to "mux". UnaryRPC :call UserServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterUserHandlerFromEndpoint instead.
func RegisterUserServer ¶
func RegisterUserServer(s grpc.ServiceRegistrar, srv UserServer)
func RegisterWatchHandler ¶
RegisterWatchHandler registers the http handlers for service Watch to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterWatchHandlerClient ¶
func RegisterWatchHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WatchClient) error
RegisterWatchHandlerClient registers the http handlers for service Watch to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "WatchClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "WatchClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "WatchClient" to call the correct interceptors.
func RegisterWatchHandlerFromEndpoint ¶
func RegisterWatchHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterWatchHandlerFromEndpoint is same as RegisterWatchHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterWatchHandlerServer ¶
func RegisterWatchHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WatchServer) error
RegisterWatchHandlerServer registers the http handlers for service Watch to "mux". UnaryRPC :call WatchServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterWatchHandlerFromEndpoint instead.
func RegisterWatchServer ¶
func RegisterWatchServer(s grpc.ServiceRegistrar, srv WatchServer)
Types ¶
type ApplyRecordRequest ¶
type ApplyRecordRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Record *model.Record `protobuf:"bytes,4,opt,name=record,proto3" json:"record,omitempty"` // Rest Only Records []*model.Record `protobuf:"bytes,5,rep,name=records,proto3" json:"records,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ApplyRecordRequest) Descriptor
deprecated
func (*ApplyRecordRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApplyRecordRequest.ProtoReflect.Descriptor instead.
func (*ApplyRecordRequest) GetAnnotations ¶
func (x *ApplyRecordRequest) GetAnnotations() map[string]string
func (*ApplyRecordRequest) GetNamespace ¶
func (x *ApplyRecordRequest) GetNamespace() string
func (*ApplyRecordRequest) GetRecord ¶
func (x *ApplyRecordRequest) GetRecord() *model.Record
func (*ApplyRecordRequest) GetRecords ¶
func (x *ApplyRecordRequest) GetRecords() []*model.Record
func (*ApplyRecordRequest) GetResource ¶
func (x *ApplyRecordRequest) GetResource() string
func (*ApplyRecordRequest) GetToken ¶
func (x *ApplyRecordRequest) GetToken() string
func (*ApplyRecordRequest) ProtoMessage ¶
func (*ApplyRecordRequest) ProtoMessage()
func (*ApplyRecordRequest) ProtoReflect ¶
func (x *ApplyRecordRequest) ProtoReflect() protoreflect.Message
func (*ApplyRecordRequest) Reset ¶
func (x *ApplyRecordRequest) Reset()
func (*ApplyRecordRequest) String ¶
func (x *ApplyRecordRequest) String() string
type ApplyRecordResponse ¶
type ApplyRecordResponse struct { Record *model.Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` // Rest Only Records []*model.Record `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"` // contains filtered or unexported fields }
func (*ApplyRecordResponse) Descriptor
deprecated
func (*ApplyRecordResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApplyRecordResponse.ProtoReflect.Descriptor instead.
func (*ApplyRecordResponse) GetRecord ¶
func (x *ApplyRecordResponse) GetRecord() *model.Record
func (*ApplyRecordResponse) GetRecords ¶
func (x *ApplyRecordResponse) GetRecords() []*model.Record
func (*ApplyRecordResponse) ProtoMessage ¶
func (*ApplyRecordResponse) ProtoMessage()
func (*ApplyRecordResponse) ProtoReflect ¶
func (x *ApplyRecordResponse) ProtoReflect() protoreflect.Message
func (*ApplyRecordResponse) Reset ¶
func (x *ApplyRecordResponse) Reset()
func (*ApplyRecordResponse) String ¶
func (x *ApplyRecordResponse) String() string
type AuthenticationClient ¶
type AuthenticationClient interface { // Authentication with username/password and create new token // Later on, you need to use this token to access other services, for grpc, you need to set the token on request. For Rest, you need to set the token on Authorization header with Bearer prefix Authenticate(ctx context.Context, in *AuthenticationRequest, opts ...grpc.CallOption) (*AuthenticationResponse, error) // Renew token with existing token RenewToken(ctx context.Context, in *RenewTokenRequest, opts ...grpc.CallOption) (*RenewTokenResponse, error) }
AuthenticationClient is the client API for Authentication service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAuthenticationClient ¶
func NewAuthenticationClient(cc grpc.ClientConnInterface) AuthenticationClient
type AuthenticationRequest ¶
type AuthenticationRequest struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` // Token Lifespan Term model.TokenTerm `protobuf:"varint,3,opt,name=term,proto3,enum=model.TokenTerm" json:"term,omitempty"` // contains filtered or unexported fields }
AuthenticationRequest is the request for authentication
func (*AuthenticationRequest) Descriptor
deprecated
func (*AuthenticationRequest) Descriptor() ([]byte, []int)
Deprecated: Use AuthenticationRequest.ProtoReflect.Descriptor instead.
func (*AuthenticationRequest) GetPassword ¶
func (x *AuthenticationRequest) GetPassword() string
func (*AuthenticationRequest) GetTerm ¶
func (x *AuthenticationRequest) GetTerm() model.TokenTerm
func (*AuthenticationRequest) GetUsername ¶
func (x *AuthenticationRequest) GetUsername() string
func (*AuthenticationRequest) ProtoMessage ¶
func (*AuthenticationRequest) ProtoMessage()
func (*AuthenticationRequest) ProtoReflect ¶
func (x *AuthenticationRequest) ProtoReflect() protoreflect.Message
func (*AuthenticationRequest) Reset ¶
func (x *AuthenticationRequest) Reset()
func (*AuthenticationRequest) String ¶
func (x *AuthenticationRequest) String() string
type AuthenticationResponse ¶
type AuthenticationResponse struct { Token *model.Token `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
func (*AuthenticationResponse) Descriptor
deprecated
func (*AuthenticationResponse) Descriptor() ([]byte, []int)
Deprecated: Use AuthenticationResponse.ProtoReflect.Descriptor instead.
func (*AuthenticationResponse) GetToken ¶
func (x *AuthenticationResponse) GetToken() *model.Token
func (*AuthenticationResponse) ProtoMessage ¶
func (*AuthenticationResponse) ProtoMessage()
func (*AuthenticationResponse) ProtoReflect ¶
func (x *AuthenticationResponse) ProtoReflect() protoreflect.Message
func (*AuthenticationResponse) Reset ¶
func (x *AuthenticationResponse) Reset()
func (*AuthenticationResponse) String ¶
func (x *AuthenticationResponse) String() string
type AuthenticationServer ¶
type AuthenticationServer interface { // Authentication with username/password and create new token // Later on, you need to use this token to access other services, for grpc, you need to set the token on request. For Rest, you need to set the token on Authorization header with Bearer prefix Authenticate(context.Context, *AuthenticationRequest) (*AuthenticationResponse, error) // Renew token with existing token RenewToken(context.Context, *RenewTokenRequest) (*RenewTokenResponse, error) // contains filtered or unexported methods }
AuthenticationServer is the server API for Authentication service. All implementations must embed UnimplementedAuthenticationServer for forward compatibility
type CreateDataSourceRequest ¶
type CreateDataSourceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` DataSources []*model.DataSource `protobuf:"bytes,2,rep,name=dataSources,proto3" json:"dataSources,omitempty"` // contains filtered or unexported fields }
func (*CreateDataSourceRequest) Descriptor
deprecated
func (*CreateDataSourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateDataSourceRequest.ProtoReflect.Descriptor instead.
func (*CreateDataSourceRequest) GetDataSources ¶
func (x *CreateDataSourceRequest) GetDataSources() []*model.DataSource
func (*CreateDataSourceRequest) GetToken ¶
func (x *CreateDataSourceRequest) GetToken() string
func (*CreateDataSourceRequest) ProtoMessage ¶
func (*CreateDataSourceRequest) ProtoMessage()
func (*CreateDataSourceRequest) ProtoReflect ¶
func (x *CreateDataSourceRequest) ProtoReflect() protoreflect.Message
func (*CreateDataSourceRequest) Reset ¶
func (x *CreateDataSourceRequest) Reset()
func (*CreateDataSourceRequest) String ¶
func (x *CreateDataSourceRequest) String() string
type CreateDataSourceResponse ¶
type CreateDataSourceResponse struct { DataSources []*model.DataSource `protobuf:"bytes,1,rep,name=dataSources,proto3" json:"dataSources,omitempty"` // contains filtered or unexported fields }
func (*CreateDataSourceResponse) Descriptor
deprecated
func (*CreateDataSourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateDataSourceResponse.ProtoReflect.Descriptor instead.
func (*CreateDataSourceResponse) GetDataSources ¶
func (x *CreateDataSourceResponse) GetDataSources() []*model.DataSource
func (*CreateDataSourceResponse) ProtoMessage ¶
func (*CreateDataSourceResponse) ProtoMessage()
func (*CreateDataSourceResponse) ProtoReflect ¶
func (x *CreateDataSourceResponse) ProtoReflect() protoreflect.Message
func (*CreateDataSourceResponse) Reset ¶
func (x *CreateDataSourceResponse) Reset()
func (*CreateDataSourceResponse) String ¶
func (x *CreateDataSourceResponse) String() string
type CreateExtensionRequest ¶
type CreateExtensionRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Extensions []*model.Extension `protobuf:"bytes,2,rep,name=extensions,proto3" json:"extensions,omitempty"` // contains filtered or unexported fields }
func (*CreateExtensionRequest) Descriptor
deprecated
func (*CreateExtensionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateExtensionRequest.ProtoReflect.Descriptor instead.
func (*CreateExtensionRequest) GetExtensions ¶
func (x *CreateExtensionRequest) GetExtensions() []*model.Extension
func (*CreateExtensionRequest) GetToken ¶
func (x *CreateExtensionRequest) GetToken() string
func (*CreateExtensionRequest) ProtoMessage ¶
func (*CreateExtensionRequest) ProtoMessage()
func (*CreateExtensionRequest) ProtoReflect ¶
func (x *CreateExtensionRequest) ProtoReflect() protoreflect.Message
func (*CreateExtensionRequest) Reset ¶
func (x *CreateExtensionRequest) Reset()
func (*CreateExtensionRequest) String ¶
func (x *CreateExtensionRequest) String() string
type CreateExtensionResponse ¶
type CreateExtensionResponse struct { Extensions []*model.Extension `protobuf:"bytes,1,rep,name=extensions,proto3" json:"extensions,omitempty"` // contains filtered or unexported fields }
func (*CreateExtensionResponse) Descriptor
deprecated
func (*CreateExtensionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateExtensionResponse.ProtoReflect.Descriptor instead.
func (*CreateExtensionResponse) GetExtensions ¶
func (x *CreateExtensionResponse) GetExtensions() []*model.Extension
func (*CreateExtensionResponse) ProtoMessage ¶
func (*CreateExtensionResponse) ProtoMessage()
func (*CreateExtensionResponse) ProtoReflect ¶
func (x *CreateExtensionResponse) ProtoReflect() protoreflect.Message
func (*CreateExtensionResponse) Reset ¶
func (x *CreateExtensionResponse) Reset()
func (*CreateExtensionResponse) String ¶
func (x *CreateExtensionResponse) String() string
type CreateNamespaceRequest ¶
type CreateNamespaceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespaces []*model.Namespace `protobuf:"bytes,2,rep,name=Namespaces,proto3" json:"Namespaces,omitempty"` // contains filtered or unexported fields }
func (*CreateNamespaceRequest) Descriptor
deprecated
func (*CreateNamespaceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateNamespaceRequest.ProtoReflect.Descriptor instead.
func (*CreateNamespaceRequest) GetNamespaces ¶
func (x *CreateNamespaceRequest) GetNamespaces() []*model.Namespace
func (*CreateNamespaceRequest) GetToken ¶
func (x *CreateNamespaceRequest) GetToken() string
func (*CreateNamespaceRequest) ProtoMessage ¶
func (*CreateNamespaceRequest) ProtoMessage()
func (*CreateNamespaceRequest) ProtoReflect ¶
func (x *CreateNamespaceRequest) ProtoReflect() protoreflect.Message
func (*CreateNamespaceRequest) Reset ¶
func (x *CreateNamespaceRequest) Reset()
func (*CreateNamespaceRequest) String ¶
func (x *CreateNamespaceRequest) String() string
type CreateNamespaceResponse ¶
type CreateNamespaceResponse struct { Namespaces []*model.Namespace `protobuf:"bytes,1,rep,name=Namespaces,proto3" json:"Namespaces,omitempty"` // contains filtered or unexported fields }
func (*CreateNamespaceResponse) Descriptor
deprecated
func (*CreateNamespaceResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateNamespaceResponse.ProtoReflect.Descriptor instead.
func (*CreateNamespaceResponse) GetNamespaces ¶
func (x *CreateNamespaceResponse) GetNamespaces() []*model.Namespace
func (*CreateNamespaceResponse) ProtoMessage ¶
func (*CreateNamespaceResponse) ProtoMessage()
func (*CreateNamespaceResponse) ProtoReflect ¶
func (x *CreateNamespaceResponse) ProtoReflect() protoreflect.Message
func (*CreateNamespaceResponse) Reset ¶
func (x *CreateNamespaceResponse) Reset()
func (*CreateNamespaceResponse) String ¶
func (x *CreateNamespaceResponse) String() string
type CreateRecordRequest ¶
type CreateRecordRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Record *model.Record `protobuf:"bytes,4,opt,name=record,proto3" json:"record,omitempty"` Records []*model.Record `protobuf:"bytes,5,rep,name=records,proto3" json:"records,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CreateRecordRequest) Descriptor
deprecated
func (*CreateRecordRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateRecordRequest.ProtoReflect.Descriptor instead.
func (*CreateRecordRequest) GetAnnotations ¶
func (x *CreateRecordRequest) GetAnnotations() map[string]string
func (*CreateRecordRequest) GetNamespace ¶
func (x *CreateRecordRequest) GetNamespace() string
func (*CreateRecordRequest) GetRecord ¶
func (x *CreateRecordRequest) GetRecord() *model.Record
func (*CreateRecordRequest) GetRecords ¶
func (x *CreateRecordRequest) GetRecords() []*model.Record
func (*CreateRecordRequest) GetResource ¶
func (x *CreateRecordRequest) GetResource() string
func (*CreateRecordRequest) GetToken ¶
func (x *CreateRecordRequest) GetToken() string
func (*CreateRecordRequest) ProtoMessage ¶
func (*CreateRecordRequest) ProtoMessage()
func (*CreateRecordRequest) ProtoReflect ¶
func (x *CreateRecordRequest) ProtoReflect() protoreflect.Message
func (*CreateRecordRequest) Reset ¶
func (x *CreateRecordRequest) Reset()
func (*CreateRecordRequest) String ¶
func (x *CreateRecordRequest) String() string
type CreateRecordResponse ¶
type CreateRecordResponse struct { Record *model.Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` // Rest Only Records []*model.Record `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"` Inserted []bool `protobuf:"varint,4,rep,packed,name=inserted,proto3" json:"inserted,omitempty"` // contains filtered or unexported fields }
func (*CreateRecordResponse) Descriptor
deprecated
func (*CreateRecordResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateRecordResponse.ProtoReflect.Descriptor instead.
func (*CreateRecordResponse) GetInserted ¶
func (x *CreateRecordResponse) GetInserted() []bool
func (*CreateRecordResponse) GetRecord ¶
func (x *CreateRecordResponse) GetRecord() *model.Record
func (*CreateRecordResponse) GetRecords ¶
func (x *CreateRecordResponse) GetRecords() []*model.Record
func (*CreateRecordResponse) ProtoMessage ¶
func (*CreateRecordResponse) ProtoMessage()
func (*CreateRecordResponse) ProtoReflect ¶
func (x *CreateRecordResponse) ProtoReflect() protoreflect.Message
func (*CreateRecordResponse) Reset ¶
func (x *CreateRecordResponse) Reset()
func (*CreateRecordResponse) String ¶
func (x *CreateRecordResponse) String() string
type CreateRequest ¶
type CreateRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Items []*anypb.Any `protobuf:"bytes,4,rep,name=items,proto3" json:"items,omitempty"` IgnoreIfExists bool `protobuf:"varint,5,opt,name=ignoreIfExists,proto3" json:"ignoreIfExists,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CreateRequest) Descriptor
deprecated
func (*CreateRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.
func (*CreateRequest) GetAnnotations ¶
func (x *CreateRequest) GetAnnotations() map[string]string
func (*CreateRequest) GetIgnoreIfExists ¶
func (x *CreateRequest) GetIgnoreIfExists() bool
func (*CreateRequest) GetItems ¶
func (x *CreateRequest) GetItems() []*anypb.Any
func (*CreateRequest) GetNamespace ¶
func (x *CreateRequest) GetNamespace() string
func (*CreateRequest) GetResource ¶
func (x *CreateRequest) GetResource() string
func (*CreateRequest) GetToken ¶
func (x *CreateRequest) GetToken() string
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) ProtoReflect ¶
func (x *CreateRequest) ProtoReflect() protoreflect.Message
func (*CreateRequest) Reset ¶
func (x *CreateRequest) Reset()
func (*CreateRequest) String ¶
func (x *CreateRequest) String() string
type CreateResourceRequest ¶
type CreateResourceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Resources []*model.Resource `protobuf:"bytes,2,rep,name=resources,proto3" json:"resources,omitempty"` // if true, it will try to migrate the resource to the data source, if it is false, resource will be only created, backend will not be affected. DoMigration bool `protobuf:"varint,3,opt,name=doMigration,proto3" json:"doMigration,omitempty"` // if true, it will force the migration, if it is false, it will not migrate if there is a conflict. // Force migration will also do following things: // - if column/index is deleted from resource, it will delete it from backend ForceMigration bool `protobuf:"varint,4,opt,name=forceMigration,proto3" json:"forceMigration,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CreateResourceRequest) Descriptor
deprecated
func (*CreateResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateResourceRequest.ProtoReflect.Descriptor instead.
func (*CreateResourceRequest) GetAnnotations ¶
func (x *CreateResourceRequest) GetAnnotations() map[string]string
func (*CreateResourceRequest) GetDoMigration ¶
func (x *CreateResourceRequest) GetDoMigration() bool
func (*CreateResourceRequest) GetForceMigration ¶
func (x *CreateResourceRequest) GetForceMigration() bool
func (*CreateResourceRequest) GetResources ¶
func (x *CreateResourceRequest) GetResources() []*model.Resource
func (*CreateResourceRequest) GetToken ¶
func (x *CreateResourceRequest) GetToken() string
func (*CreateResourceRequest) ProtoMessage ¶
func (*CreateResourceRequest) ProtoMessage()
func (*CreateResourceRequest) ProtoReflect ¶
func (x *CreateResourceRequest) ProtoReflect() protoreflect.Message
func (*CreateResourceRequest) Reset ¶
func (x *CreateResourceRequest) Reset()
func (*CreateResourceRequest) String ¶
func (x *CreateResourceRequest) String() string
type CreateResourceResponse ¶
type CreateResourceResponse struct { Resources []*model.Resource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"` // contains filtered or unexported fields }
func (*CreateResourceResponse) Descriptor
deprecated
func (*CreateResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateResourceResponse.ProtoReflect.Descriptor instead.
func (*CreateResourceResponse) GetResources ¶
func (x *CreateResourceResponse) GetResources() []*model.Resource
func (*CreateResourceResponse) ProtoMessage ¶
func (*CreateResourceResponse) ProtoMessage()
func (*CreateResourceResponse) ProtoReflect ¶
func (x *CreateResourceResponse) ProtoReflect() protoreflect.Message
func (*CreateResourceResponse) Reset ¶
func (x *CreateResourceResponse) Reset()
func (*CreateResourceResponse) String ¶
func (x *CreateResourceResponse) String() string
type CreateResponse ¶
type CreateResponse struct { Items []*anypb.Any `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"` Inserted []bool `protobuf:"varint,4,rep,packed,name=inserted,proto3" json:"inserted,omitempty"` // contains filtered or unexported fields }
func (*CreateResponse) Descriptor
deprecated
func (*CreateResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.
func (*CreateResponse) GetInserted ¶
func (x *CreateResponse) GetInserted() []bool
func (*CreateResponse) GetItems ¶
func (x *CreateResponse) GetItems() []*anypb.Any
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) ProtoReflect ¶
func (x *CreateResponse) ProtoReflect() protoreflect.Message
func (*CreateResponse) Reset ¶
func (x *CreateResponse) Reset()
func (*CreateResponse) String ¶
func (x *CreateResponse) String() string
type CreateUserRequest ¶
type CreateUserRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` User *model.User `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` Users []*model.User `protobuf:"bytes,3,rep,name=users,proto3" json:"users,omitempty"` // contains filtered or unexported fields }
func (*CreateUserRequest) Descriptor
deprecated
func (*CreateUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateUserRequest.ProtoReflect.Descriptor instead.
func (*CreateUserRequest) GetToken ¶
func (x *CreateUserRequest) GetToken() string
func (*CreateUserRequest) GetUser ¶
func (x *CreateUserRequest) GetUser() *model.User
func (*CreateUserRequest) GetUsers ¶
func (x *CreateUserRequest) GetUsers() []*model.User
func (*CreateUserRequest) ProtoMessage ¶
func (*CreateUserRequest) ProtoMessage()
func (*CreateUserRequest) ProtoReflect ¶
func (x *CreateUserRequest) ProtoReflect() protoreflect.Message
func (*CreateUserRequest) Reset ¶
func (x *CreateUserRequest) Reset()
func (*CreateUserRequest) String ¶
func (x *CreateUserRequest) String() string
type CreateUserResponse ¶
type CreateUserResponse struct { User *model.User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Users []*model.User `protobuf:"bytes,2,rep,name=users,proto3" json:"users,omitempty"` // contains filtered or unexported fields }
func (*CreateUserResponse) Descriptor
deprecated
func (*CreateUserResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateUserResponse.ProtoReflect.Descriptor instead.
func (*CreateUserResponse) GetUser ¶
func (x *CreateUserResponse) GetUser() *model.User
func (*CreateUserResponse) GetUsers ¶
func (x *CreateUserResponse) GetUsers() []*model.User
func (*CreateUserResponse) ProtoMessage ¶
func (*CreateUserResponse) ProtoMessage()
func (*CreateUserResponse) ProtoReflect ¶
func (x *CreateUserResponse) ProtoReflect() protoreflect.Message
func (*CreateUserResponse) Reset ¶
func (x *CreateUserResponse) Reset()
func (*CreateUserResponse) String ¶
func (x *CreateUserResponse) String() string
type DataSourceClient ¶
type DataSourceClient interface { Create(ctx context.Context, in *CreateDataSourceRequest, opts ...grpc.CallOption) (*CreateDataSourceResponse, error) List(ctx context.Context, in *ListDataSourceRequest, opts ...grpc.CallOption) (*ListDataSourceResponse, error) Update(ctx context.Context, in *UpdateDataSourceRequest, opts ...grpc.CallOption) (*UpdateDataSourceResponse, error) Delete(ctx context.Context, in *DeleteDataSourceRequest, opts ...grpc.CallOption) (*DeleteDataSourceResponse, error) Get(ctx context.Context, in *GetDataSourceRequest, opts ...grpc.CallOption) (*GetDataSourceResponse, error) // Status will return connection status of data source Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error) // List entities will return all entities from data source ListEntities(ctx context.Context, in *ListEntitiesRequest, opts ...grpc.CallOption) (*ListEntitiesResponse, error) // PrepareResourceFromEntity will return resource from data source based on entity. // It is for database first approach. If you already have an entity/table on data source and your want to create resource based on it, you can call this endpoint to do it. PrepareResourceFromEntity(ctx context.Context, in *PrepareResourceFromEntityRequest, opts ...grpc.CallOption) (*PrepareResourceFromEntityResponse, error) }
DataSourceClient is the client API for DataSource service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewDataSourceClient ¶
func NewDataSourceClient(cc grpc.ClientConnInterface) DataSourceClient
type DataSourceServer ¶
type DataSourceServer interface { Create(context.Context, *CreateDataSourceRequest) (*CreateDataSourceResponse, error) List(context.Context, *ListDataSourceRequest) (*ListDataSourceResponse, error) Update(context.Context, *UpdateDataSourceRequest) (*UpdateDataSourceResponse, error) Delete(context.Context, *DeleteDataSourceRequest) (*DeleteDataSourceResponse, error) Get(context.Context, *GetDataSourceRequest) (*GetDataSourceResponse, error) // Status will return connection status of data source Status(context.Context, *StatusRequest) (*StatusResponse, error) // List entities will return all entities from data source ListEntities(context.Context, *ListEntitiesRequest) (*ListEntitiesResponse, error) // PrepareResourceFromEntity will return resource from data source based on entity. // It is for database first approach. If you already have an entity/table on data source and your want to create resource based on it, you can call this endpoint to do it. PrepareResourceFromEntity(context.Context, *PrepareResourceFromEntityRequest) (*PrepareResourceFromEntityResponse, error) // contains filtered or unexported methods }
DataSourceServer is the server API for DataSource service. All implementations must embed UnimplementedDataSourceServer for forward compatibility
type DeleteDataSourceRequest ¶
type DeleteDataSourceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Ids []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"` // contains filtered or unexported fields }
func (*DeleteDataSourceRequest) Descriptor
deprecated
func (*DeleteDataSourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDataSourceRequest.ProtoReflect.Descriptor instead.
func (*DeleteDataSourceRequest) GetIds ¶
func (x *DeleteDataSourceRequest) GetIds() []string
func (*DeleteDataSourceRequest) GetToken ¶
func (x *DeleteDataSourceRequest) GetToken() string
func (*DeleteDataSourceRequest) ProtoMessage ¶
func (*DeleteDataSourceRequest) ProtoMessage()
func (*DeleteDataSourceRequest) ProtoReflect ¶
func (x *DeleteDataSourceRequest) ProtoReflect() protoreflect.Message
func (*DeleteDataSourceRequest) Reset ¶
func (x *DeleteDataSourceRequest) Reset()
func (*DeleteDataSourceRequest) String ¶
func (x *DeleteDataSourceRequest) String() string
type DeleteDataSourceResponse ¶
type DeleteDataSourceResponse struct {
// contains filtered or unexported fields
}
func (*DeleteDataSourceResponse) Descriptor
deprecated
func (*DeleteDataSourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDataSourceResponse.ProtoReflect.Descriptor instead.
func (*DeleteDataSourceResponse) ProtoMessage ¶
func (*DeleteDataSourceResponse) ProtoMessage()
func (*DeleteDataSourceResponse) ProtoReflect ¶
func (x *DeleteDataSourceResponse) ProtoReflect() protoreflect.Message
func (*DeleteDataSourceResponse) Reset ¶
func (x *DeleteDataSourceResponse) Reset()
func (*DeleteDataSourceResponse) String ¶
func (x *DeleteDataSourceResponse) String() string
type DeleteExtensionRequest ¶
type DeleteExtensionRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Ids []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"` // contains filtered or unexported fields }
func (*DeleteExtensionRequest) Descriptor
deprecated
func (*DeleteExtensionRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteExtensionRequest.ProtoReflect.Descriptor instead.
func (*DeleteExtensionRequest) GetIds ¶
func (x *DeleteExtensionRequest) GetIds() []string
func (*DeleteExtensionRequest) GetToken ¶
func (x *DeleteExtensionRequest) GetToken() string
func (*DeleteExtensionRequest) ProtoMessage ¶
func (*DeleteExtensionRequest) ProtoMessage()
func (*DeleteExtensionRequest) ProtoReflect ¶
func (x *DeleteExtensionRequest) ProtoReflect() protoreflect.Message
func (*DeleteExtensionRequest) Reset ¶
func (x *DeleteExtensionRequest) Reset()
func (*DeleteExtensionRequest) String ¶
func (x *DeleteExtensionRequest) String() string
type DeleteExtensionResponse ¶
type DeleteExtensionResponse struct {
// contains filtered or unexported fields
}
func (*DeleteExtensionResponse) Descriptor
deprecated
func (*DeleteExtensionResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteExtensionResponse.ProtoReflect.Descriptor instead.
func (*DeleteExtensionResponse) ProtoMessage ¶
func (*DeleteExtensionResponse) ProtoMessage()
func (*DeleteExtensionResponse) ProtoReflect ¶
func (x *DeleteExtensionResponse) ProtoReflect() protoreflect.Message
func (*DeleteExtensionResponse) Reset ¶
func (x *DeleteExtensionResponse) Reset()
func (*DeleteExtensionResponse) String ¶
func (x *DeleteExtensionResponse) String() string
type DeleteNamespaceRequest ¶
type DeleteNamespaceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Ids []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"` // contains filtered or unexported fields }
func (*DeleteNamespaceRequest) Descriptor
deprecated
func (*DeleteNamespaceRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteNamespaceRequest.ProtoReflect.Descriptor instead.
func (*DeleteNamespaceRequest) GetIds ¶
func (x *DeleteNamespaceRequest) GetIds() []string
func (*DeleteNamespaceRequest) GetToken ¶
func (x *DeleteNamespaceRequest) GetToken() string
func (*DeleteNamespaceRequest) ProtoMessage ¶
func (*DeleteNamespaceRequest) ProtoMessage()
func (*DeleteNamespaceRequest) ProtoReflect ¶
func (x *DeleteNamespaceRequest) ProtoReflect() protoreflect.Message
func (*DeleteNamespaceRequest) Reset ¶
func (x *DeleteNamespaceRequest) Reset()
func (*DeleteNamespaceRequest) String ¶
func (x *DeleteNamespaceRequest) String() string
type DeleteNamespaceResponse ¶
type DeleteNamespaceResponse struct { Namespaces []*model.Namespace `protobuf:"bytes,1,rep,name=Namespaces,proto3" json:"Namespaces,omitempty"` // contains filtered or unexported fields }
func (*DeleteNamespaceResponse) Descriptor
deprecated
func (*DeleteNamespaceResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteNamespaceResponse.ProtoReflect.Descriptor instead.
func (*DeleteNamespaceResponse) GetNamespaces ¶
func (x *DeleteNamespaceResponse) GetNamespaces() []*model.Namespace
func (*DeleteNamespaceResponse) ProtoMessage ¶
func (*DeleteNamespaceResponse) ProtoMessage()
func (*DeleteNamespaceResponse) ProtoReflect ¶
func (x *DeleteNamespaceResponse) ProtoReflect() protoreflect.Message
func (*DeleteNamespaceResponse) Reset ¶
func (x *DeleteNamespaceResponse) Reset()
func (*DeleteNamespaceResponse) String ¶
func (x *DeleteNamespaceResponse) String() string
type DeleteRecordRequest ¶
type DeleteRecordRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Id string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"` // Rest Only Ids []string `protobuf:"bytes,5,rep,name=ids,proto3" json:"ids,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DeleteRecordRequest) Descriptor
deprecated
func (*DeleteRecordRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRecordRequest.ProtoReflect.Descriptor instead.
func (*DeleteRecordRequest) GetAnnotations ¶
func (x *DeleteRecordRequest) GetAnnotations() map[string]string
func (*DeleteRecordRequest) GetId ¶
func (x *DeleteRecordRequest) GetId() string
func (*DeleteRecordRequest) GetIds ¶
func (x *DeleteRecordRequest) GetIds() []string
func (*DeleteRecordRequest) GetNamespace ¶
func (x *DeleteRecordRequest) GetNamespace() string
func (*DeleteRecordRequest) GetResource ¶
func (x *DeleteRecordRequest) GetResource() string
func (*DeleteRecordRequest) GetToken ¶
func (x *DeleteRecordRequest) GetToken() string
func (*DeleteRecordRequest) ProtoMessage ¶
func (*DeleteRecordRequest) ProtoMessage()
func (*DeleteRecordRequest) ProtoReflect ¶
func (x *DeleteRecordRequest) ProtoReflect() protoreflect.Message
func (*DeleteRecordRequest) Reset ¶
func (x *DeleteRecordRequest) Reset()
func (*DeleteRecordRequest) String ¶
func (x *DeleteRecordRequest) String() string
type DeleteRecordResponse ¶
type DeleteRecordResponse struct {
// contains filtered or unexported fields
}
func (*DeleteRecordResponse) Descriptor
deprecated
func (*DeleteRecordResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRecordResponse.ProtoReflect.Descriptor instead.
func (*DeleteRecordResponse) ProtoMessage ¶
func (*DeleteRecordResponse) ProtoMessage()
func (*DeleteRecordResponse) ProtoReflect ¶
func (x *DeleteRecordResponse) ProtoReflect() protoreflect.Message
func (*DeleteRecordResponse) Reset ¶
func (x *DeleteRecordResponse) Reset()
func (*DeleteRecordResponse) String ¶
func (x *DeleteRecordResponse) String() string
type DeleteRequest ¶
type DeleteRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Id []string `protobuf:"bytes,4,rep,name=id,proto3" json:"id,omitempty"` Ids []string `protobuf:"bytes,5,rep,name=ids,proto3" json:"ids,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DeleteRequest) Descriptor
deprecated
func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetAnnotations ¶
func (x *DeleteRequest) GetAnnotations() map[string]string
func (*DeleteRequest) GetId ¶
func (x *DeleteRequest) GetId() []string
func (*DeleteRequest) GetIds ¶
func (x *DeleteRequest) GetIds() []string
func (*DeleteRequest) GetNamespace ¶
func (x *DeleteRequest) GetNamespace() string
func (*DeleteRequest) GetResource ¶
func (x *DeleteRequest) GetResource() string
func (*DeleteRequest) GetToken ¶
func (x *DeleteRequest) GetToken() string
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶
func (x *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (x *DeleteRequest) String() string
type DeleteResourceRequest ¶
type DeleteResourceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Ids []string `protobuf:"bytes,3,rep,name=ids,proto3" json:"ids,omitempty"` // See the comments on CreateResourceRequest.doMigration DoMigration bool `protobuf:"varint,4,opt,name=doMigration,proto3" json:"doMigration,omitempty"` // See the comments on CreateResourceRequest.forceMigration ForceMigration bool `protobuf:"varint,5,opt,name=forceMigration,proto3" json:"forceMigration,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DeleteResourceRequest) Descriptor
deprecated
func (*DeleteResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResourceRequest.ProtoReflect.Descriptor instead.
func (*DeleteResourceRequest) GetAnnotations ¶
func (x *DeleteResourceRequest) GetAnnotations() map[string]string
func (*DeleteResourceRequest) GetDoMigration ¶
func (x *DeleteResourceRequest) GetDoMigration() bool
func (*DeleteResourceRequest) GetForceMigration ¶
func (x *DeleteResourceRequest) GetForceMigration() bool
func (*DeleteResourceRequest) GetIds ¶
func (x *DeleteResourceRequest) GetIds() []string
func (*DeleteResourceRequest) GetToken ¶
func (x *DeleteResourceRequest) GetToken() string
func (*DeleteResourceRequest) ProtoMessage ¶
func (*DeleteResourceRequest) ProtoMessage()
func (*DeleteResourceRequest) ProtoReflect ¶
func (x *DeleteResourceRequest) ProtoReflect() protoreflect.Message
func (*DeleteResourceRequest) Reset ¶
func (x *DeleteResourceRequest) Reset()
func (*DeleteResourceRequest) String ¶
func (x *DeleteResourceRequest) String() string
type DeleteResourceResponse ¶
type DeleteResourceResponse struct {
// contains filtered or unexported fields
}
func (*DeleteResourceResponse) Descriptor
deprecated
func (*DeleteResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResourceResponse.ProtoReflect.Descriptor instead.
func (*DeleteResourceResponse) ProtoMessage ¶
func (*DeleteResourceResponse) ProtoMessage()
func (*DeleteResourceResponse) ProtoReflect ¶
func (x *DeleteResourceResponse) ProtoReflect() protoreflect.Message
func (*DeleteResourceResponse) Reset ¶
func (x *DeleteResourceResponse) Reset()
func (*DeleteResourceResponse) String ¶
func (x *DeleteResourceResponse) String() string
type DeleteResponse ¶
type DeleteResponse struct {
// contains filtered or unexported fields
}
func (*DeleteResponse) Descriptor
deprecated
func (*DeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) ProtoReflect ¶
func (x *DeleteResponse) ProtoReflect() protoreflect.Message
func (*DeleteResponse) Reset ¶
func (x *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (x *DeleteResponse) String() string
type DeleteUserRequest ¶
type DeleteUserRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Ids []string `protobuf:"bytes,3,rep,name=ids,proto3" json:"ids,omitempty"` // contains filtered or unexported fields }
func (*DeleteUserRequest) Descriptor
deprecated
func (*DeleteUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteUserRequest.ProtoReflect.Descriptor instead.
func (*DeleteUserRequest) GetId ¶
func (x *DeleteUserRequest) GetId() string
func (*DeleteUserRequest) GetIds ¶
func (x *DeleteUserRequest) GetIds() []string
func (*DeleteUserRequest) GetToken ¶
func (x *DeleteUserRequest) GetToken() string
func (*DeleteUserRequest) ProtoMessage ¶
func (*DeleteUserRequest) ProtoMessage()
func (*DeleteUserRequest) ProtoReflect ¶
func (x *DeleteUserRequest) ProtoReflect() protoreflect.Message
func (*DeleteUserRequest) Reset ¶
func (x *DeleteUserRequest) Reset()
func (*DeleteUserRequest) String ¶
func (x *DeleteUserRequest) String() string
type DeleteUserResponse ¶
type DeleteUserResponse struct {
// contains filtered or unexported fields
}
func (*DeleteUserResponse) Descriptor
deprecated
func (*DeleteUserResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteUserResponse.ProtoReflect.Descriptor instead.
func (*DeleteUserResponse) ProtoMessage ¶
func (*DeleteUserResponse) ProtoMessage()
func (*DeleteUserResponse) ProtoReflect ¶
func (x *DeleteUserResponse) ProtoReflect() protoreflect.Message
func (*DeleteUserResponse) Reset ¶
func (x *DeleteUserResponse) Reset()
func (*DeleteUserResponse) String ¶
func (x *DeleteUserResponse) String() string
type ExtensionClient ¶
type ExtensionClient interface { List(ctx context.Context, in *ListExtensionRequest, opts ...grpc.CallOption) (*ListExtensionResponse, error) Get(ctx context.Context, in *GetExtensionRequest, opts ...grpc.CallOption) (*GetExtensionResponse, error) Create(ctx context.Context, in *CreateExtensionRequest, opts ...grpc.CallOption) (*CreateExtensionResponse, error) Update(ctx context.Context, in *UpdateExtensionRequest, opts ...grpc.CallOption) (*UpdateExtensionResponse, error) Delete(ctx context.Context, in *DeleteExtensionRequest, opts ...grpc.CallOption) (*DeleteExtensionResponse, error) }
ExtensionClient is the client API for Extension service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewExtensionClient ¶
func NewExtensionClient(cc grpc.ClientConnInterface) ExtensionClient
type ExtensionServer ¶
type ExtensionServer interface { List(context.Context, *ListExtensionRequest) (*ListExtensionResponse, error) Get(context.Context, *GetExtensionRequest) (*GetExtensionResponse, error) Create(context.Context, *CreateExtensionRequest) (*CreateExtensionResponse, error) Update(context.Context, *UpdateExtensionRequest) (*UpdateExtensionResponse, error) Delete(context.Context, *DeleteExtensionRequest) (*DeleteExtensionResponse, error) // contains filtered or unexported methods }
ExtensionServer is the server API for Extension service. All implementations must embed UnimplementedExtensionServer for forward compatibility
type GenericClient ¶
type GenericClient interface { Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error) UpdateMulti(ctx context.Context, in *UpdateMultiRequest, opts ...grpc.CallOption) (*UpdateMultiResponse, error) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) }
GenericClient is the client API for Generic service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewGenericClient ¶
func NewGenericClient(cc grpc.ClientConnInterface) GenericClient
type GenericServer ¶
type GenericServer interface { Create(context.Context, *CreateRequest) (*CreateResponse, error) Update(context.Context, *UpdateRequest) (*UpdateResponse, error) UpdateMulti(context.Context, *UpdateMultiRequest) (*UpdateMultiResponse, error) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) List(context.Context, *ListRequest) (*ListResponse, error) Search(context.Context, *SearchRequest) (*SearchResponse, error) Get(context.Context, *GetRequest) (*GetResponse, error) // contains filtered or unexported methods }
GenericServer is the server API for Generic service. All implementations must embed UnimplementedGenericServer for forward compatibility
type GetDataSourceRequest ¶
type GetDataSourceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetDataSourceRequest) Descriptor
deprecated
func (*GetDataSourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDataSourceRequest.ProtoReflect.Descriptor instead.
func (*GetDataSourceRequest) GetId ¶
func (x *GetDataSourceRequest) GetId() string
func (*GetDataSourceRequest) GetToken ¶
func (x *GetDataSourceRequest) GetToken() string
func (*GetDataSourceRequest) ProtoMessage ¶
func (*GetDataSourceRequest) ProtoMessage()
func (*GetDataSourceRequest) ProtoReflect ¶
func (x *GetDataSourceRequest) ProtoReflect() protoreflect.Message
func (*GetDataSourceRequest) Reset ¶
func (x *GetDataSourceRequest) Reset()
func (*GetDataSourceRequest) String ¶
func (x *GetDataSourceRequest) String() string
type GetDataSourceResponse ¶
type GetDataSourceResponse struct { DataSource *model.DataSource `protobuf:"bytes,1,opt,name=dataSource,proto3" json:"dataSource,omitempty"` // contains filtered or unexported fields }
func (*GetDataSourceResponse) Descriptor
deprecated
func (*GetDataSourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetDataSourceResponse.ProtoReflect.Descriptor instead.
func (*GetDataSourceResponse) GetDataSource ¶
func (x *GetDataSourceResponse) GetDataSource() *model.DataSource
func (*GetDataSourceResponse) ProtoMessage ¶
func (*GetDataSourceResponse) ProtoMessage()
func (*GetDataSourceResponse) ProtoReflect ¶
func (x *GetDataSourceResponse) ProtoReflect() protoreflect.Message
func (*GetDataSourceResponse) Reset ¶
func (x *GetDataSourceResponse) Reset()
func (*GetDataSourceResponse) String ¶
func (x *GetDataSourceResponse) String() string
type GetExtensionRequest ¶
type GetExtensionRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetExtensionRequest) Descriptor
deprecated
func (*GetExtensionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetExtensionRequest.ProtoReflect.Descriptor instead.
func (*GetExtensionRequest) GetId ¶
func (x *GetExtensionRequest) GetId() string
func (*GetExtensionRequest) GetToken ¶
func (x *GetExtensionRequest) GetToken() string
func (*GetExtensionRequest) ProtoMessage ¶
func (*GetExtensionRequest) ProtoMessage()
func (*GetExtensionRequest) ProtoReflect ¶
func (x *GetExtensionRequest) ProtoReflect() protoreflect.Message
func (*GetExtensionRequest) Reset ¶
func (x *GetExtensionRequest) Reset()
func (*GetExtensionRequest) String ¶
func (x *GetExtensionRequest) String() string
type GetExtensionResponse ¶
type GetExtensionResponse struct { Extension *model.Extension `protobuf:"bytes,1,opt,name=extension,proto3" json:"extension,omitempty"` // contains filtered or unexported fields }
func (*GetExtensionResponse) Descriptor
deprecated
func (*GetExtensionResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetExtensionResponse.ProtoReflect.Descriptor instead.
func (*GetExtensionResponse) GetExtension ¶
func (x *GetExtensionResponse) GetExtension() *model.Extension
func (*GetExtensionResponse) ProtoMessage ¶
func (*GetExtensionResponse) ProtoMessage()
func (*GetExtensionResponse) ProtoReflect ¶
func (x *GetExtensionResponse) ProtoReflect() protoreflect.Message
func (*GetExtensionResponse) Reset ¶
func (x *GetExtensionResponse) Reset()
func (*GetExtensionResponse) String ¶
func (x *GetExtensionResponse) String() string
type GetNamespaceRequest ¶
type GetNamespaceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetNamespaceRequest) Descriptor
deprecated
func (*GetNamespaceRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetNamespaceRequest.ProtoReflect.Descriptor instead.
func (*GetNamespaceRequest) GetId ¶
func (x *GetNamespaceRequest) GetId() string
func (*GetNamespaceRequest) GetToken ¶
func (x *GetNamespaceRequest) GetToken() string
func (*GetNamespaceRequest) ProtoMessage ¶
func (*GetNamespaceRequest) ProtoMessage()
func (*GetNamespaceRequest) ProtoReflect ¶
func (x *GetNamespaceRequest) ProtoReflect() protoreflect.Message
func (*GetNamespaceRequest) Reset ¶
func (x *GetNamespaceRequest) Reset()
func (*GetNamespaceRequest) String ¶
func (x *GetNamespaceRequest) String() string
type GetNamespaceResponse ¶
type GetNamespaceResponse struct { Namespace *model.Namespace `protobuf:"bytes,1,opt,name=Namespace,proto3" json:"Namespace,omitempty"` // contains filtered or unexported fields }
func (*GetNamespaceResponse) Descriptor
deprecated
func (*GetNamespaceResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetNamespaceResponse.ProtoReflect.Descriptor instead.
func (*GetNamespaceResponse) GetNamespace ¶
func (x *GetNamespaceResponse) GetNamespace() *model.Namespace
func (*GetNamespaceResponse) ProtoMessage ¶
func (*GetNamespaceResponse) ProtoMessage()
func (*GetNamespaceResponse) ProtoReflect ¶
func (x *GetNamespaceResponse) ProtoReflect() protoreflect.Message
func (*GetNamespaceResponse) Reset ¶
func (x *GetNamespaceResponse) Reset()
func (*GetNamespaceResponse) String ¶
func (x *GetNamespaceResponse) String() string
type GetRecordRequest ¶
type GetRecordRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Id string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetRecordRequest) Descriptor
deprecated
func (*GetRecordRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRecordRequest.ProtoReflect.Descriptor instead.
func (*GetRecordRequest) GetAnnotations ¶
func (x *GetRecordRequest) GetAnnotations() map[string]string
func (*GetRecordRequest) GetId ¶
func (x *GetRecordRequest) GetId() string
func (*GetRecordRequest) GetNamespace ¶
func (x *GetRecordRequest) GetNamespace() string
func (*GetRecordRequest) GetResource ¶
func (x *GetRecordRequest) GetResource() string
func (*GetRecordRequest) GetToken ¶
func (x *GetRecordRequest) GetToken() string
func (*GetRecordRequest) ProtoMessage ¶
func (*GetRecordRequest) ProtoMessage()
func (*GetRecordRequest) ProtoReflect ¶
func (x *GetRecordRequest) ProtoReflect() protoreflect.Message
func (*GetRecordRequest) Reset ¶
func (x *GetRecordRequest) Reset()
func (*GetRecordRequest) String ¶
func (x *GetRecordRequest) String() string
type GetRecordResponse ¶
type GetRecordResponse struct { Record *model.Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` // contains filtered or unexported fields }
func (*GetRecordResponse) Descriptor
deprecated
func (*GetRecordResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetRecordResponse.ProtoReflect.Descriptor instead.
func (*GetRecordResponse) GetRecord ¶
func (x *GetRecordResponse) GetRecord() *model.Record
func (*GetRecordResponse) ProtoMessage ¶
func (*GetRecordResponse) ProtoMessage()
func (*GetRecordResponse) ProtoReflect ¶
func (x *GetRecordResponse) ProtoReflect() protoreflect.Message
func (*GetRecordResponse) Reset ¶
func (x *GetRecordResponse) Reset()
func (*GetRecordResponse) String ¶
func (x *GetRecordResponse) String() string
type GetRequest ¶
type GetRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Id string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetAnnotations ¶
func (x *GetRequest) GetAnnotations() map[string]string
func (*GetRequest) GetId ¶
func (x *GetRequest) GetId() string
func (*GetRequest) GetNamespace ¶
func (x *GetRequest) GetNamespace() string
func (*GetRequest) GetResource ¶
func (x *GetRequest) GetResource() string
func (*GetRequest) GetToken ¶
func (x *GetRequest) GetToken() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset ¶
func (x *GetRequest) Reset()
func (*GetRequest) String ¶
func (x *GetRequest) String() string
type GetResourceByNameRequest ¶
type GetResourceByNameRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetResourceByNameRequest) Descriptor
deprecated
func (*GetResourceByNameRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetResourceByNameRequest.ProtoReflect.Descriptor instead.
func (*GetResourceByNameRequest) GetAnnotations ¶
func (x *GetResourceByNameRequest) GetAnnotations() map[string]string
func (*GetResourceByNameRequest) GetName ¶
func (x *GetResourceByNameRequest) GetName() string
func (*GetResourceByNameRequest) GetNamespace ¶
func (x *GetResourceByNameRequest) GetNamespace() string
func (*GetResourceByNameRequest) GetToken ¶
func (x *GetResourceByNameRequest) GetToken() string
func (*GetResourceByNameRequest) ProtoMessage ¶
func (*GetResourceByNameRequest) ProtoMessage()
func (*GetResourceByNameRequest) ProtoReflect ¶
func (x *GetResourceByNameRequest) ProtoReflect() protoreflect.Message
func (*GetResourceByNameRequest) Reset ¶
func (x *GetResourceByNameRequest) Reset()
func (*GetResourceByNameRequest) String ¶
func (x *GetResourceByNameRequest) String() string
type GetResourceByNameResponse ¶
type GetResourceByNameResponse struct { Resource *model.Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` // contains filtered or unexported fields }
func (*GetResourceByNameResponse) Descriptor
deprecated
func (*GetResourceByNameResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResourceByNameResponse.ProtoReflect.Descriptor instead.
func (*GetResourceByNameResponse) GetResource ¶
func (x *GetResourceByNameResponse) GetResource() *model.Resource
func (*GetResourceByNameResponse) ProtoMessage ¶
func (*GetResourceByNameResponse) ProtoMessage()
func (*GetResourceByNameResponse) ProtoReflect ¶
func (x *GetResourceByNameResponse) ProtoReflect() protoreflect.Message
func (*GetResourceByNameResponse) Reset ¶
func (x *GetResourceByNameResponse) Reset()
func (*GetResourceByNameResponse) String ¶
func (x *GetResourceByNameResponse) String() string
type GetResourceRequest ¶
type GetResourceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetResourceRequest) Descriptor
deprecated
func (*GetResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetResourceRequest.ProtoReflect.Descriptor instead.
func (*GetResourceRequest) GetAnnotations ¶
func (x *GetResourceRequest) GetAnnotations() map[string]string
func (*GetResourceRequest) GetId ¶
func (x *GetResourceRequest) GetId() string
func (*GetResourceRequest) GetToken ¶
func (x *GetResourceRequest) GetToken() string
func (*GetResourceRequest) ProtoMessage ¶
func (*GetResourceRequest) ProtoMessage()
func (*GetResourceRequest) ProtoReflect ¶
func (x *GetResourceRequest) ProtoReflect() protoreflect.Message
func (*GetResourceRequest) Reset ¶
func (x *GetResourceRequest) Reset()
func (*GetResourceRequest) String ¶
func (x *GetResourceRequest) String() string
type GetResourceResponse ¶
type GetResourceResponse struct { Resource *model.Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` // contains filtered or unexported fields }
func (*GetResourceResponse) Descriptor
deprecated
func (*GetResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResourceResponse.ProtoReflect.Descriptor instead.
func (*GetResourceResponse) GetResource ¶
func (x *GetResourceResponse) GetResource() *model.Resource
func (*GetResourceResponse) ProtoMessage ¶
func (*GetResourceResponse) ProtoMessage()
func (*GetResourceResponse) ProtoReflect ¶
func (x *GetResourceResponse) ProtoReflect() protoreflect.Message
func (*GetResourceResponse) Reset ¶
func (x *GetResourceResponse) Reset()
func (*GetResourceResponse) String ¶
func (x *GetResourceResponse) String() string
type GetResponse ¶
type GetResponse struct { Item *anypb.Any `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"` // contains filtered or unexported fields }
func (*GetResponse) Descriptor
deprecated
func (*GetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.
func (*GetResponse) GetItem ¶
func (x *GetResponse) GetItem() *anypb.Any
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) ProtoReflect ¶
func (x *GetResponse) ProtoReflect() protoreflect.Message
func (*GetResponse) Reset ¶
func (x *GetResponse) Reset()
func (*GetResponse) String ¶
func (x *GetResponse) String() string
type GetSystemResourceRequest ¶
type GetSystemResourceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetSystemResourceRequest) Descriptor
deprecated
func (*GetSystemResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSystemResourceRequest.ProtoReflect.Descriptor instead.
func (*GetSystemResourceRequest) GetAnnotations ¶
func (x *GetSystemResourceRequest) GetAnnotations() map[string]string
func (*GetSystemResourceRequest) GetName ¶
func (x *GetSystemResourceRequest) GetName() string
func (*GetSystemResourceRequest) GetToken ¶
func (x *GetSystemResourceRequest) GetToken() string
func (*GetSystemResourceRequest) ProtoMessage ¶
func (*GetSystemResourceRequest) ProtoMessage()
func (*GetSystemResourceRequest) ProtoReflect ¶
func (x *GetSystemResourceRequest) ProtoReflect() protoreflect.Message
func (*GetSystemResourceRequest) Reset ¶
func (x *GetSystemResourceRequest) Reset()
func (*GetSystemResourceRequest) String ¶
func (x *GetSystemResourceRequest) String() string
type GetSystemResourceResponse ¶
type GetSystemResourceResponse struct { Resource *model.Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` // contains filtered or unexported fields }
func (*GetSystemResourceResponse) Descriptor
deprecated
func (*GetSystemResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSystemResourceResponse.ProtoReflect.Descriptor instead.
func (*GetSystemResourceResponse) GetResource ¶
func (x *GetSystemResourceResponse) GetResource() *model.Resource
func (*GetSystemResourceResponse) ProtoMessage ¶
func (*GetSystemResourceResponse) ProtoMessage()
func (*GetSystemResourceResponse) ProtoReflect ¶
func (x *GetSystemResourceResponse) ProtoReflect() protoreflect.Message
func (*GetSystemResourceResponse) Reset ¶
func (x *GetSystemResourceResponse) Reset()
func (*GetSystemResourceResponse) String ¶
func (x *GetSystemResourceResponse) String() string
type GetUserRequest ¶
type GetUserRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetUserRequest) Descriptor
deprecated
func (*GetUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetUserRequest.ProtoReflect.Descriptor instead.
func (*GetUserRequest) GetId ¶
func (x *GetUserRequest) GetId() string
func (*GetUserRequest) GetToken ¶
func (x *GetUserRequest) GetToken() string
func (*GetUserRequest) ProtoMessage ¶
func (*GetUserRequest) ProtoMessage()
func (*GetUserRequest) ProtoReflect ¶
func (x *GetUserRequest) ProtoReflect() protoreflect.Message
func (*GetUserRequest) Reset ¶
func (x *GetUserRequest) Reset()
func (*GetUserRequest) String ¶
func (x *GetUserRequest) String() string
type GetUserResponse ¶
type GetUserResponse struct { User *model.User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
func (*GetUserResponse) Descriptor
deprecated
func (*GetUserResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetUserResponse.ProtoReflect.Descriptor instead.
func (*GetUserResponse) GetUser ¶
func (x *GetUserResponse) GetUser() *model.User
func (*GetUserResponse) ProtoMessage ¶
func (*GetUserResponse) ProtoMessage()
func (*GetUserResponse) ProtoReflect ¶
func (x *GetUserResponse) ProtoReflect() protoreflect.Message
func (*GetUserResponse) Reset ¶
func (x *GetUserResponse) Reset()
func (*GetUserResponse) String ¶
func (x *GetUserResponse) String() string
type ListDataSourceRequest ¶
type ListDataSourceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
func (*ListDataSourceRequest) Descriptor
deprecated
func (*ListDataSourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDataSourceRequest.ProtoReflect.Descriptor instead.
func (*ListDataSourceRequest) GetToken ¶
func (x *ListDataSourceRequest) GetToken() string
func (*ListDataSourceRequest) ProtoMessage ¶
func (*ListDataSourceRequest) ProtoMessage()
func (*ListDataSourceRequest) ProtoReflect ¶
func (x *ListDataSourceRequest) ProtoReflect() protoreflect.Message
func (*ListDataSourceRequest) Reset ¶
func (x *ListDataSourceRequest) Reset()
func (*ListDataSourceRequest) String ¶
func (x *ListDataSourceRequest) String() string
type ListDataSourceResponse ¶
type ListDataSourceResponse struct { Content []*model.DataSource `protobuf:"bytes,2,rep,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*ListDataSourceResponse) Descriptor
deprecated
func (*ListDataSourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListDataSourceResponse.ProtoReflect.Descriptor instead.
func (*ListDataSourceResponse) GetContent ¶
func (x *ListDataSourceResponse) GetContent() []*model.DataSource
func (*ListDataSourceResponse) ProtoMessage ¶
func (*ListDataSourceResponse) ProtoMessage()
func (*ListDataSourceResponse) ProtoReflect ¶
func (x *ListDataSourceResponse) ProtoReflect() protoreflect.Message
func (*ListDataSourceResponse) Reset ¶
func (x *ListDataSourceResponse) Reset()
func (*ListDataSourceResponse) String ¶
func (x *ListDataSourceResponse) String() string
type ListEntitiesRequest ¶
type ListEntitiesRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*ListEntitiesRequest) Descriptor
deprecated
func (*ListEntitiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListEntitiesRequest.ProtoReflect.Descriptor instead.
func (*ListEntitiesRequest) GetId ¶
func (x *ListEntitiesRequest) GetId() string
func (*ListEntitiesRequest) GetToken ¶
func (x *ListEntitiesRequest) GetToken() string
func (*ListEntitiesRequest) ProtoMessage ¶
func (*ListEntitiesRequest) ProtoMessage()
func (*ListEntitiesRequest) ProtoReflect ¶
func (x *ListEntitiesRequest) ProtoReflect() protoreflect.Message
func (*ListEntitiesRequest) Reset ¶
func (x *ListEntitiesRequest) Reset()
func (*ListEntitiesRequest) String ¶
func (x *ListEntitiesRequest) String() string
type ListEntitiesResponse ¶
type ListEntitiesResponse struct { Catalogs []*model.DataSourceCatalog `protobuf:"bytes,1,rep,name=catalogs,proto3" json:"catalogs,omitempty"` // contains filtered or unexported fields }
func (*ListEntitiesResponse) Descriptor
deprecated
func (*ListEntitiesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListEntitiesResponse.ProtoReflect.Descriptor instead.
func (*ListEntitiesResponse) GetCatalogs ¶
func (x *ListEntitiesResponse) GetCatalogs() []*model.DataSourceCatalog
func (*ListEntitiesResponse) ProtoMessage ¶
func (*ListEntitiesResponse) ProtoMessage()
func (*ListEntitiesResponse) ProtoReflect ¶
func (x *ListEntitiesResponse) ProtoReflect() protoreflect.Message
func (*ListEntitiesResponse) Reset ¶
func (x *ListEntitiesResponse) Reset()
func (*ListEntitiesResponse) String ¶
func (x *ListEntitiesResponse) String() string
type ListExtensionRequest ¶
type ListExtensionRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
func (*ListExtensionRequest) Descriptor
deprecated
func (*ListExtensionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListExtensionRequest.ProtoReflect.Descriptor instead.
func (*ListExtensionRequest) GetToken ¶
func (x *ListExtensionRequest) GetToken() string
func (*ListExtensionRequest) ProtoMessage ¶
func (*ListExtensionRequest) ProtoMessage()
func (*ListExtensionRequest) ProtoReflect ¶
func (x *ListExtensionRequest) ProtoReflect() protoreflect.Message
func (*ListExtensionRequest) Reset ¶
func (x *ListExtensionRequest) Reset()
func (*ListExtensionRequest) String ¶
func (x *ListExtensionRequest) String() string
type ListExtensionResponse ¶
type ListExtensionResponse struct { Content []*model.Extension `protobuf:"bytes,1,rep,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*ListExtensionResponse) Descriptor
deprecated
func (*ListExtensionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListExtensionResponse.ProtoReflect.Descriptor instead.
func (*ListExtensionResponse) GetContent ¶
func (x *ListExtensionResponse) GetContent() []*model.Extension
func (*ListExtensionResponse) ProtoMessage ¶
func (*ListExtensionResponse) ProtoMessage()
func (*ListExtensionResponse) ProtoReflect ¶
func (x *ListExtensionResponse) ProtoReflect() protoreflect.Message
func (*ListExtensionResponse) Reset ¶
func (x *ListExtensionResponse) Reset()
func (*ListExtensionResponse) String ¶
func (x *ListExtensionResponse) String() string
type ListNamespaceRequest ¶
type ListNamespaceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
func (*ListNamespaceRequest) Descriptor
deprecated
func (*ListNamespaceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListNamespaceRequest.ProtoReflect.Descriptor instead.
func (*ListNamespaceRequest) GetToken ¶
func (x *ListNamespaceRequest) GetToken() string
func (*ListNamespaceRequest) ProtoMessage ¶
func (*ListNamespaceRequest) ProtoMessage()
func (*ListNamespaceRequest) ProtoReflect ¶
func (x *ListNamespaceRequest) ProtoReflect() protoreflect.Message
func (*ListNamespaceRequest) Reset ¶
func (x *ListNamespaceRequest) Reset()
func (*ListNamespaceRequest) String ¶
func (x *ListNamespaceRequest) String() string
type ListNamespaceResponse ¶
type ListNamespaceResponse struct { Content []*model.Namespace `protobuf:"bytes,2,rep,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*ListNamespaceResponse) Descriptor
deprecated
func (*ListNamespaceResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListNamespaceResponse.ProtoReflect.Descriptor instead.
func (*ListNamespaceResponse) GetContent ¶
func (x *ListNamespaceResponse) GetContent() []*model.Namespace
func (*ListNamespaceResponse) ProtoMessage ¶
func (*ListNamespaceResponse) ProtoMessage()
func (*ListNamespaceResponse) ProtoReflect ¶
func (x *ListNamespaceResponse) ProtoReflect() protoreflect.Message
func (*ListNamespaceResponse) Reset ¶
func (x *ListNamespaceResponse) Reset()
func (*ListNamespaceResponse) String ¶
func (x *ListNamespaceResponse) String() string
type ListRecordRequest ¶
type ListRecordRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Filters map[string]string `` /* 155-byte string literal not displayed */ Limit uint32 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"` Offset uint64 `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"` UseHistory bool `protobuf:"varint,7,opt,name=useHistory,proto3" json:"useHistory,omitempty"` ResolveReferences []string `protobuf:"bytes,8,rep,name=resolveReferences,proto3" json:"resolveReferences,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ListRecordRequest) Descriptor
deprecated
func (*ListRecordRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRecordRequest.ProtoReflect.Descriptor instead.
func (*ListRecordRequest) GetAnnotations ¶
func (x *ListRecordRequest) GetAnnotations() map[string]string
func (*ListRecordRequest) GetFilters ¶
func (x *ListRecordRequest) GetFilters() map[string]string
func (*ListRecordRequest) GetLimit ¶
func (x *ListRecordRequest) GetLimit() uint32
func (*ListRecordRequest) GetNamespace ¶
func (x *ListRecordRequest) GetNamespace() string
func (*ListRecordRequest) GetOffset ¶
func (x *ListRecordRequest) GetOffset() uint64
func (*ListRecordRequest) GetResolveReferences ¶
func (x *ListRecordRequest) GetResolveReferences() []string
func (*ListRecordRequest) GetResource ¶
func (x *ListRecordRequest) GetResource() string
func (*ListRecordRequest) GetToken ¶
func (x *ListRecordRequest) GetToken() string
func (*ListRecordRequest) GetUseHistory ¶
func (x *ListRecordRequest) GetUseHistory() bool
func (*ListRecordRequest) ProtoMessage ¶
func (*ListRecordRequest) ProtoMessage()
func (*ListRecordRequest) ProtoReflect ¶
func (x *ListRecordRequest) ProtoReflect() protoreflect.Message
func (*ListRecordRequest) Reset ¶
func (x *ListRecordRequest) Reset()
func (*ListRecordRequest) String ¶
func (x *ListRecordRequest) String() string
type ListRecordResponse ¶
type ListRecordResponse struct { Total uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` Content []*model.Record `protobuf:"bytes,2,rep,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*ListRecordResponse) Descriptor
deprecated
func (*ListRecordResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListRecordResponse.ProtoReflect.Descriptor instead.
func (*ListRecordResponse) GetContent ¶
func (x *ListRecordResponse) GetContent() []*model.Record
func (*ListRecordResponse) GetTotal ¶
func (x *ListRecordResponse) GetTotal() uint32
func (*ListRecordResponse) ProtoMessage ¶
func (*ListRecordResponse) ProtoMessage()
func (*ListRecordResponse) ProtoReflect ¶
func (x *ListRecordResponse) ProtoReflect() protoreflect.Message
func (*ListRecordResponse) Reset ¶
func (x *ListRecordResponse) Reset()
func (*ListRecordResponse) String ¶
func (x *ListRecordResponse) String() string
type ListRequest ¶
type ListRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Filters map[string]string `` /* 155-byte string literal not displayed */ Limit uint32 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"` Offset uint64 `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"` UseHistory bool `protobuf:"varint,7,opt,name=useHistory,proto3" json:"useHistory,omitempty"` ResolveReferences []string `protobuf:"bytes,8,rep,name=resolveReferences,proto3" json:"resolveReferences,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetAnnotations ¶
func (x *ListRequest) GetAnnotations() map[string]string
func (*ListRequest) GetFilters ¶
func (x *ListRequest) GetFilters() map[string]string
func (*ListRequest) GetLimit ¶
func (x *ListRequest) GetLimit() uint32
func (*ListRequest) GetNamespace ¶
func (x *ListRequest) GetNamespace() string
func (*ListRequest) GetOffset ¶
func (x *ListRequest) GetOffset() uint64
func (*ListRequest) GetResolveReferences ¶
func (x *ListRequest) GetResolveReferences() []string
func (*ListRequest) GetResource ¶
func (x *ListRequest) GetResource() string
func (*ListRequest) GetToken ¶
func (x *ListRequest) GetToken() string
func (*ListRequest) GetUseHistory ¶
func (x *ListRequest) GetUseHistory() bool
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type ListResourceRequest ¶
type ListResourceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ListResourceRequest) Descriptor
deprecated
func (*ListResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListResourceRequest.ProtoReflect.Descriptor instead.
func (*ListResourceRequest) GetAnnotations ¶
func (x *ListResourceRequest) GetAnnotations() map[string]string
func (*ListResourceRequest) GetToken ¶
func (x *ListResourceRequest) GetToken() string
func (*ListResourceRequest) ProtoMessage ¶
func (*ListResourceRequest) ProtoMessage()
func (*ListResourceRequest) ProtoReflect ¶
func (x *ListResourceRequest) ProtoReflect() protoreflect.Message
func (*ListResourceRequest) Reset ¶
func (x *ListResourceRequest) Reset()
func (*ListResourceRequest) String ¶
func (x *ListResourceRequest) String() string
type ListResourceResponse ¶
type ListResourceResponse struct { Resources []*model.Resource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"` // contains filtered or unexported fields }
func (*ListResourceResponse) Descriptor
deprecated
func (*ListResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResourceResponse.ProtoReflect.Descriptor instead.
func (*ListResourceResponse) GetResources ¶
func (x *ListResourceResponse) GetResources() []*model.Resource
func (*ListResourceResponse) ProtoMessage ¶
func (*ListResourceResponse) ProtoMessage()
func (*ListResourceResponse) ProtoReflect ¶
func (x *ListResourceResponse) ProtoReflect() protoreflect.Message
func (*ListResourceResponse) Reset ¶
func (x *ListResourceResponse) Reset()
func (*ListResourceResponse) String ¶
func (x *ListResourceResponse) String() string
type ListResponse ¶
type ListResponse struct { Total uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` Content []*anypb.Any `protobuf:"bytes,2,rep,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetContent ¶
func (x *ListResponse) GetContent() []*anypb.Any
func (*ListResponse) GetTotal ¶
func (x *ListResponse) GetTotal() uint32
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
type ListUserRequest ¶
type ListUserRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"` Offset uint64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"` // contains filtered or unexported fields }
func (*ListUserRequest) Descriptor
deprecated
func (*ListUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListUserRequest.ProtoReflect.Descriptor instead.
func (*ListUserRequest) GetLimit ¶
func (x *ListUserRequest) GetLimit() uint32
func (*ListUserRequest) GetOffset ¶
func (x *ListUserRequest) GetOffset() uint64
func (*ListUserRequest) GetToken ¶
func (x *ListUserRequest) GetToken() string
func (*ListUserRequest) ProtoMessage ¶
func (*ListUserRequest) ProtoMessage()
func (*ListUserRequest) ProtoReflect ¶
func (x *ListUserRequest) ProtoReflect() protoreflect.Message
func (*ListUserRequest) Reset ¶
func (x *ListUserRequest) Reset()
func (*ListUserRequest) String ¶
func (x *ListUserRequest) String() string
type ListUserResponse ¶
type ListUserResponse struct { Content []*model.User `protobuf:"bytes,1,rep,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*ListUserResponse) Descriptor
deprecated
func (*ListUserResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListUserResponse.ProtoReflect.Descriptor instead.
func (*ListUserResponse) GetContent ¶
func (x *ListUserResponse) GetContent() []*model.User
func (*ListUserResponse) ProtoMessage ¶
func (*ListUserResponse) ProtoMessage()
func (*ListUserResponse) ProtoReflect ¶
func (x *ListUserResponse) ProtoReflect() protoreflect.Message
func (*ListUserResponse) Reset ¶
func (x *ListUserResponse) Reset()
func (*ListUserResponse) String ¶
func (x *ListUserResponse) String() string
type NamespaceClient ¶
type NamespaceClient interface { Create(ctx context.Context, in *CreateNamespaceRequest, opts ...grpc.CallOption) (*CreateNamespaceResponse, error) List(ctx context.Context, in *ListNamespaceRequest, opts ...grpc.CallOption) (*ListNamespaceResponse, error) Update(ctx context.Context, in *UpdateNamespaceRequest, opts ...grpc.CallOption) (*UpdateNamespaceResponse, error) Delete(ctx context.Context, in *DeleteNamespaceRequest, opts ...grpc.CallOption) (*DeleteNamespaceResponse, error) Get(ctx context.Context, in *GetNamespaceRequest, opts ...grpc.CallOption) (*GetNamespaceResponse, error) }
NamespaceClient is the client API for Namespace service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewNamespaceClient ¶
func NewNamespaceClient(cc grpc.ClientConnInterface) NamespaceClient
type NamespaceServer ¶
type NamespaceServer interface { Create(context.Context, *CreateNamespaceRequest) (*CreateNamespaceResponse, error) List(context.Context, *ListNamespaceRequest) (*ListNamespaceResponse, error) Update(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error) Delete(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error) Get(context.Context, *GetNamespaceRequest) (*GetNamespaceResponse, error) // contains filtered or unexported methods }
NamespaceServer is the server API for Namespace service. All implementations must embed UnimplementedNamespaceServer for forward compatibility
type PrepareResourceFromEntityRequest ¶
type PrepareResourceFromEntityRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // data source id, required, It is for specifying that which database the operation will be performed Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // catalog is optional, if not provided, default catalog will be used, catalog is like schema in database Catalog string `protobuf:"bytes,3,opt,name=catalog,proto3" json:"catalog,omitempty"` // entity is required, it is like table in database, collection on mongodb, etc. Entity string `protobuf:"bytes,4,opt,name=entity,proto3" json:"entity,omitempty"` // contains filtered or unexported fields }
func (*PrepareResourceFromEntityRequest) Descriptor
deprecated
func (*PrepareResourceFromEntityRequest) Descriptor() ([]byte, []int)
Deprecated: Use PrepareResourceFromEntityRequest.ProtoReflect.Descriptor instead.
func (*PrepareResourceFromEntityRequest) GetCatalog ¶
func (x *PrepareResourceFromEntityRequest) GetCatalog() string
func (*PrepareResourceFromEntityRequest) GetEntity ¶
func (x *PrepareResourceFromEntityRequest) GetEntity() string
func (*PrepareResourceFromEntityRequest) GetId ¶
func (x *PrepareResourceFromEntityRequest) GetId() string
func (*PrepareResourceFromEntityRequest) GetToken ¶
func (x *PrepareResourceFromEntityRequest) GetToken() string
func (*PrepareResourceFromEntityRequest) ProtoMessage ¶
func (*PrepareResourceFromEntityRequest) ProtoMessage()
func (*PrepareResourceFromEntityRequest) ProtoReflect ¶
func (x *PrepareResourceFromEntityRequest) ProtoReflect() protoreflect.Message
func (*PrepareResourceFromEntityRequest) Reset ¶
func (x *PrepareResourceFromEntityRequest) Reset()
func (*PrepareResourceFromEntityRequest) String ¶
func (x *PrepareResourceFromEntityRequest) String() string
type PrepareResourceFromEntityResponse ¶
type PrepareResourceFromEntityResponse struct { Resource *model.Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` // contains filtered or unexported fields }
func (*PrepareResourceFromEntityResponse) Descriptor
deprecated
func (*PrepareResourceFromEntityResponse) Descriptor() ([]byte, []int)
Deprecated: Use PrepareResourceFromEntityResponse.ProtoReflect.Descriptor instead.
func (*PrepareResourceFromEntityResponse) GetResource ¶
func (x *PrepareResourceFromEntityResponse) GetResource() *model.Resource
func (*PrepareResourceFromEntityResponse) ProtoMessage ¶
func (*PrepareResourceFromEntityResponse) ProtoMessage()
func (*PrepareResourceFromEntityResponse) ProtoReflect ¶
func (x *PrepareResourceFromEntityResponse) ProtoReflect() protoreflect.Message
func (*PrepareResourceFromEntityResponse) Reset ¶
func (x *PrepareResourceFromEntityResponse) Reset()
func (*PrepareResourceFromEntityResponse) String ¶
func (x *PrepareResourceFromEntityResponse) String() string
type PrepareResourceMigrationPlanRequest ¶
type PrepareResourceMigrationPlanRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` PrepareFromDataSource bool `protobuf:"varint,2,opt,name=prepareFromDataSource,proto3" json:"prepareFromDataSource,omitempty"` Resources []*model.Resource `protobuf:"bytes,3,rep,name=resources,proto3" json:"resources,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*PrepareResourceMigrationPlanRequest) Descriptor
deprecated
func (*PrepareResourceMigrationPlanRequest) Descriptor() ([]byte, []int)
Deprecated: Use PrepareResourceMigrationPlanRequest.ProtoReflect.Descriptor instead.
func (*PrepareResourceMigrationPlanRequest) GetAnnotations ¶
func (x *PrepareResourceMigrationPlanRequest) GetAnnotations() map[string]string
func (*PrepareResourceMigrationPlanRequest) GetPrepareFromDataSource ¶
func (x *PrepareResourceMigrationPlanRequest) GetPrepareFromDataSource() bool
func (*PrepareResourceMigrationPlanRequest) GetResources ¶
func (x *PrepareResourceMigrationPlanRequest) GetResources() []*model.Resource
func (*PrepareResourceMigrationPlanRequest) GetToken ¶
func (x *PrepareResourceMigrationPlanRequest) GetToken() string
func (*PrepareResourceMigrationPlanRequest) ProtoMessage ¶
func (*PrepareResourceMigrationPlanRequest) ProtoMessage()
func (*PrepareResourceMigrationPlanRequest) ProtoReflect ¶
func (x *PrepareResourceMigrationPlanRequest) ProtoReflect() protoreflect.Message
func (*PrepareResourceMigrationPlanRequest) Reset ¶
func (x *PrepareResourceMigrationPlanRequest) Reset()
func (*PrepareResourceMigrationPlanRequest) String ¶
func (x *PrepareResourceMigrationPlanRequest) String() string
type PrepareResourceMigrationPlanResponse ¶
type PrepareResourceMigrationPlanResponse struct { Plans []*model.ResourceMigrationPlan `protobuf:"bytes,1,rep,name=plans,proto3" json:"plans,omitempty"` // contains filtered or unexported fields }
func (*PrepareResourceMigrationPlanResponse) Descriptor
deprecated
func (*PrepareResourceMigrationPlanResponse) Descriptor() ([]byte, []int)
Deprecated: Use PrepareResourceMigrationPlanResponse.ProtoReflect.Descriptor instead.
func (*PrepareResourceMigrationPlanResponse) GetPlans ¶
func (x *PrepareResourceMigrationPlanResponse) GetPlans() []*model.ResourceMigrationPlan
func (*PrepareResourceMigrationPlanResponse) ProtoMessage ¶
func (*PrepareResourceMigrationPlanResponse) ProtoMessage()
func (*PrepareResourceMigrationPlanResponse) ProtoReflect ¶
func (x *PrepareResourceMigrationPlanResponse) ProtoReflect() protoreflect.Message
func (*PrepareResourceMigrationPlanResponse) Reset ¶
func (x *PrepareResourceMigrationPlanResponse) Reset()
func (*PrepareResourceMigrationPlanResponse) String ¶
func (x *PrepareResourceMigrationPlanResponse) String() string
type ReadStreamRequest ¶
type ReadStreamRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Query *model.BooleanExpression `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"` Limit uint32 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"` Offset uint64 `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"` UseHistory bool `protobuf:"varint,7,opt,name=useHistory,proto3" json:"useHistory,omitempty"` ResolveReferences []string `protobuf:"bytes,8,rep,name=resolveReferences,proto3" json:"resolveReferences,omitempty"` UseTransaction bool `protobuf:"varint,9,opt,name=useTransaction,proto3" json:"useTransaction,omitempty"` PackRecords bool `protobuf:"varint,10,opt,name=packRecords,proto3" json:"packRecords,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ReadStreamRequest) Descriptor
deprecated
func (*ReadStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadStreamRequest.ProtoReflect.Descriptor instead.
func (*ReadStreamRequest) GetAnnotations ¶
func (x *ReadStreamRequest) GetAnnotations() map[string]string
func (*ReadStreamRequest) GetLimit ¶
func (x *ReadStreamRequest) GetLimit() uint32
func (*ReadStreamRequest) GetNamespace ¶
func (x *ReadStreamRequest) GetNamespace() string
func (*ReadStreamRequest) GetOffset ¶
func (x *ReadStreamRequest) GetOffset() uint64
func (*ReadStreamRequest) GetPackRecords ¶
func (x *ReadStreamRequest) GetPackRecords() bool
func (*ReadStreamRequest) GetQuery ¶
func (x *ReadStreamRequest) GetQuery() *model.BooleanExpression
func (*ReadStreamRequest) GetResolveReferences ¶
func (x *ReadStreamRequest) GetResolveReferences() []string
func (*ReadStreamRequest) GetResource ¶
func (x *ReadStreamRequest) GetResource() string
func (*ReadStreamRequest) GetToken ¶
func (x *ReadStreamRequest) GetToken() string
func (*ReadStreamRequest) GetUseHistory ¶
func (x *ReadStreamRequest) GetUseHistory() bool
func (*ReadStreamRequest) GetUseTransaction ¶
func (x *ReadStreamRequest) GetUseTransaction() bool
func (*ReadStreamRequest) ProtoMessage ¶
func (*ReadStreamRequest) ProtoMessage()
func (*ReadStreamRequest) ProtoReflect ¶
func (x *ReadStreamRequest) ProtoReflect() protoreflect.Message
func (*ReadStreamRequest) Reset ¶
func (x *ReadStreamRequest) Reset()
func (*ReadStreamRequest) String ¶
func (x *ReadStreamRequest) String() string
type RecordClient ¶
type RecordClient interface { Create(ctx context.Context, in *CreateRecordRequest, opts ...grpc.CallOption) (*CreateRecordResponse, error) Update(ctx context.Context, in *UpdateRecordRequest, opts ...grpc.CallOption) (*UpdateRecordResponse, error) Apply(ctx context.Context, in *ApplyRecordRequest, opts ...grpc.CallOption) (*ApplyRecordResponse, error) // Not implemented yet UpdateMulti(ctx context.Context, in *UpdateMultiRecordRequest, opts ...grpc.CallOption) (*UpdateMultiRecordResponse, error) Delete(ctx context.Context, in *DeleteRecordRequest, opts ...grpc.CallOption) (*DeleteRecordResponse, error) List(ctx context.Context, in *ListRecordRequest, opts ...grpc.CallOption) (*ListRecordResponse, error) Search(ctx context.Context, in *SearchRecordRequest, opts ...grpc.CallOption) (*SearchRecordResponse, error) ReadStream(ctx context.Context, in *ReadStreamRequest, opts ...grpc.CallOption) (Record_ReadStreamClient, error) // Not implemented yet WriteStream(ctx context.Context, opts ...grpc.CallOption) (Record_WriteStreamClient, error) Get(ctx context.Context, in *GetRecordRequest, opts ...grpc.CallOption) (*GetRecordResponse, error) }
RecordClient is the client API for Record service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewRecordClient ¶
func NewRecordClient(cc grpc.ClientConnInterface) RecordClient
type RecordServer ¶
type RecordServer interface { Create(context.Context, *CreateRecordRequest) (*CreateRecordResponse, error) Update(context.Context, *UpdateRecordRequest) (*UpdateRecordResponse, error) Apply(context.Context, *ApplyRecordRequest) (*ApplyRecordResponse, error) // Not implemented yet UpdateMulti(context.Context, *UpdateMultiRecordRequest) (*UpdateMultiRecordResponse, error) Delete(context.Context, *DeleteRecordRequest) (*DeleteRecordResponse, error) List(context.Context, *ListRecordRequest) (*ListRecordResponse, error) Search(context.Context, *SearchRecordRequest) (*SearchRecordResponse, error) ReadStream(*ReadStreamRequest, Record_ReadStreamServer) error // Not implemented yet WriteStream(Record_WriteStreamServer) error Get(context.Context, *GetRecordRequest) (*GetRecordResponse, error) // contains filtered or unexported methods }
RecordServer is the server API for Record service. All implementations must embed UnimplementedRecordServer for forward compatibility
type Record_ReadStreamClient ¶
type Record_ReadStreamClient interface { Recv() (*model.Record, error) grpc.ClientStream }
type Record_ReadStreamServer ¶
type Record_ReadStreamServer interface { Send(*model.Record) error grpc.ServerStream }
type Record_WriteStreamClient ¶
type Record_WriteStreamClient interface { Send(*model.Record) error CloseAndRecv() (*WriteStreamResponse, error) grpc.ClientStream }
type Record_WriteStreamServer ¶
type Record_WriteStreamServer interface { SendAndClose(*WriteStreamResponse) error Recv() (*model.Record, error) grpc.ServerStream }
type RenewTokenRequest ¶
type RenewTokenRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Term model.TokenTerm `protobuf:"varint,2,opt,name=term,proto3,enum=model.TokenTerm" json:"term,omitempty"` // contains filtered or unexported fields }
func (*RenewTokenRequest) Descriptor
deprecated
func (*RenewTokenRequest) Descriptor() ([]byte, []int)
Deprecated: Use RenewTokenRequest.ProtoReflect.Descriptor instead.
func (*RenewTokenRequest) GetTerm ¶
func (x *RenewTokenRequest) GetTerm() model.TokenTerm
func (*RenewTokenRequest) GetToken ¶
func (x *RenewTokenRequest) GetToken() string
func (*RenewTokenRequest) ProtoMessage ¶
func (*RenewTokenRequest) ProtoMessage()
func (*RenewTokenRequest) ProtoReflect ¶
func (x *RenewTokenRequest) ProtoReflect() protoreflect.Message
func (*RenewTokenRequest) Reset ¶
func (x *RenewTokenRequest) Reset()
func (*RenewTokenRequest) String ¶
func (x *RenewTokenRequest) String() string
type RenewTokenResponse ¶
type RenewTokenResponse struct { Token *model.Token `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
func (*RenewTokenResponse) Descriptor
deprecated
func (*RenewTokenResponse) Descriptor() ([]byte, []int)
Deprecated: Use RenewTokenResponse.ProtoReflect.Descriptor instead.
func (*RenewTokenResponse) GetToken ¶
func (x *RenewTokenResponse) GetToken() *model.Token
func (*RenewTokenResponse) ProtoMessage ¶
func (*RenewTokenResponse) ProtoMessage()
func (*RenewTokenResponse) ProtoReflect ¶
func (x *RenewTokenResponse) ProtoReflect() protoreflect.Message
func (*RenewTokenResponse) Reset ¶
func (x *RenewTokenResponse) Reset()
func (*RenewTokenResponse) String ¶
func (x *RenewTokenResponse) String() string
type ResourceClient ¶
type ResourceClient interface { Create(ctx context.Context, in *CreateResourceRequest, opts ...grpc.CallOption) (*CreateResourceResponse, error) Update(ctx context.Context, in *UpdateResourceRequest, opts ...grpc.CallOption) (*UpdateResourceResponse, error) Delete(ctx context.Context, in *DeleteResourceRequest, opts ...grpc.CallOption) (*DeleteResourceResponse, error) List(ctx context.Context, in *ListResourceRequest, opts ...grpc.CallOption) (*ListResourceResponse, error) // PrepareResourceMigrationPlan will prepare the migration plan for the resources, it will not do any migration. It will just return the plan for the migration. PrepareResourceMigrationPlan(ctx context.Context, in *PrepareResourceMigrationPlanRequest, opts ...grpc.CallOption) (*PrepareResourceMigrationPlanResponse, error) Get(ctx context.Context, in *GetResourceRequest, opts ...grpc.CallOption) (*GetResourceResponse, error) GetByName(ctx context.Context, in *GetResourceByNameRequest, opts ...grpc.CallOption) (*GetResourceByNameResponse, error) GetSystemResource(ctx context.Context, in *GetSystemResourceRequest, opts ...grpc.CallOption) (*GetSystemResourceResponse, error) }
ResourceClient is the client API for Resource service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewResourceClient ¶
func NewResourceClient(cc grpc.ClientConnInterface) ResourceClient
type ResourceServer ¶
type ResourceServer interface { Create(context.Context, *CreateResourceRequest) (*CreateResourceResponse, error) Update(context.Context, *UpdateResourceRequest) (*UpdateResourceResponse, error) Delete(context.Context, *DeleteResourceRequest) (*DeleteResourceResponse, error) List(context.Context, *ListResourceRequest) (*ListResourceResponse, error) // PrepareResourceMigrationPlan will prepare the migration plan for the resources, it will not do any migration. It will just return the plan for the migration. PrepareResourceMigrationPlan(context.Context, *PrepareResourceMigrationPlanRequest) (*PrepareResourceMigrationPlanResponse, error) Get(context.Context, *GetResourceRequest) (*GetResourceResponse, error) GetByName(context.Context, *GetResourceByNameRequest) (*GetResourceByNameResponse, error) GetSystemResource(context.Context, *GetSystemResourceRequest) (*GetSystemResourceResponse, error) // contains filtered or unexported methods }
ResourceServer is the server API for Resource service. All implementations must embed UnimplementedResourceServer for forward compatibility
type SearchRecordRequest ¶
type SearchRecordRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Query *model.BooleanExpression `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"` Limit uint32 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"` Offset uint64 `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"` UseHistory bool `protobuf:"varint,7,opt,name=useHistory,proto3" json:"useHistory,omitempty"` ResolveReferences []string `protobuf:"bytes,8,rep,name=resolveReferences,proto3" json:"resolveReferences,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*SearchRecordRequest) Descriptor
deprecated
func (*SearchRecordRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchRecordRequest.ProtoReflect.Descriptor instead.
func (*SearchRecordRequest) GetAnnotations ¶
func (x *SearchRecordRequest) GetAnnotations() map[string]string
func (*SearchRecordRequest) GetLimit ¶
func (x *SearchRecordRequest) GetLimit() uint32
func (*SearchRecordRequest) GetNamespace ¶
func (x *SearchRecordRequest) GetNamespace() string
func (*SearchRecordRequest) GetOffset ¶
func (x *SearchRecordRequest) GetOffset() uint64
func (*SearchRecordRequest) GetQuery ¶
func (x *SearchRecordRequest) GetQuery() *model.BooleanExpression
func (*SearchRecordRequest) GetResolveReferences ¶
func (x *SearchRecordRequest) GetResolveReferences() []string
func (*SearchRecordRequest) GetResource ¶
func (x *SearchRecordRequest) GetResource() string
func (*SearchRecordRequest) GetToken ¶
func (x *SearchRecordRequest) GetToken() string
func (*SearchRecordRequest) GetUseHistory ¶
func (x *SearchRecordRequest) GetUseHistory() bool
func (*SearchRecordRequest) ProtoMessage ¶
func (*SearchRecordRequest) ProtoMessage()
func (*SearchRecordRequest) ProtoReflect ¶
func (x *SearchRecordRequest) ProtoReflect() protoreflect.Message
func (*SearchRecordRequest) Reset ¶
func (x *SearchRecordRequest) Reset()
func (*SearchRecordRequest) String ¶
func (x *SearchRecordRequest) String() string
type SearchRecordResponse ¶
type SearchRecordResponse struct { Total uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` Content []*model.Record `protobuf:"bytes,2,rep,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*SearchRecordResponse) Descriptor
deprecated
func (*SearchRecordResponse) Descriptor() ([]byte, []int)
Deprecated: Use SearchRecordResponse.ProtoReflect.Descriptor instead.
func (*SearchRecordResponse) GetContent ¶
func (x *SearchRecordResponse) GetContent() []*model.Record
func (*SearchRecordResponse) GetTotal ¶
func (x *SearchRecordResponse) GetTotal() uint32
func (*SearchRecordResponse) ProtoMessage ¶
func (*SearchRecordResponse) ProtoMessage()
func (*SearchRecordResponse) ProtoReflect ¶
func (x *SearchRecordResponse) ProtoReflect() protoreflect.Message
func (*SearchRecordResponse) Reset ¶
func (x *SearchRecordResponse) Reset()
func (*SearchRecordResponse) String ¶
func (x *SearchRecordResponse) String() string
type SearchRequest ¶
type SearchRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Query *model.BooleanExpression `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"` Limit uint32 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"` Offset uint64 `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"` UseHistory bool `protobuf:"varint,7,opt,name=useHistory,proto3" json:"useHistory,omitempty"` ResolveReferences []string `protobuf:"bytes,8,rep,name=resolveReferences,proto3" json:"resolveReferences,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*SearchRequest) Descriptor
deprecated
func (*SearchRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.
func (*SearchRequest) GetAnnotations ¶
func (x *SearchRequest) GetAnnotations() map[string]string
func (*SearchRequest) GetLimit ¶
func (x *SearchRequest) GetLimit() uint32
func (*SearchRequest) GetNamespace ¶
func (x *SearchRequest) GetNamespace() string
func (*SearchRequest) GetOffset ¶
func (x *SearchRequest) GetOffset() uint64
func (*SearchRequest) GetQuery ¶
func (x *SearchRequest) GetQuery() *model.BooleanExpression
func (*SearchRequest) GetResolveReferences ¶
func (x *SearchRequest) GetResolveReferences() []string
func (*SearchRequest) GetResource ¶
func (x *SearchRequest) GetResource() string
func (*SearchRequest) GetToken ¶
func (x *SearchRequest) GetToken() string
func (*SearchRequest) GetUseHistory ¶
func (x *SearchRequest) GetUseHistory() bool
func (*SearchRequest) ProtoMessage ¶
func (*SearchRequest) ProtoMessage()
func (*SearchRequest) ProtoReflect ¶
func (x *SearchRequest) ProtoReflect() protoreflect.Message
func (*SearchRequest) Reset ¶
func (x *SearchRequest) Reset()
func (*SearchRequest) String ¶
func (x *SearchRequest) String() string
type SearchResponse ¶
type SearchResponse struct { Total uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` Content []*anypb.Any `protobuf:"bytes,2,rep,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*SearchResponse) Descriptor
deprecated
func (*SearchResponse) Descriptor() ([]byte, []int)
Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.
func (*SearchResponse) GetContent ¶
func (x *SearchResponse) GetContent() []*anypb.Any
func (*SearchResponse) GetTotal ¶
func (x *SearchResponse) GetTotal() uint32
func (*SearchResponse) ProtoMessage ¶
func (*SearchResponse) ProtoMessage()
func (*SearchResponse) ProtoReflect ¶
func (x *SearchResponse) ProtoReflect() protoreflect.Message
func (*SearchResponse) Reset ¶
func (x *SearchResponse) Reset()
func (*SearchResponse) String ¶
func (x *SearchResponse) String() string
type StatusRequest ¶
type StatusRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*StatusRequest) Descriptor
deprecated
func (*StatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.
func (*StatusRequest) GetId ¶
func (x *StatusRequest) GetId() string
func (*StatusRequest) GetToken ¶
func (x *StatusRequest) GetToken() string
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) ProtoReflect ¶
func (x *StatusRequest) ProtoReflect() protoreflect.Message
func (*StatusRequest) Reset ¶
func (x *StatusRequest) Reset()
func (*StatusRequest) String ¶
func (x *StatusRequest) String() string
type StatusResponse ¶
type StatusResponse struct { ConnectionAlreadyInitiated bool `protobuf:"varint,1,opt,name=connectionAlreadyInitiated,proto3" json:"connectionAlreadyInitiated,omitempty"` TestConnection bool `protobuf:"varint,2,opt,name=testConnection,proto3" json:"testConnection,omitempty"` // contains filtered or unexported fields }
func (*StatusResponse) Descriptor
deprecated
func (*StatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.
func (*StatusResponse) GetConnectionAlreadyInitiated ¶
func (x *StatusResponse) GetConnectionAlreadyInitiated() bool
func (*StatusResponse) GetTestConnection ¶
func (x *StatusResponse) GetTestConnection() bool
func (*StatusResponse) ProtoMessage ¶
func (*StatusResponse) ProtoMessage()
func (*StatusResponse) ProtoReflect ¶
func (x *StatusResponse) ProtoReflect() protoreflect.Message
func (*StatusResponse) Reset ¶
func (x *StatusResponse) Reset()
func (*StatusResponse) String ¶
func (x *StatusResponse) String() string
type UnimplementedAuthenticationServer ¶
type UnimplementedAuthenticationServer struct { }
UnimplementedAuthenticationServer must be embedded to have forward compatible implementations.
func (UnimplementedAuthenticationServer) Authenticate ¶
func (UnimplementedAuthenticationServer) Authenticate(context.Context, *AuthenticationRequest) (*AuthenticationResponse, error)
func (UnimplementedAuthenticationServer) RenewToken ¶
func (UnimplementedAuthenticationServer) RenewToken(context.Context, *RenewTokenRequest) (*RenewTokenResponse, error)
type UnimplementedDataSourceServer ¶
type UnimplementedDataSourceServer struct { }
UnimplementedDataSourceServer must be embedded to have forward compatible implementations.
func (UnimplementedDataSourceServer) Create ¶
func (UnimplementedDataSourceServer) Create(context.Context, *CreateDataSourceRequest) (*CreateDataSourceResponse, error)
func (UnimplementedDataSourceServer) Delete ¶
func (UnimplementedDataSourceServer) Delete(context.Context, *DeleteDataSourceRequest) (*DeleteDataSourceResponse, error)
func (UnimplementedDataSourceServer) Get ¶
func (UnimplementedDataSourceServer) Get(context.Context, *GetDataSourceRequest) (*GetDataSourceResponse, error)
func (UnimplementedDataSourceServer) List ¶
func (UnimplementedDataSourceServer) List(context.Context, *ListDataSourceRequest) (*ListDataSourceResponse, error)
func (UnimplementedDataSourceServer) ListEntities ¶
func (UnimplementedDataSourceServer) ListEntities(context.Context, *ListEntitiesRequest) (*ListEntitiesResponse, error)
func (UnimplementedDataSourceServer) PrepareResourceFromEntity ¶
func (UnimplementedDataSourceServer) PrepareResourceFromEntity(context.Context, *PrepareResourceFromEntityRequest) (*PrepareResourceFromEntityResponse, error)
func (UnimplementedDataSourceServer) Status ¶
func (UnimplementedDataSourceServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)
func (UnimplementedDataSourceServer) Update ¶
func (UnimplementedDataSourceServer) Update(context.Context, *UpdateDataSourceRequest) (*UpdateDataSourceResponse, error)
type UnimplementedExtensionServer ¶
type UnimplementedExtensionServer struct { }
UnimplementedExtensionServer must be embedded to have forward compatible implementations.
func (UnimplementedExtensionServer) Create ¶
func (UnimplementedExtensionServer) Create(context.Context, *CreateExtensionRequest) (*CreateExtensionResponse, error)
func (UnimplementedExtensionServer) Delete ¶
func (UnimplementedExtensionServer) Delete(context.Context, *DeleteExtensionRequest) (*DeleteExtensionResponse, error)
func (UnimplementedExtensionServer) Get ¶
func (UnimplementedExtensionServer) Get(context.Context, *GetExtensionRequest) (*GetExtensionResponse, error)
func (UnimplementedExtensionServer) List ¶
func (UnimplementedExtensionServer) List(context.Context, *ListExtensionRequest) (*ListExtensionResponse, error)
func (UnimplementedExtensionServer) Update ¶
func (UnimplementedExtensionServer) Update(context.Context, *UpdateExtensionRequest) (*UpdateExtensionResponse, error)
type UnimplementedGenericServer ¶
type UnimplementedGenericServer struct { }
UnimplementedGenericServer must be embedded to have forward compatible implementations.
func (UnimplementedGenericServer) Create ¶
func (UnimplementedGenericServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)
func (UnimplementedGenericServer) Delete ¶
func (UnimplementedGenericServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
func (UnimplementedGenericServer) Get ¶
func (UnimplementedGenericServer) Get(context.Context, *GetRequest) (*GetResponse, error)
func (UnimplementedGenericServer) List ¶
func (UnimplementedGenericServer) List(context.Context, *ListRequest) (*ListResponse, error)
func (UnimplementedGenericServer) Search ¶
func (UnimplementedGenericServer) Search(context.Context, *SearchRequest) (*SearchResponse, error)
func (UnimplementedGenericServer) Update ¶
func (UnimplementedGenericServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
func (UnimplementedGenericServer) UpdateMulti ¶
func (UnimplementedGenericServer) UpdateMulti(context.Context, *UpdateMultiRequest) (*UpdateMultiResponse, error)
type UnimplementedNamespaceServer ¶
type UnimplementedNamespaceServer struct { }
UnimplementedNamespaceServer must be embedded to have forward compatible implementations.
func (UnimplementedNamespaceServer) Create ¶
func (UnimplementedNamespaceServer) Create(context.Context, *CreateNamespaceRequest) (*CreateNamespaceResponse, error)
func (UnimplementedNamespaceServer) Delete ¶
func (UnimplementedNamespaceServer) Delete(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
func (UnimplementedNamespaceServer) Get ¶
func (UnimplementedNamespaceServer) Get(context.Context, *GetNamespaceRequest) (*GetNamespaceResponse, error)
func (UnimplementedNamespaceServer) List ¶
func (UnimplementedNamespaceServer) List(context.Context, *ListNamespaceRequest) (*ListNamespaceResponse, error)
func (UnimplementedNamespaceServer) Update ¶
func (UnimplementedNamespaceServer) Update(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)
type UnimplementedRecordServer ¶
type UnimplementedRecordServer struct { }
UnimplementedRecordServer must be embedded to have forward compatible implementations.
func (UnimplementedRecordServer) Apply ¶
func (UnimplementedRecordServer) Apply(context.Context, *ApplyRecordRequest) (*ApplyRecordResponse, error)
func (UnimplementedRecordServer) Create ¶
func (UnimplementedRecordServer) Create(context.Context, *CreateRecordRequest) (*CreateRecordResponse, error)
func (UnimplementedRecordServer) Delete ¶
func (UnimplementedRecordServer) Delete(context.Context, *DeleteRecordRequest) (*DeleteRecordResponse, error)
func (UnimplementedRecordServer) Get ¶
func (UnimplementedRecordServer) Get(context.Context, *GetRecordRequest) (*GetRecordResponse, error)
func (UnimplementedRecordServer) List ¶
func (UnimplementedRecordServer) List(context.Context, *ListRecordRequest) (*ListRecordResponse, error)
func (UnimplementedRecordServer) ReadStream ¶
func (UnimplementedRecordServer) ReadStream(*ReadStreamRequest, Record_ReadStreamServer) error
func (UnimplementedRecordServer) Search ¶
func (UnimplementedRecordServer) Search(context.Context, *SearchRecordRequest) (*SearchRecordResponse, error)
func (UnimplementedRecordServer) Update ¶
func (UnimplementedRecordServer) Update(context.Context, *UpdateRecordRequest) (*UpdateRecordResponse, error)
func (UnimplementedRecordServer) UpdateMulti ¶
func (UnimplementedRecordServer) UpdateMulti(context.Context, *UpdateMultiRecordRequest) (*UpdateMultiRecordResponse, error)
func (UnimplementedRecordServer) WriteStream ¶
func (UnimplementedRecordServer) WriteStream(Record_WriteStreamServer) error
type UnimplementedResourceServer ¶
type UnimplementedResourceServer struct { }
UnimplementedResourceServer must be embedded to have forward compatible implementations.
func (UnimplementedResourceServer) Create ¶
func (UnimplementedResourceServer) Create(context.Context, *CreateResourceRequest) (*CreateResourceResponse, error)
func (UnimplementedResourceServer) Delete ¶
func (UnimplementedResourceServer) Delete(context.Context, *DeleteResourceRequest) (*DeleteResourceResponse, error)
func (UnimplementedResourceServer) Get ¶
func (UnimplementedResourceServer) Get(context.Context, *GetResourceRequest) (*GetResourceResponse, error)
func (UnimplementedResourceServer) GetByName ¶
func (UnimplementedResourceServer) GetByName(context.Context, *GetResourceByNameRequest) (*GetResourceByNameResponse, error)
func (UnimplementedResourceServer) GetSystemResource ¶
func (UnimplementedResourceServer) GetSystemResource(context.Context, *GetSystemResourceRequest) (*GetSystemResourceResponse, error)
func (UnimplementedResourceServer) List ¶
func (UnimplementedResourceServer) List(context.Context, *ListResourceRequest) (*ListResourceResponse, error)
func (UnimplementedResourceServer) PrepareResourceMigrationPlan ¶
func (UnimplementedResourceServer) PrepareResourceMigrationPlan(context.Context, *PrepareResourceMigrationPlanRequest) (*PrepareResourceMigrationPlanResponse, error)
func (UnimplementedResourceServer) Update ¶
func (UnimplementedResourceServer) Update(context.Context, *UpdateResourceRequest) (*UpdateResourceResponse, error)
type UnimplementedUserServer ¶
type UnimplementedUserServer struct { }
UnimplementedUserServer must be embedded to have forward compatible implementations.
func (UnimplementedUserServer) Create ¶
func (UnimplementedUserServer) Create(context.Context, *CreateUserRequest) (*CreateUserResponse, error)
func (UnimplementedUserServer) Delete ¶
func (UnimplementedUserServer) Delete(context.Context, *DeleteUserRequest) (*DeleteUserResponse, error)
func (UnimplementedUserServer) Get ¶
func (UnimplementedUserServer) Get(context.Context, *GetUserRequest) (*GetUserResponse, error)
func (UnimplementedUserServer) List ¶
func (UnimplementedUserServer) List(context.Context, *ListUserRequest) (*ListUserResponse, error)
func (UnimplementedUserServer) Update ¶
func (UnimplementedUserServer) Update(context.Context, *UpdateUserRequest) (*UpdateUserResponse, error)
type UnimplementedWatchServer ¶
type UnimplementedWatchServer struct { }
UnimplementedWatchServer must be embedded to have forward compatible implementations.
func (UnimplementedWatchServer) Watch ¶
func (UnimplementedWatchServer) Watch(*WatchRequest, Watch_WatchServer) error
type UnsafeAuthenticationServer ¶
type UnsafeAuthenticationServer interface {
// contains filtered or unexported methods
}
UnsafeAuthenticationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AuthenticationServer will result in compilation errors.
type UnsafeDataSourceServer ¶
type UnsafeDataSourceServer interface {
// contains filtered or unexported methods
}
UnsafeDataSourceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataSourceServer will result in compilation errors.
type UnsafeExtensionServer ¶
type UnsafeExtensionServer interface {
// contains filtered or unexported methods
}
UnsafeExtensionServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExtensionServer will result in compilation errors.
type UnsafeGenericServer ¶
type UnsafeGenericServer interface {
// contains filtered or unexported methods
}
UnsafeGenericServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GenericServer will result in compilation errors.
type UnsafeNamespaceServer ¶
type UnsafeNamespaceServer interface {
// contains filtered or unexported methods
}
UnsafeNamespaceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NamespaceServer will result in compilation errors.
type UnsafeRecordServer ¶
type UnsafeRecordServer interface {
// contains filtered or unexported methods
}
UnsafeRecordServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RecordServer will result in compilation errors.
type UnsafeResourceServer ¶
type UnsafeResourceServer interface {
// contains filtered or unexported methods
}
UnsafeResourceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ResourceServer will result in compilation errors.
type UnsafeUserServer ¶
type UnsafeUserServer interface {
// contains filtered or unexported methods
}
UnsafeUserServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UserServer will result in compilation errors.
type UnsafeWatchServer ¶
type UnsafeWatchServer interface {
// contains filtered or unexported methods
}
UnsafeWatchServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WatchServer will result in compilation errors.
type UpdateDataSourceRequest ¶
type UpdateDataSourceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` DataSources []*model.DataSource `protobuf:"bytes,2,rep,name=dataSources,proto3" json:"dataSources,omitempty"` // contains filtered or unexported fields }
func (*UpdateDataSourceRequest) Descriptor
deprecated
func (*UpdateDataSourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDataSourceRequest.ProtoReflect.Descriptor instead.
func (*UpdateDataSourceRequest) GetDataSources ¶
func (x *UpdateDataSourceRequest) GetDataSources() []*model.DataSource
func (*UpdateDataSourceRequest) GetToken ¶
func (x *UpdateDataSourceRequest) GetToken() string
func (*UpdateDataSourceRequest) ProtoMessage ¶
func (*UpdateDataSourceRequest) ProtoMessage()
func (*UpdateDataSourceRequest) ProtoReflect ¶
func (x *UpdateDataSourceRequest) ProtoReflect() protoreflect.Message
func (*UpdateDataSourceRequest) Reset ¶
func (x *UpdateDataSourceRequest) Reset()
func (*UpdateDataSourceRequest) String ¶
func (x *UpdateDataSourceRequest) String() string
type UpdateDataSourceResponse ¶
type UpdateDataSourceResponse struct { DataSources []*model.DataSource `protobuf:"bytes,1,rep,name=dataSources,proto3" json:"dataSources,omitempty"` // contains filtered or unexported fields }
func (*UpdateDataSourceResponse) Descriptor
deprecated
func (*UpdateDataSourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDataSourceResponse.ProtoReflect.Descriptor instead.
func (*UpdateDataSourceResponse) GetDataSources ¶
func (x *UpdateDataSourceResponse) GetDataSources() []*model.DataSource
func (*UpdateDataSourceResponse) ProtoMessage ¶
func (*UpdateDataSourceResponse) ProtoMessage()
func (*UpdateDataSourceResponse) ProtoReflect ¶
func (x *UpdateDataSourceResponse) ProtoReflect() protoreflect.Message
func (*UpdateDataSourceResponse) Reset ¶
func (x *UpdateDataSourceResponse) Reset()
func (*UpdateDataSourceResponse) String ¶
func (x *UpdateDataSourceResponse) String() string
type UpdateExtensionRequest ¶
type UpdateExtensionRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Extensions []*model.Extension `protobuf:"bytes,2,rep,name=extensions,proto3" json:"extensions,omitempty"` // contains filtered or unexported fields }
func (*UpdateExtensionRequest) Descriptor
deprecated
func (*UpdateExtensionRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateExtensionRequest.ProtoReflect.Descriptor instead.
func (*UpdateExtensionRequest) GetExtensions ¶
func (x *UpdateExtensionRequest) GetExtensions() []*model.Extension
func (*UpdateExtensionRequest) GetToken ¶
func (x *UpdateExtensionRequest) GetToken() string
func (*UpdateExtensionRequest) ProtoMessage ¶
func (*UpdateExtensionRequest) ProtoMessage()
func (*UpdateExtensionRequest) ProtoReflect ¶
func (x *UpdateExtensionRequest) ProtoReflect() protoreflect.Message
func (*UpdateExtensionRequest) Reset ¶
func (x *UpdateExtensionRequest) Reset()
func (*UpdateExtensionRequest) String ¶
func (x *UpdateExtensionRequest) String() string
type UpdateExtensionResponse ¶
type UpdateExtensionResponse struct { Extensions []*model.Extension `protobuf:"bytes,1,rep,name=extensions,proto3" json:"extensions,omitempty"` // contains filtered or unexported fields }
func (*UpdateExtensionResponse) Descriptor
deprecated
func (*UpdateExtensionResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateExtensionResponse.ProtoReflect.Descriptor instead.
func (*UpdateExtensionResponse) GetExtensions ¶
func (x *UpdateExtensionResponse) GetExtensions() []*model.Extension
func (*UpdateExtensionResponse) ProtoMessage ¶
func (*UpdateExtensionResponse) ProtoMessage()
func (*UpdateExtensionResponse) ProtoReflect ¶
func (x *UpdateExtensionResponse) ProtoReflect() protoreflect.Message
func (*UpdateExtensionResponse) Reset ¶
func (x *UpdateExtensionResponse) Reset()
func (*UpdateExtensionResponse) String ¶
func (x *UpdateExtensionResponse) String() string
type UpdateMultiRecordRequest ¶
type UpdateMultiRecordRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Query *model.BooleanExpression `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"` Properties map[string]*structpb.Value `` /* 161-byte string literal not displayed */ Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*UpdateMultiRecordRequest) Descriptor
deprecated
func (*UpdateMultiRecordRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateMultiRecordRequest.ProtoReflect.Descriptor instead.
func (*UpdateMultiRecordRequest) GetAnnotations ¶
func (x *UpdateMultiRecordRequest) GetAnnotations() map[string]string
func (*UpdateMultiRecordRequest) GetNamespace ¶
func (x *UpdateMultiRecordRequest) GetNamespace() string
func (*UpdateMultiRecordRequest) GetProperties ¶
func (x *UpdateMultiRecordRequest) GetProperties() map[string]*structpb.Value
func (*UpdateMultiRecordRequest) GetQuery ¶
func (x *UpdateMultiRecordRequest) GetQuery() *model.BooleanExpression
func (*UpdateMultiRecordRequest) GetResource ¶
func (x *UpdateMultiRecordRequest) GetResource() string
func (*UpdateMultiRecordRequest) GetToken ¶
func (x *UpdateMultiRecordRequest) GetToken() string
func (*UpdateMultiRecordRequest) ProtoMessage ¶
func (*UpdateMultiRecordRequest) ProtoMessage()
func (*UpdateMultiRecordRequest) ProtoReflect ¶
func (x *UpdateMultiRecordRequest) ProtoReflect() protoreflect.Message
func (*UpdateMultiRecordRequest) Reset ¶
func (x *UpdateMultiRecordRequest) Reset()
func (*UpdateMultiRecordRequest) String ¶
func (x *UpdateMultiRecordRequest) String() string
type UpdateMultiRecordResponse ¶
type UpdateMultiRecordResponse struct { Record *model.Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` // Rest Only Records []*model.Record `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"` // contains filtered or unexported fields }
func (*UpdateMultiRecordResponse) Descriptor
deprecated
func (*UpdateMultiRecordResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateMultiRecordResponse.ProtoReflect.Descriptor instead.
func (*UpdateMultiRecordResponse) GetRecord ¶
func (x *UpdateMultiRecordResponse) GetRecord() *model.Record
func (*UpdateMultiRecordResponse) GetRecords ¶
func (x *UpdateMultiRecordResponse) GetRecords() []*model.Record
func (*UpdateMultiRecordResponse) ProtoMessage ¶
func (*UpdateMultiRecordResponse) ProtoMessage()
func (*UpdateMultiRecordResponse) ProtoReflect ¶
func (x *UpdateMultiRecordResponse) ProtoReflect() protoreflect.Message
func (*UpdateMultiRecordResponse) Reset ¶
func (x *UpdateMultiRecordResponse) Reset()
func (*UpdateMultiRecordResponse) String ¶
func (x *UpdateMultiRecordResponse) String() string
type UpdateMultiRequest ¶
type UpdateMultiRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Query *model.BooleanExpression `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"` Properties map[string]*structpb.Value `` /* 161-byte string literal not displayed */ Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*UpdateMultiRequest) Descriptor
deprecated
func (*UpdateMultiRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateMultiRequest.ProtoReflect.Descriptor instead.
func (*UpdateMultiRequest) GetAnnotations ¶
func (x *UpdateMultiRequest) GetAnnotations() map[string]string
func (*UpdateMultiRequest) GetNamespace ¶
func (x *UpdateMultiRequest) GetNamespace() string
func (*UpdateMultiRequest) GetProperties ¶
func (x *UpdateMultiRequest) GetProperties() map[string]*structpb.Value
func (*UpdateMultiRequest) GetQuery ¶
func (x *UpdateMultiRequest) GetQuery() *model.BooleanExpression
func (*UpdateMultiRequest) GetResource ¶
func (x *UpdateMultiRequest) GetResource() string
func (*UpdateMultiRequest) GetToken ¶
func (x *UpdateMultiRequest) GetToken() string
func (*UpdateMultiRequest) ProtoMessage ¶
func (*UpdateMultiRequest) ProtoMessage()
func (*UpdateMultiRequest) ProtoReflect ¶
func (x *UpdateMultiRequest) ProtoReflect() protoreflect.Message
func (*UpdateMultiRequest) Reset ¶
func (x *UpdateMultiRequest) Reset()
func (*UpdateMultiRequest) String ¶
func (x *UpdateMultiRequest) String() string
type UpdateMultiResponse ¶
type UpdateMultiResponse struct { Items []*anypb.Any `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*UpdateMultiResponse) Descriptor
deprecated
func (*UpdateMultiResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateMultiResponse.ProtoReflect.Descriptor instead.
func (*UpdateMultiResponse) GetItems ¶
func (x *UpdateMultiResponse) GetItems() []*anypb.Any
func (*UpdateMultiResponse) ProtoMessage ¶
func (*UpdateMultiResponse) ProtoMessage()
func (*UpdateMultiResponse) ProtoReflect ¶
func (x *UpdateMultiResponse) ProtoReflect() protoreflect.Message
func (*UpdateMultiResponse) Reset ¶
func (x *UpdateMultiResponse) Reset()
func (*UpdateMultiResponse) String ¶
func (x *UpdateMultiResponse) String() string
type UpdateNamespaceRequest ¶
type UpdateNamespaceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespaces []*model.Namespace `protobuf:"bytes,2,rep,name=Namespaces,proto3" json:"Namespaces,omitempty"` // contains filtered or unexported fields }
func (*UpdateNamespaceRequest) Descriptor
deprecated
func (*UpdateNamespaceRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateNamespaceRequest.ProtoReflect.Descriptor instead.
func (*UpdateNamespaceRequest) GetNamespaces ¶
func (x *UpdateNamespaceRequest) GetNamespaces() []*model.Namespace
func (*UpdateNamespaceRequest) GetToken ¶
func (x *UpdateNamespaceRequest) GetToken() string
func (*UpdateNamespaceRequest) ProtoMessage ¶
func (*UpdateNamespaceRequest) ProtoMessage()
func (*UpdateNamespaceRequest) ProtoReflect ¶
func (x *UpdateNamespaceRequest) ProtoReflect() protoreflect.Message
func (*UpdateNamespaceRequest) Reset ¶
func (x *UpdateNamespaceRequest) Reset()
func (*UpdateNamespaceRequest) String ¶
func (x *UpdateNamespaceRequest) String() string
type UpdateNamespaceResponse ¶
type UpdateNamespaceResponse struct { Namespaces []*model.Namespace `protobuf:"bytes,1,rep,name=Namespaces,proto3" json:"Namespaces,omitempty"` // contains filtered or unexported fields }
func (*UpdateNamespaceResponse) Descriptor
deprecated
func (*UpdateNamespaceResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateNamespaceResponse.ProtoReflect.Descriptor instead.
func (*UpdateNamespaceResponse) GetNamespaces ¶
func (x *UpdateNamespaceResponse) GetNamespaces() []*model.Namespace
func (*UpdateNamespaceResponse) ProtoMessage ¶
func (*UpdateNamespaceResponse) ProtoMessage()
func (*UpdateNamespaceResponse) ProtoReflect ¶
func (x *UpdateNamespaceResponse) ProtoReflect() protoreflect.Message
func (*UpdateNamespaceResponse) Reset ¶
func (x *UpdateNamespaceResponse) Reset()
func (*UpdateNamespaceResponse) String ¶
func (x *UpdateNamespaceResponse) String() string
type UpdateRecordRequest ¶
type UpdateRecordRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Record *model.Record `protobuf:"bytes,4,opt,name=record,proto3" json:"record,omitempty"` // Rest Only Records []*model.Record `protobuf:"bytes,5,rep,name=records,proto3" json:"records,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*UpdateRecordRequest) Descriptor
deprecated
func (*UpdateRecordRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRecordRequest.ProtoReflect.Descriptor instead.
func (*UpdateRecordRequest) GetAnnotations ¶
func (x *UpdateRecordRequest) GetAnnotations() map[string]string
func (*UpdateRecordRequest) GetNamespace ¶
func (x *UpdateRecordRequest) GetNamespace() string
func (*UpdateRecordRequest) GetRecord ¶
func (x *UpdateRecordRequest) GetRecord() *model.Record
func (*UpdateRecordRequest) GetRecords ¶
func (x *UpdateRecordRequest) GetRecords() []*model.Record
func (*UpdateRecordRequest) GetResource ¶
func (x *UpdateRecordRequest) GetResource() string
func (*UpdateRecordRequest) GetToken ¶
func (x *UpdateRecordRequest) GetToken() string
func (*UpdateRecordRequest) ProtoMessage ¶
func (*UpdateRecordRequest) ProtoMessage()
func (*UpdateRecordRequest) ProtoReflect ¶
func (x *UpdateRecordRequest) ProtoReflect() protoreflect.Message
func (*UpdateRecordRequest) Reset ¶
func (x *UpdateRecordRequest) Reset()
func (*UpdateRecordRequest) String ¶
func (x *UpdateRecordRequest) String() string
type UpdateRecordResponse ¶
type UpdateRecordResponse struct { Record *model.Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` // Rest Only Records []*model.Record `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"` // contains filtered or unexported fields }
func (*UpdateRecordResponse) Descriptor
deprecated
func (*UpdateRecordResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRecordResponse.ProtoReflect.Descriptor instead.
func (*UpdateRecordResponse) GetRecord ¶
func (x *UpdateRecordResponse) GetRecord() *model.Record
func (*UpdateRecordResponse) GetRecords ¶
func (x *UpdateRecordResponse) GetRecords() []*model.Record
func (*UpdateRecordResponse) ProtoMessage ¶
func (*UpdateRecordResponse) ProtoMessage()
func (*UpdateRecordResponse) ProtoReflect ¶
func (x *UpdateRecordResponse) ProtoReflect() protoreflect.Message
func (*UpdateRecordResponse) Reset ¶
func (x *UpdateRecordResponse) Reset()
func (*UpdateRecordResponse) String ¶
func (x *UpdateRecordResponse) String() string
type UpdateRequest ¶
type UpdateRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` Items []*anypb.Any `protobuf:"bytes,4,rep,name=items,proto3" json:"items,omitempty"` CheckVersion bool `protobuf:"varint,5,opt,name=checkVersion,proto3" json:"checkVersion,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*UpdateRequest) Descriptor
deprecated
func (*UpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.
func (*UpdateRequest) GetAnnotations ¶
func (x *UpdateRequest) GetAnnotations() map[string]string
func (*UpdateRequest) GetCheckVersion ¶
func (x *UpdateRequest) GetCheckVersion() bool
func (*UpdateRequest) GetItems ¶
func (x *UpdateRequest) GetItems() []*anypb.Any
func (*UpdateRequest) GetNamespace ¶
func (x *UpdateRequest) GetNamespace() string
func (*UpdateRequest) GetResource ¶
func (x *UpdateRequest) GetResource() string
func (*UpdateRequest) GetToken ¶
func (x *UpdateRequest) GetToken() string
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) ProtoReflect ¶
func (x *UpdateRequest) ProtoReflect() protoreflect.Message
func (*UpdateRequest) Reset ¶
func (x *UpdateRequest) Reset()
func (*UpdateRequest) String ¶
func (x *UpdateRequest) String() string
type UpdateResourceRequest ¶
type UpdateResourceRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Resources []*model.Resource `protobuf:"bytes,2,rep,name=resources,proto3" json:"resources,omitempty"` // See the comments on CreateResourceRequest.doMigration DoMigration bool `protobuf:"varint,3,opt,name=doMigration,proto3" json:"doMigration,omitempty"` // See the comments on CreateResourceRequest.forceMigration ForceMigration bool `protobuf:"varint,4,opt,name=forceMigration,proto3" json:"forceMigration,omitempty"` Annotations map[string]string `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*UpdateResourceRequest) Descriptor
deprecated
func (*UpdateResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResourceRequest.ProtoReflect.Descriptor instead.
func (*UpdateResourceRequest) GetAnnotations ¶
func (x *UpdateResourceRequest) GetAnnotations() map[string]string
func (*UpdateResourceRequest) GetDoMigration ¶
func (x *UpdateResourceRequest) GetDoMigration() bool
func (*UpdateResourceRequest) GetForceMigration ¶
func (x *UpdateResourceRequest) GetForceMigration() bool
func (*UpdateResourceRequest) GetResources ¶
func (x *UpdateResourceRequest) GetResources() []*model.Resource
func (*UpdateResourceRequest) GetToken ¶
func (x *UpdateResourceRequest) GetToken() string
func (*UpdateResourceRequest) ProtoMessage ¶
func (*UpdateResourceRequest) ProtoMessage()
func (*UpdateResourceRequest) ProtoReflect ¶
func (x *UpdateResourceRequest) ProtoReflect() protoreflect.Message
func (*UpdateResourceRequest) Reset ¶
func (x *UpdateResourceRequest) Reset()
func (*UpdateResourceRequest) String ¶
func (x *UpdateResourceRequest) String() string
type UpdateResourceResponse ¶
type UpdateResourceResponse struct { Resources []*model.Resource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"` // contains filtered or unexported fields }
func (*UpdateResourceResponse) Descriptor
deprecated
func (*UpdateResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResourceResponse.ProtoReflect.Descriptor instead.
func (*UpdateResourceResponse) GetResources ¶
func (x *UpdateResourceResponse) GetResources() []*model.Resource
func (*UpdateResourceResponse) ProtoMessage ¶
func (*UpdateResourceResponse) ProtoMessage()
func (*UpdateResourceResponse) ProtoReflect ¶
func (x *UpdateResourceResponse) ProtoReflect() protoreflect.Message
func (*UpdateResourceResponse) Reset ¶
func (x *UpdateResourceResponse) Reset()
func (*UpdateResourceResponse) String ¶
func (x *UpdateResourceResponse) String() string
type UpdateResponse ¶
type UpdateResponse struct { Items []*anypb.Any `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*UpdateResponse) Descriptor
deprecated
func (*UpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.
func (*UpdateResponse) GetItems ¶
func (x *UpdateResponse) GetItems() []*anypb.Any
func (*UpdateResponse) ProtoMessage ¶
func (*UpdateResponse) ProtoMessage()
func (*UpdateResponse) ProtoReflect ¶
func (x *UpdateResponse) ProtoReflect() protoreflect.Message
func (*UpdateResponse) Reset ¶
func (x *UpdateResponse) Reset()
func (*UpdateResponse) String ¶
func (x *UpdateResponse) String() string
type UpdateUserRequest ¶
type UpdateUserRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` User *model.User `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` Users []*model.User `protobuf:"bytes,3,rep,name=users,proto3" json:"users,omitempty"` // contains filtered or unexported fields }
func (*UpdateUserRequest) Descriptor
deprecated
func (*UpdateUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateUserRequest.ProtoReflect.Descriptor instead.
func (*UpdateUserRequest) GetToken ¶
func (x *UpdateUserRequest) GetToken() string
func (*UpdateUserRequest) GetUser ¶
func (x *UpdateUserRequest) GetUser() *model.User
func (*UpdateUserRequest) GetUsers ¶
func (x *UpdateUserRequest) GetUsers() []*model.User
func (*UpdateUserRequest) ProtoMessage ¶
func (*UpdateUserRequest) ProtoMessage()
func (*UpdateUserRequest) ProtoReflect ¶
func (x *UpdateUserRequest) ProtoReflect() protoreflect.Message
func (*UpdateUserRequest) Reset ¶
func (x *UpdateUserRequest) Reset()
func (*UpdateUserRequest) String ¶
func (x *UpdateUserRequest) String() string
type UpdateUserResponse ¶
type UpdateUserResponse struct { User *model.User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Users []*model.User `protobuf:"bytes,2,rep,name=users,proto3" json:"users,omitempty"` // contains filtered or unexported fields }
func (*UpdateUserResponse) Descriptor
deprecated
func (*UpdateUserResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateUserResponse.ProtoReflect.Descriptor instead.
func (*UpdateUserResponse) GetUser ¶
func (x *UpdateUserResponse) GetUser() *model.User
func (*UpdateUserResponse) GetUsers ¶
func (x *UpdateUserResponse) GetUsers() []*model.User
func (*UpdateUserResponse) ProtoMessage ¶
func (*UpdateUserResponse) ProtoMessage()
func (*UpdateUserResponse) ProtoReflect ¶
func (x *UpdateUserResponse) ProtoReflect() protoreflect.Message
func (*UpdateUserResponse) Reset ¶
func (x *UpdateUserResponse) Reset()
func (*UpdateUserResponse) String ¶
func (x *UpdateUserResponse) String() string
type UserClient ¶
type UserClient interface { Create(ctx context.Context, in *CreateUserRequest, opts ...grpc.CallOption) (*CreateUserResponse, error) Update(ctx context.Context, in *UpdateUserRequest, opts ...grpc.CallOption) (*UpdateUserResponse, error) Delete(ctx context.Context, in *DeleteUserRequest, opts ...grpc.CallOption) (*DeleteUserResponse, error) List(ctx context.Context, in *ListUserRequest, opts ...grpc.CallOption) (*ListUserResponse, error) Get(ctx context.Context, in *GetUserRequest, opts ...grpc.CallOption) (*GetUserResponse, error) }
UserClient is the client API for User service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewUserClient ¶
func NewUserClient(cc grpc.ClientConnInterface) UserClient
type UserServer ¶
type UserServer interface { Create(context.Context, *CreateUserRequest) (*CreateUserResponse, error) Update(context.Context, *UpdateUserRequest) (*UpdateUserResponse, error) Delete(context.Context, *DeleteUserRequest) (*DeleteUserResponse, error) List(context.Context, *ListUserRequest) (*ListUserResponse, error) Get(context.Context, *GetUserRequest) (*GetUserResponse, error) // contains filtered or unexported methods }
UserServer is the server API for User service. All implementations must embed UnimplementedUserServer for forward compatibility
type WatchClient ¶
type WatchClient interface { // Sends a greeting Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Watch_WatchClient, error) }
WatchClient is the client API for Watch service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewWatchClient ¶
func NewWatchClient(cc grpc.ClientConnInterface) WatchClient
type WatchRequest ¶
type WatchRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Selector *model.EventSelector `protobuf:"bytes,2,opt,name=selector,proto3" json:"selector,omitempty"` // contains filtered or unexported fields }
func (*WatchRequest) Descriptor
deprecated
func (*WatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.
func (*WatchRequest) GetSelector ¶
func (x *WatchRequest) GetSelector() *model.EventSelector
func (*WatchRequest) GetToken ¶
func (x *WatchRequest) GetToken() string
func (*WatchRequest) ProtoMessage ¶
func (*WatchRequest) ProtoMessage()
func (*WatchRequest) ProtoReflect ¶
func (x *WatchRequest) ProtoReflect() protoreflect.Message
func (*WatchRequest) Reset ¶
func (x *WatchRequest) Reset()
func (*WatchRequest) String ¶
func (x *WatchRequest) String() string
type WatchServer ¶
type WatchServer interface { // Sends a greeting Watch(*WatchRequest, Watch_WatchServer) error // contains filtered or unexported methods }
WatchServer is the server API for Watch service. All implementations must embed UnimplementedWatchServer for forward compatibility
type Watch_WatchClient ¶
type Watch_WatchClient interface { Recv() (*model.Event, error) grpc.ClientStream }
type Watch_WatchServer ¶
type Watch_WatchServer interface { Send(*model.Event) error grpc.ServerStream }
type WriteStreamResponse ¶
type WriteStreamResponse struct { Success []bool `protobuf:"varint,1,rep,packed,name=success,proto3" json:"success,omitempty"` Created []bool `protobuf:"varint,2,rep,packed,name=created,proto3" json:"created,omitempty"` Updated []bool `protobuf:"varint,3,rep,packed,name=updated,proto3" json:"updated,omitempty"` // contains filtered or unexported fields }
func (*WriteStreamResponse) Descriptor
deprecated
func (*WriteStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use WriteStreamResponse.ProtoReflect.Descriptor instead.
func (*WriteStreamResponse) GetCreated ¶
func (x *WriteStreamResponse) GetCreated() []bool
func (*WriteStreamResponse) GetSuccess ¶
func (x *WriteStreamResponse) GetSuccess() []bool
func (*WriteStreamResponse) GetUpdated ¶
func (x *WriteStreamResponse) GetUpdated() []bool
func (*WriteStreamResponse) ProtoMessage ¶
func (*WriteStreamResponse) ProtoMessage()
func (*WriteStreamResponse) ProtoReflect ¶
func (x *WriteStreamResponse) ProtoReflect() protoreflect.Message
func (*WriteStreamResponse) Reset ¶
func (x *WriteStreamResponse) Reset()
func (*WriteStreamResponse) String ¶
func (x *WriteStreamResponse) String() string
Source Files ¶
- authentication.pb.go
- authentication.pb.gw.go
- authentication_grpc.pb.go
- data-source.pb.go
- data-source.pb.gw.go
- data-source_grpc.pb.go
- extension.pb.go
- extension.pb.gw.go
- extension_grpc.pb.go
- generic.pb.go
- generic_grpc.pb.go
- namespace.pb.go
- namespace.pb.gw.go
- namespace_grpc.pb.go
- openapi.pb.go
- record.pb.go
- record.pb.gw.go
- record_grpc.pb.go
- resource.pb.go
- resource.pb.gw.go
- resource_grpc.pb.go
- user.pb.go
- user.pb.gw.go
- user_grpc.pb.go
- watch.pb.go
- watch.pb.gw.go
- watch_grpc.pb.go