stub

package
v1.3.85 Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2024 License: MIT Imports: 20 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.

Index

Constants

View Source 
const (
	Authentication_Authenticate_FullMethodName = "/stub.Authentication/Authenticate"
	Authentication_RenewToken_FullMethodName   = "/stub.Authentication/RenewToken"
)
View Source 
const (
	DataSource_Status_FullMethodName                    = "/stub.DataSource/Status"
	DataSource_ListEntities_FullMethodName              = "/stub.DataSource/ListEntities"
	DataSource_PrepareResourceFromEntity_FullMethodName = "/stub.DataSource/PrepareResourceFromEntity"
)
View Source 
const (
	EventChannel_Poll_FullMethodName  = "/stub.EventChannel/Poll"
	EventChannel_Write_FullMethodName = "/stub.EventChannel/Write"
)
View Source 
const (
	Record_Create_FullMethodName      = "/stub.Record/Create"
	Record_Update_FullMethodName      = "/stub.Record/Update"
	Record_Apply_FullMethodName       = "/stub.Record/Apply"
	Record_UpdateMulti_FullMethodName = "/stub.Record/UpdateMulti"
	Record_Delete_FullMethodName      = "/stub.Record/Delete"
	Record_List_FullMethodName        = "/stub.Record/List"
	Record_Search_FullMethodName      = "/stub.Record/Search"
	Record_ReadStream_FullMethodName  = "/stub.Record/ReadStream"
	Record_WriteStream_FullMethodName = "/stub.Record/WriteStream"
	Record_Get_FullMethodName         = "/stub.Record/Get"
)
View Source 
const (
	Resource_Create_FullMethodName                       = "/stub.Resource/Create"
	Resource_Update_FullMethodName                       = "/stub.Resource/Update"
	Resource_Delete_FullMethodName                       = "/stub.Resource/Delete"
	Resource_List_FullMethodName                         = "/stub.Resource/List"
	Resource_PrepareResourceMigrationPlan_FullMethodName = "/stub.Resource/PrepareResourceMigrationPlan"
	Resource_Get_FullMethodName                          = "/stub.Resource/Get"
	Resource_GetByName_FullMethodName                    = "/stub.Resource/GetByName"
	Resource_GetSystemResource_FullMethodName            = "/stub.Resource/GetSystemResource"
)
View Source 
const (
	Watch_Watch_FullMethodName = "/stub.Watch/Watch"
)

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: "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 EventChannel_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "stub.EventChannel",
	HandlerType: (*EventChannelServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Write",
			Handler:    _EventChannel_Write_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Poll",
			Handler:       _EventChannel_Poll_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "stub/event-channel.proto",
}

EventChannel_ServiceDesc is the grpc.ServiceDesc for EventChannel 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_event_channel_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_watch_proto protoreflect.FileDescriptor
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 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 RegisterEventChannelServer added in v1.1.48 

