stub

package
v1.1.12 Latest Latest
Warning

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

 Go to latest Published: May 16, 2023 License: MIT Imports: 19 Imported by: 0

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

Constants

This section is empty.

Variables

View Source 
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)

View Source 
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)

View Source 
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)

View Source 
var File_stub_authentication_proto protoreflect.FileDescriptor
View Source 
var File_stub_data_source_proto protoreflect.FileDescriptor
View Source 
var File_stub_extension_proto protoreflect.FileDescriptor
View Source 
var File_stub_generic_proto protoreflect.FileDescriptor
View Source 
var File_stub_namespace_proto protoreflect.FileDescriptor
View Source 
var File_stub_openapi_proto protoreflect.FileDescriptor
View Source 
var File_stub_record_proto protoreflect.FileDescriptor
View Source 
var File_stub_resource_proto protoreflect.FileDescriptor
View Source 
var File_stub_user_proto protoreflect.FileDescriptor
View Source 
var File_stub_watch_proto protoreflect.FileDescriptor
View Source 
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)

View Source 
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)

View Source 
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)

View Source 
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)

View Source 
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)

View Source 
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 

func RegisterRecordHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

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 

func RegisterUserHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterUserHandler registers the http handlers for service User to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterUserHandlerClient 

func RegisterUserHandlerClient(ctx context.Context, mux *runtime.ServeMux, client UserClient) error

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 

func RegisterUserHandlerServer(ctx context.Context, mux *runtime.ServeMux, server UserServer) error

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 

func RegisterWatchHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

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

View all Source files

Directories

Path Synopsis
Package rest is a reverse proxy.
 Package rest is a reverse proxy.

Jump to

Keyboard shortcuts

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