func RegisterEventChannelServer(s grpc.ServiceRegistrar, srv EventChannelServer)

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 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"` // username is the username
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` // password is the password
	// 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 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 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 DataSourceClient 

type DataSourceClient interface {
	// 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 {
	// 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 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 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 EventChannelClient added in v1.1.48 

type EventChannelClient interface {
	// Sends a greeting
	Poll(ctx context.Context, in *EventPollRequest, opts ...grpc.CallOption) (EventChannel_PollClient, error)
	Write(ctx context.Context, in *EventWriteRequest, opts ...grpc.CallOption) (*EventWriteResponse, error)
}

EventChannelClient is the client API for EventChannel 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 NewEventChannelClient added in v1.1.48 

func NewEventChannelClient(cc grpc.ClientConnInterface) EventChannelClient

type EventChannelServer added in v1.1.48 

type EventChannelServer interface {
	// Sends a greeting
	Poll(*EventPollRequest, EventChannel_PollServer) error
	Write(context.Context, *EventWriteRequest) (*EventWriteResponse, error)
	// contains filtered or unexported methods
}

EventChannelServer is the server API for EventChannel service. All implementations must embed UnimplementedEventChannelServer for forward compatibility

type EventChannel_PollClient added in v1.1.48 

type EventChannel_PollClient interface {
	Recv() (*model.Event, error)
	grpc.ClientStream
}

type EventChannel_PollServer added in v1.1.48 

type EventChannel_PollServer interface {
	Send(*model.Event) error
	grpc.ServerStream
}

type EventPollRequest added in v1.1.48 

type EventPollRequest struct {
	Token      string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	ChannelKey string `protobuf:"bytes,2,opt,name=channelKey,proto3" json:"channelKey,omitempty"`
	// contains filtered or unexported fields
}

func (*EventPollRequest) Descriptor deprecated added in v1.1.48 

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

Deprecated: Use EventPollRequest.ProtoReflect.Descriptor instead.

func (*EventPollRequest) GetChannelKey added in v1.1.48 

func (x *EventPollRequest) GetChannelKey() string

func (*EventPollRequest) GetToken added in v1.1.48 

func (x *EventPollRequest) GetToken() string

func (*EventPollRequest) ProtoMessage added in v1.1.48 

func (*EventPollRequest) ProtoMessage()

func (*EventPollRequest) ProtoReflect added in v1.1.48 

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

func (*EventPollRequest) Reset added in v1.1.48 

func (x *EventPollRequest) Reset()

func (*EventPollRequest) String added in v1.1.48 

func (x *EventPollRequest) String() string

type EventWriteRequest added in v1.1.48 

type EventWriteRequest struct {
	Token string       `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Event *model.Event `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*EventWriteRequest) Descriptor deprecated added in v1.1.48 

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

Deprecated: Use EventWriteRequest.ProtoReflect.Descriptor instead.

func (*EventWriteRequest) GetEvent added in v1.1.48 

func (x *EventWriteRequest) GetEvent() *model.Event

func (*EventWriteRequest) GetToken added in v1.1.48 

func (x *EventWriteRequest) GetToken() string

func (*EventWriteRequest) ProtoMessage added in v1.1.48 

func (*EventWriteRequest) ProtoMessage()

func (*EventWriteRequest) ProtoReflect added in v1.1.48 

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

func (*EventWriteRequest) Reset added in v1.1.48 

func (x *EventWriteRequest) Reset()

func (*EventWriteRequest) String added in v1.1.48 

func (x *EventWriteRequest) String() string

type EventWriteResponse added in v1.1.48 

type EventWriteResponse struct {
	Token      string       `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	ChannelKey string       `protobuf:"bytes,2,opt,name=channelKey,proto3" json:"channelKey,omitempty"`
	Event      *model.Event `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*EventWriteResponse) Descriptor deprecated added in v1.1.48 

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

Deprecated: Use EventWriteResponse.ProtoReflect.Descriptor instead.

func (*EventWriteResponse) GetChannelKey added in v1.1.48 

func (x *EventWriteResponse) GetChannelKey() string

func (*EventWriteResponse) GetEvent added in v1.1.48 

func (x *EventWriteResponse) GetEvent() *model.Event

func (*EventWriteResponse) GetToken added in v1.1.48 

func (x *EventWriteResponse) GetToken() string

func (*EventWriteResponse) ProtoMessage added in v1.1.48 

func (*EventWriteResponse) ProtoMessage()

func (*EventWriteResponse) ProtoReflect added in v1.1.48 

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

func (*EventWriteResponse) Reset added in v1.1.48 

func (x *EventWriteResponse) Reset()

func (*EventWriteResponse) String added in v1.1.48 

func (x *EventWriteResponse) 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 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 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 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 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 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 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"`
	Aggregation       *model.Aggregation       `protobuf:"bytes,9,opt,name=aggregation,proto3" json:"aggregation,omitempty"`
	Sorting           *model.Sorting           `protobuf:"bytes,10,opt,name=sorting,proto3" json:"sorting,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) GetAggregation added in v1.2.82 

func (x *SearchRecordRequest) GetAggregation() *model.Aggregation

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) GetSorting added in v1.3.15 

func (x *SearchRecordRequest) GetSorting() *model.Sorting

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

type UnimplementedEventChannelServer added in v1.1.48 

type UnimplementedEventChannelServer struct {
}

UnimplementedEventChannelServer must be embedded to have forward compatible implementations.

func (UnimplementedEventChannelServer) Poll added in v1.1.48 

func (UnimplementedEventChannelServer) Poll(*EventPollRequest, EventChannel_PollServer) error

func (UnimplementedEventChannelServer) Write added in v1.1.48 

func (UnimplementedEventChannelServer) Write(context.Context, *EventWriteRequest) (*EventWriteResponse, 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 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 UnsafeEventChannelServer added in v1.1.48 

type UnsafeEventChannelServer interface {
	// contains filtered or unexported methods
}

UnsafeEventChannelServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventChannelServer 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 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 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 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 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 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.