Documentation ¶
Index ¶
- Variables
- func RegisterDatasourceServer(s grpc.ServiceRegistrar, srv DatasourceServer)
- type AddRequest
- func (*AddRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddRequest) GetDataDomain() string
- func (x *AddRequest) GetDescription() string
- func (x *AddRequest) GetHost() string
- func (x *AddRequest) GetName() string
- func (x *AddRequest) GetPassword() string
- func (x *AddRequest) GetPort() string
- func (x *AddRequest) GetType() string
- func (x *AddRequest) GetUser() string
- func (x *AddRequest) GetVersion() string
- func (*AddRequest) ProtoMessage()
- func (x *AddRequest) ProtoReflect() protoreflect.Message
- func (x *AddRequest) Reset()
- func (x *AddRequest) String() string
- type AddResponse
- func (*AddResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AddResponse) GetMessage() string
- func (x *AddResponse) GetStatusCode() string
- func (*AddResponse) ProtoMessage()
- func (x *AddResponse) ProtoReflect() protoreflect.Message
- func (x *AddResponse) Reset()
- func (x *AddResponse) String() string
- type ApplyPolicyRequest
- func (*ApplyPolicyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyPolicyRequest) GetDsName() string
- func (x *ApplyPolicyRequest) GetId() []int64
- func (*ApplyPolicyRequest) ProtoMessage()
- func (x *ApplyPolicyRequest) ProtoReflect() protoreflect.Message
- func (x *ApplyPolicyRequest) Reset()
- func (x *ApplyPolicyRequest) String() string
- type ApplyPolicyResponse
- func (*ApplyPolicyResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyPolicyResponse) GetMessage() string
- func (x *ApplyPolicyResponse) GetStatusCode() string
- func (*ApplyPolicyResponse) ProtoMessage()
- func (x *ApplyPolicyResponse) ProtoReflect() protoreflect.Message
- func (x *ApplyPolicyResponse) Reset()
- func (x *ApplyPolicyResponse) String() string
- type DatasourceClient
- type DatasourceLogResponseStruct
- func (*DatasourceLogResponseStruct) Descriptor() ([]byte, []int)deprecated
- func (x *DatasourceLogResponseStruct) GetClasses() []string
- func (x *DatasourceLogResponseStruct) GetColumn() string
- func (x *DatasourceLogResponseStruct) GetDatabase() string
- func (x *DatasourceLogResponseStruct) GetDatasource() string
- func (x *DatasourceLogResponseStruct) GetLastScanTime() string
- func (x *DatasourceLogResponseStruct) GetTable() string
- func (x *DatasourceLogResponseStruct) GetTags() []string
- func (*DatasourceLogResponseStruct) ProtoMessage()
- func (x *DatasourceLogResponseStruct) ProtoReflect() protoreflect.Message
- func (x *DatasourceLogResponseStruct) Reset()
- func (x *DatasourceLogResponseStruct) String() string
- type DatasourceServer
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRequest) GetId() []string
- func (x *DeleteRequest) GetIsDeleteAll() bool
- func (*DeleteRequest) ProtoMessage()
- func (x *DeleteRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRequest) Reset()
- func (x *DeleteRequest) String() string
- type DeleteResponse
- func (*DeleteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteResponse) GetMessage() string
- func (x *DeleteResponse) GetStatusCode() string
- func (*DeleteResponse) ProtoMessage()
- func (x *DeleteResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteResponse) Reset()
- func (x *DeleteResponse) String() string
- type ListAll
- func (*ListAll) Descriptor() ([]byte, []int)deprecated
- func (x *ListAll) GetCreatedAt() string
- func (x *ListAll) GetDatadomain() string
- func (x *ListAll) GetDescription() string
- func (x *ListAll) GetId() string
- func (x *ListAll) GetKey() string
- func (x *ListAll) GetName() string
- func (x *ListAll) GetType() string
- func (x *ListAll) GetVersion() string
- func (*ListAll) ProtoMessage()
- func (x *ListAll) ProtoReflect() protoreflect.Message
- func (x *ListAll) Reset()
- func (x *ListAll) String() string
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListRequest) GetCount() bool
- func (x *ListRequest) GetDataDomain() []string
- func (x *ListRequest) GetFirst() int64
- func (x *ListRequest) GetLast() int64
- func (x *ListRequest) GetLimit() int64
- func (x *ListRequest) GetName() string
- func (x *ListRequest) GetType() []string
- func (*ListRequest) ProtoMessage()
- func (x *ListRequest) ProtoReflect() protoreflect.Message
- func (x *ListRequest) Reset()
- func (x *ListRequest) String() string
- type ListResponse
- func (*ListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListResponse) GetCount() int64
- func (x *ListResponse) GetListAllDatasources() []*ListAll
- func (*ListResponse) ProtoMessage()
- func (x *ListResponse) ProtoReflect() protoreflect.Message
- func (x *ListResponse) Reset()
- func (x *ListResponse) String() string
- type LogRequest
- func (*LogRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LogRequest) GetColumns() []string
- func (x *LogRequest) GetDatabase() string
- func (x *LogRequest) GetDatasource() string
- func (x *LogRequest) GetTable() string
- func (*LogRequest) ProtoMessage()
- func (x *LogRequest) ProtoReflect() protoreflect.Message
- func (x *LogRequest) Reset()
- func (x *LogRequest) String() string
- type LogResponse
- type RecommendedPolicyStruct
- func (*RecommendedPolicyStruct) Descriptor() ([]byte, []int)deprecated
- func (x *RecommendedPolicyStruct) GetPolicyId() int32
- func (x *RecommendedPolicyStruct) GetPolicyName() string
- func (*RecommendedPolicyStruct) ProtoMessage()
- func (x *RecommendedPolicyStruct) ProtoReflect() protoreflect.Message
- func (x *RecommendedPolicyStruct) Reset()
- func (x *RecommendedPolicyStruct) String() string
- type RecommendedpolicyRequest
- func (*RecommendedpolicyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RecommendedpolicyRequest) GetDsName() string
- func (*RecommendedpolicyRequest) ProtoMessage()
- func (x *RecommendedpolicyRequest) ProtoReflect() protoreflect.Message
- func (x *RecommendedpolicyRequest) Reset()
- func (x *RecommendedpolicyRequest) String() string
- type RecommendedpolicyResponse
- func (*RecommendedpolicyResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RecommendedpolicyResponse) GetPolicy() []*RecommendedPolicyStruct
- func (x *RecommendedpolicyResponse) GetStatusCode() string
- func (*RecommendedpolicyResponse) ProtoMessage()
- func (x *RecommendedpolicyResponse) ProtoReflect() protoreflect.Message
- func (x *RecommendedpolicyResponse) Reset()
- func (x *RecommendedpolicyResponse) String() string
- type ScanRequest
- type ScanResponse
- func (*ScanResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ScanResponse) GetMessage() string
- func (x *ScanResponse) GetStatusCode() string
- func (*ScanResponse) ProtoMessage()
- func (x *ScanResponse) ProtoReflect() protoreflect.Message
- func (x *ScanResponse) Reset()
- func (x *ScanResponse) String() string
- type StatusRequest
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatusResponse) GetDsStatus() string
- func (x *StatusResponse) GetStatusCode() string
- func (*StatusResponse) ProtoMessage()
- func (x *StatusResponse) ProtoReflect() protoreflect.Message
- func (x *StatusResponse) Reset()
- func (x *StatusResponse) String() string
- type UnimplementedDatasourceServer
- func (UnimplementedDatasourceServer) AddDatasource(context.Context, *AddRequest) (*AddResponse, error)
- func (UnimplementedDatasourceServer) ApplyPolicy(context.Context, *ApplyPolicyRequest) (*ApplyPolicyResponse, error)
- func (UnimplementedDatasourceServer) DeleteDatasource(context.Context, *DeleteRequest) (*DeleteResponse, error)
- func (UnimplementedDatasourceServer) GetRecommendedPolicy(context.Context, *RecommendedpolicyRequest) (*RecommendedpolicyResponse, error)
- func (UnimplementedDatasourceServer) GetStatus(context.Context, *StatusRequest) (*StatusResponse, error)
- func (UnimplementedDatasourceServer) ListDatasource(context.Context, *ListRequest) (*ListResponse, error)
- func (UnimplementedDatasourceServer) LogDatasource(context.Context, *LogRequest) (*LogResponse, error)
- func (UnimplementedDatasourceServer) Scan(context.Context, *ScanRequest) (*ScanResponse, error)
- type UnsafeDatasourceServer
Constants ¶
This section is empty.
Variables ¶
var Datasource_ServiceDesc = grpc.ServiceDesc{ ServiceName: "datasource.Datasource", HandlerType: (*DatasourceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "AddDatasource", Handler: _Datasource_AddDatasource_Handler, }, { MethodName: "ListDatasource", Handler: _Datasource_ListDatasource_Handler, }, { MethodName: "DeleteDatasource", Handler: _Datasource_DeleteDatasource_Handler, }, { MethodName: "LogDatasource", Handler: _Datasource_LogDatasource_Handler, }, { MethodName: "Scan", Handler: _Datasource_Scan_Handler, }, { MethodName: "GetStatus", Handler: _Datasource_GetStatus_Handler, }, { MethodName: "GetRecommendedPolicy", Handler: _Datasource_GetRecommendedPolicy_Handler, }, { MethodName: "ApplyPolicy", Handler: _Datasource_ApplyPolicy_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "datasource.proto", }
Datasource_ServiceDesc is the grpc.ServiceDesc for Datasource service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_datasource_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDatasourceServer ¶
func RegisterDatasourceServer(s grpc.ServiceRegistrar, srv DatasourceServer)
Types ¶
type AddRequest ¶
type AddRequest struct { DataDomain string `protobuf:"bytes,1,opt,name=data_domain,json=dataDomain,proto3" json:"data_domain,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"` Host string `protobuf:"bytes,7,opt,name=host,proto3" json:"host,omitempty"` Port string `protobuf:"bytes,8,opt,name=port,proto3" json:"port,omitempty"` User string `protobuf:"bytes,9,opt,name=user,proto3" json:"user,omitempty"` Password string `protobuf:"bytes,10,opt,name=password,proto3" json:"password,omitempty"` // contains filtered or unexported fields }
Request for Create Datasource
func (*AddRequest) Descriptor
deprecated
func (*AddRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddRequest.ProtoReflect.Descriptor instead.
func (*AddRequest) GetDataDomain ¶
func (x *AddRequest) GetDataDomain() string
func (*AddRequest) GetDescription ¶
func (x *AddRequest) GetDescription() string
func (*AddRequest) GetHost ¶
func (x *AddRequest) GetHost() string
func (*AddRequest) GetName ¶
func (x *AddRequest) GetName() string
func (*AddRequest) GetPassword ¶
func (x *AddRequest) GetPassword() string
func (*AddRequest) GetPort ¶
func (x *AddRequest) GetPort() string
func (*AddRequest) GetType ¶
func (x *AddRequest) GetType() string
func (*AddRequest) GetUser ¶
func (x *AddRequest) GetUser() string
func (*AddRequest) GetVersion ¶
func (x *AddRequest) GetVersion() string
func (*AddRequest) ProtoMessage ¶
func (*AddRequest) ProtoMessage()
func (*AddRequest) ProtoReflect ¶
func (x *AddRequest) ProtoReflect() protoreflect.Message
func (*AddRequest) Reset ¶
func (x *AddRequest) Reset()
func (*AddRequest) String ¶
func (x *AddRequest) String() string
type AddResponse ¶
type AddResponse struct { StatusCode string `protobuf:"bytes,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
addResponse - Response for add datasource
func (*AddResponse) Descriptor
deprecated
func (*AddResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddResponse.ProtoReflect.Descriptor instead.
func (*AddResponse) GetMessage ¶
func (x *AddResponse) GetMessage() string
func (*AddResponse) GetStatusCode ¶
func (x *AddResponse) GetStatusCode() string
func (*AddResponse) ProtoMessage ¶
func (*AddResponse) ProtoMessage()
func (*AddResponse) ProtoReflect ¶
func (x *AddResponse) ProtoReflect() protoreflect.Message
func (*AddResponse) Reset ¶
func (x *AddResponse) Reset()
func (*AddResponse) String ¶
func (x *AddResponse) String() string
type ApplyPolicyRequest ¶
type ApplyPolicyRequest struct { Id []int64 `protobuf:"varint,1,rep,packed,name=Id,proto3" json:"Id,omitempty"` DsName string `protobuf:"bytes,2,opt,name=dsName,proto3" json:"dsName,omitempty"` // contains filtered or unexported fields }
applyPolicyRequest - Request for Recommended Policy
func (*ApplyPolicyRequest) Descriptor
deprecated
func (*ApplyPolicyRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApplyPolicyRequest.ProtoReflect.Descriptor instead.
func (*ApplyPolicyRequest) GetDsName ¶
func (x *ApplyPolicyRequest) GetDsName() string
func (*ApplyPolicyRequest) GetId ¶
func (x *ApplyPolicyRequest) GetId() []int64
func (*ApplyPolicyRequest) ProtoMessage ¶
func (*ApplyPolicyRequest) ProtoMessage()
func (*ApplyPolicyRequest) ProtoReflect ¶
func (x *ApplyPolicyRequest) ProtoReflect() protoreflect.Message
func (*ApplyPolicyRequest) Reset ¶
func (x *ApplyPolicyRequest) Reset()
func (*ApplyPolicyRequest) String ¶
func (x *ApplyPolicyRequest) String() string
type ApplyPolicyResponse ¶
type ApplyPolicyResponse struct { StatusCode string `protobuf:"bytes,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
applyPolicyResponse - Response for Recommended Policy
func (*ApplyPolicyResponse) Descriptor
deprecated
func (*ApplyPolicyResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApplyPolicyResponse.ProtoReflect.Descriptor instead.
func (*ApplyPolicyResponse) GetMessage ¶
func (x *ApplyPolicyResponse) GetMessage() string
func (*ApplyPolicyResponse) GetStatusCode ¶
func (x *ApplyPolicyResponse) GetStatusCode() string
func (*ApplyPolicyResponse) ProtoMessage ¶
func (*ApplyPolicyResponse) ProtoMessage()
func (*ApplyPolicyResponse) ProtoReflect ¶
func (x *ApplyPolicyResponse) ProtoReflect() protoreflect.Message
func (*ApplyPolicyResponse) Reset ¶
func (x *ApplyPolicyResponse) Reset()
func (*ApplyPolicyResponse) String ¶
func (x *ApplyPolicyResponse) String() string
type DatasourceClient ¶
type DatasourceClient interface { AddDatasource(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error) ListDatasource(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) DeleteDatasource(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) LogDatasource(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (*LogResponse, error) Scan(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (*ScanResponse, error) GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error) GetRecommendedPolicy(ctx context.Context, in *RecommendedpolicyRequest, opts ...grpc.CallOption) (*RecommendedpolicyResponse, error) ApplyPolicy(ctx context.Context, in *ApplyPolicyRequest, opts ...grpc.CallOption) (*ApplyPolicyResponse, 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 DatasourceLogResponseStruct ¶
type DatasourceLogResponseStruct struct { Datasource string `protobuf:"bytes,1,opt,name=datasource,proto3" json:"datasource,omitempty"` Database string `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"` Table string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"` Column string `protobuf:"bytes,4,opt,name=column,proto3" json:"column,omitempty"` Tags []string `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"` Classes []string `protobuf:"bytes,6,rep,name=classes,proto3" json:"classes,omitempty"` LastScanTime string `protobuf:"bytes,7,opt,name=lastScanTime,proto3" json:"lastScanTime,omitempty"` // contains filtered or unexported fields }
datasource log Response Structure
func (*DatasourceLogResponseStruct) Descriptor
deprecated
func (*DatasourceLogResponseStruct) Descriptor() ([]byte, []int)
Deprecated: Use DatasourceLogResponseStruct.ProtoReflect.Descriptor instead.
func (*DatasourceLogResponseStruct) GetClasses ¶
func (x *DatasourceLogResponseStruct) GetClasses() []string
func (*DatasourceLogResponseStruct) GetColumn ¶
func (x *DatasourceLogResponseStruct) GetColumn() string
func (*DatasourceLogResponseStruct) GetDatabase ¶
func (x *DatasourceLogResponseStruct) GetDatabase() string
func (*DatasourceLogResponseStruct) GetDatasource ¶
func (x *DatasourceLogResponseStruct) GetDatasource() string
func (*DatasourceLogResponseStruct) GetLastScanTime ¶
func (x *DatasourceLogResponseStruct) GetLastScanTime() string
func (*DatasourceLogResponseStruct) GetTable ¶
func (x *DatasourceLogResponseStruct) GetTable() string
func (*DatasourceLogResponseStruct) GetTags ¶
func (x *DatasourceLogResponseStruct) GetTags() []string
func (*DatasourceLogResponseStruct) ProtoMessage ¶
func (*DatasourceLogResponseStruct) ProtoMessage()
func (*DatasourceLogResponseStruct) ProtoReflect ¶
func (x *DatasourceLogResponseStruct) ProtoReflect() protoreflect.Message
func (*DatasourceLogResponseStruct) Reset ¶
func (x *DatasourceLogResponseStruct) Reset()
func (*DatasourceLogResponseStruct) String ¶
func (x *DatasourceLogResponseStruct) String() string
type DatasourceServer ¶
type DatasourceServer interface { AddDatasource(context.Context, *AddRequest) (*AddResponse, error) ListDatasource(context.Context, *ListRequest) (*ListResponse, error) DeleteDatasource(context.Context, *DeleteRequest) (*DeleteResponse, error) LogDatasource(context.Context, *LogRequest) (*LogResponse, error) Scan(context.Context, *ScanRequest) (*ScanResponse, error) GetStatus(context.Context, *StatusRequest) (*StatusResponse, error) GetRecommendedPolicy(context.Context, *RecommendedpolicyRequest) (*RecommendedpolicyResponse, error) ApplyPolicy(context.Context, *ApplyPolicyRequest) (*ApplyPolicyResponse, error) // contains filtered or unexported methods }
DatasourceServer is the server API for Datasource service. All implementations must embed UnimplementedDatasourceServer for forward compatibility
type DeleteRequest ¶
type DeleteRequest struct { Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"` IsDeleteAll bool `protobuf:"varint,2,opt,name=isDeleteAll,proto3" json:"isDeleteAll,omitempty"` // contains filtered or unexported fields }
deleteRequest - Request for Delete Datasource
func (*DeleteRequest) Descriptor
deprecated
func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetId ¶
func (x *DeleteRequest) GetId() []string
func (*DeleteRequest) GetIsDeleteAll ¶
func (x *DeleteRequest) GetIsDeleteAll() bool
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶
func (x *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (x *DeleteRequest) String() string
type DeleteResponse ¶
type DeleteResponse struct { StatusCode string `protobuf:"bytes,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
deleteResponse - Response for delete datasource
func (*DeleteResponse) Descriptor
deprecated
func (*DeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.
func (*DeleteResponse) GetMessage ¶
func (x *DeleteResponse) GetMessage() string
func (*DeleteResponse) GetStatusCode ¶
func (x *DeleteResponse) GetStatusCode() string
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) ProtoReflect ¶
func (x *DeleteResponse) ProtoReflect() protoreflect.Message
func (*DeleteResponse) Reset ¶
func (x *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (x *DeleteResponse) String() string
type ListAll ¶
type ListAll struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Datadomain string `protobuf:"bytes,2,opt,name=datadomain,proto3" json:"datadomain,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` Version string `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"` Key string `protobuf:"bytes,7,opt,name=key,proto3" json:"key,omitempty"` CreatedAt string `protobuf:"bytes,8,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` // contains filtered or unexported fields }
func (*ListAll) Descriptor
deprecated
func (*ListAll) GetCreatedAt ¶
func (*ListAll) GetDatadomain ¶
func (*ListAll) GetDescription ¶
func (*ListAll) GetVersion ¶
func (*ListAll) ProtoMessage ¶
func (*ListAll) ProtoMessage()
func (*ListAll) ProtoReflect ¶
func (x *ListAll) ProtoReflect() protoreflect.Message
type ListRequest ¶
type ListRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` DataDomain []string `protobuf:"bytes,2,rep,name=data_domain,json=dataDomain,proto3" json:"data_domain,omitempty"` Type []string `protobuf:"bytes,3,rep,name=type,proto3" json:"type,omitempty"` First int64 `protobuf:"varint,4,opt,name=first,proto3" json:"first,omitempty"` Last int64 `protobuf:"varint,5,opt,name=last,proto3" json:"last,omitempty"` Limit int64 `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"` Count bool `protobuf:"varint,7,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
listRequest - Request for List Datasource
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetCount ¶
func (x *ListRequest) GetCount() bool
func (*ListRequest) GetDataDomain ¶
func (x *ListRequest) GetDataDomain() []string
func (*ListRequest) GetFirst ¶
func (x *ListRequest) GetFirst() int64
func (*ListRequest) GetLast ¶
func (x *ListRequest) GetLast() int64
func (*ListRequest) GetLimit ¶
func (x *ListRequest) GetLimit() int64
func (*ListRequest) GetName ¶
func (x *ListRequest) GetName() string
func (*ListRequest) GetType ¶
func (x *ListRequest) GetType() []string
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type ListResponse ¶
type ListResponse struct { ListAllDatasources []*ListAll `protobuf:"bytes,1,rep,name=list_all_datasources,json=listAllDatasources,proto3" json:"list_all_datasources,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
listResponse - Response for List Datasource
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetCount ¶
func (x *ListResponse) GetCount() int64
func (*ListResponse) GetListAllDatasources ¶
func (x *ListResponse) GetListAllDatasources() []*ListAll
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
type LogRequest ¶
type LogRequest struct { Datasource string `protobuf:"bytes,1,opt,name=datasource,proto3" json:"datasource,omitempty"` Database string `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"` Table string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"` Columns []string `protobuf:"bytes,4,rep,name=columns,proto3" json:"columns,omitempty"` // contains filtered or unexported fields }
logRequest - Request for datasource log
func (*LogRequest) Descriptor
deprecated
func (*LogRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.
func (*LogRequest) GetColumns ¶
func (x *LogRequest) GetColumns() []string
func (*LogRequest) GetDatabase ¶
func (x *LogRequest) GetDatabase() string
func (*LogRequest) GetDatasource ¶
func (x *LogRequest) GetDatasource() string
func (*LogRequest) GetTable ¶
func (x *LogRequest) GetTable() string
func (*LogRequest) ProtoMessage ¶
func (*LogRequest) ProtoMessage()
func (*LogRequest) ProtoReflect ¶
func (x *LogRequest) ProtoReflect() protoreflect.Message
func (*LogRequest) Reset ¶
func (x *LogRequest) Reset()
func (*LogRequest) String ¶
func (x *LogRequest) String() string
type LogResponse ¶
type LogResponse struct { DatasourceLog []*DatasourceLogResponseStruct `protobuf:"bytes,1,rep,name=datasourceLog,proto3" json:"datasourceLog,omitempty"` // contains filtered or unexported fields }
logResponse - Response for log datasource
func (*LogResponse) Descriptor
deprecated
func (*LogResponse) Descriptor() ([]byte, []int)
Deprecated: Use LogResponse.ProtoReflect.Descriptor instead.
func (*LogResponse) GetDatasourceLog ¶
func (x *LogResponse) GetDatasourceLog() []*DatasourceLogResponseStruct
func (*LogResponse) ProtoMessage ¶
func (*LogResponse) ProtoMessage()
func (*LogResponse) ProtoReflect ¶
func (x *LogResponse) ProtoReflect() protoreflect.Message
func (*LogResponse) Reset ¶
func (x *LogResponse) Reset()
func (*LogResponse) String ¶
func (x *LogResponse) String() string
type RecommendedPolicyStruct ¶
type RecommendedPolicyStruct struct { PolicyId int32 `protobuf:"varint,1,opt,name=policyId,proto3" json:"policyId,omitempty"` PolicyName string `protobuf:"bytes,2,opt,name=policyName,proto3" json:"policyName,omitempty"` // contains filtered or unexported fields }
recommendedPolicyStruct - Define Struc for Recommended Policy
func (*RecommendedPolicyStruct) Descriptor
deprecated
func (*RecommendedPolicyStruct) Descriptor() ([]byte, []int)
Deprecated: Use RecommendedPolicyStruct.ProtoReflect.Descriptor instead.
func (*RecommendedPolicyStruct) GetPolicyId ¶
func (x *RecommendedPolicyStruct) GetPolicyId() int32
func (*RecommendedPolicyStruct) GetPolicyName ¶
func (x *RecommendedPolicyStruct) GetPolicyName() string
func (*RecommendedPolicyStruct) ProtoMessage ¶
func (*RecommendedPolicyStruct) ProtoMessage()
func (*RecommendedPolicyStruct) ProtoReflect ¶
func (x *RecommendedPolicyStruct) ProtoReflect() protoreflect.Message
func (*RecommendedPolicyStruct) Reset ¶
func (x *RecommendedPolicyStruct) Reset()
func (*RecommendedPolicyStruct) String ¶
func (x *RecommendedPolicyStruct) String() string
type RecommendedpolicyRequest ¶
type RecommendedpolicyRequest struct { DsName string `protobuf:"bytes,1,opt,name=dsName,proto3" json:"dsName,omitempty"` // contains filtered or unexported fields }
recommendedpolicyRequest - Request for the Recommended Policy
func (*RecommendedpolicyRequest) Descriptor
deprecated
func (*RecommendedpolicyRequest) Descriptor() ([]byte, []int)
Deprecated: Use RecommendedpolicyRequest.ProtoReflect.Descriptor instead.
func (*RecommendedpolicyRequest) GetDsName ¶
func (x *RecommendedpolicyRequest) GetDsName() string
func (*RecommendedpolicyRequest) ProtoMessage ¶
func (*RecommendedpolicyRequest) ProtoMessage()
func (*RecommendedpolicyRequest) ProtoReflect ¶
func (x *RecommendedpolicyRequest) ProtoReflect() protoreflect.Message
func (*RecommendedpolicyRequest) Reset ¶
func (x *RecommendedpolicyRequest) Reset()
func (*RecommendedpolicyRequest) String ¶
func (x *RecommendedpolicyRequest) String() string
type RecommendedpolicyResponse ¶
type RecommendedpolicyResponse struct { StatusCode string `protobuf:"bytes,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"` Policy []*RecommendedPolicyStruct `protobuf:"bytes,2,rep,name=policy,proto3" json:"policy,omitempty"` // contains filtered or unexported fields }
recommendedpolicyResponse - Response for the Recommended Policy
func (*RecommendedpolicyResponse) Descriptor
deprecated
func (*RecommendedpolicyResponse) Descriptor() ([]byte, []int)
Deprecated: Use RecommendedpolicyResponse.ProtoReflect.Descriptor instead.
func (*RecommendedpolicyResponse) GetPolicy ¶
func (x *RecommendedpolicyResponse) GetPolicy() []*RecommendedPolicyStruct
func (*RecommendedpolicyResponse) GetStatusCode ¶
func (x *RecommendedpolicyResponse) GetStatusCode() string
func (*RecommendedpolicyResponse) ProtoMessage ¶
func (*RecommendedpolicyResponse) ProtoMessage()
func (*RecommendedpolicyResponse) ProtoReflect ¶
func (x *RecommendedpolicyResponse) ProtoReflect() protoreflect.Message
func (*RecommendedpolicyResponse) Reset ¶
func (x *RecommendedpolicyResponse) Reset()
func (*RecommendedpolicyResponse) String ¶
func (x *RecommendedpolicyResponse) String() string
type ScanRequest ¶
type ScanRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
scanRequest - Request for scan datasource
func (*ScanRequest) Descriptor
deprecated
func (*ScanRequest) Descriptor() ([]byte, []int)
Deprecated: Use ScanRequest.ProtoReflect.Descriptor instead.
func (*ScanRequest) GetName ¶
func (x *ScanRequest) GetName() string
func (*ScanRequest) ProtoMessage ¶
func (*ScanRequest) ProtoMessage()
func (*ScanRequest) ProtoReflect ¶
func (x *ScanRequest) ProtoReflect() protoreflect.Message
func (*ScanRequest) Reset ¶
func (x *ScanRequest) Reset()
func (*ScanRequest) String ¶
func (x *ScanRequest) String() string
type ScanResponse ¶
type ScanResponse struct { StatusCode string `protobuf:"bytes,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
scanResponse - Response for scan datasource
func (*ScanResponse) Descriptor
deprecated
func (*ScanResponse) Descriptor() ([]byte, []int)
Deprecated: Use ScanResponse.ProtoReflect.Descriptor instead.
func (*ScanResponse) GetMessage ¶
func (x *ScanResponse) GetMessage() string
func (*ScanResponse) GetStatusCode ¶
func (x *ScanResponse) GetStatusCode() string
func (*ScanResponse) ProtoMessage ¶
func (*ScanResponse) ProtoMessage()
func (*ScanResponse) ProtoReflect ¶
func (x *ScanResponse) ProtoReflect() protoreflect.Message
func (*ScanResponse) Reset ¶
func (x *ScanResponse) Reset()
func (*ScanResponse) String ¶
func (x *ScanResponse) String() string
type StatusRequest ¶
type StatusRequest struct { DsName string `protobuf:"bytes,1,opt,name=dsName,proto3" json:"dsName,omitempty"` // contains filtered or unexported fields }
statusRequest - Request to get status
func (*StatusRequest) Descriptor
deprecated
func (*StatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.
func (*StatusRequest) GetDsName ¶
func (x *StatusRequest) GetDsName() 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 { StatusCode string `protobuf:"bytes,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"` DsStatus string `protobuf:"bytes,2,opt,name=dsStatus,proto3" json:"dsStatus,omitempty"` // contains filtered or unexported fields }
statusResponse - Response for the status
func (*StatusResponse) Descriptor
deprecated
func (*StatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.
func (*StatusResponse) GetDsStatus ¶
func (x *StatusResponse) GetDsStatus() string
func (*StatusResponse) GetStatusCode ¶
func (x *StatusResponse) GetStatusCode() string
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 UnimplementedDatasourceServer ¶
type UnimplementedDatasourceServer struct { }
UnimplementedDatasourceServer must be embedded to have forward compatible implementations.
func (UnimplementedDatasourceServer) AddDatasource ¶
func (UnimplementedDatasourceServer) AddDatasource(context.Context, *AddRequest) (*AddResponse, error)
func (UnimplementedDatasourceServer) ApplyPolicy ¶
func (UnimplementedDatasourceServer) ApplyPolicy(context.Context, *ApplyPolicyRequest) (*ApplyPolicyResponse, error)
func (UnimplementedDatasourceServer) DeleteDatasource ¶
func (UnimplementedDatasourceServer) DeleteDatasource(context.Context, *DeleteRequest) (*DeleteResponse, error)
func (UnimplementedDatasourceServer) GetRecommendedPolicy ¶
func (UnimplementedDatasourceServer) GetRecommendedPolicy(context.Context, *RecommendedpolicyRequest) (*RecommendedpolicyResponse, error)
func (UnimplementedDatasourceServer) GetStatus ¶
func (UnimplementedDatasourceServer) GetStatus(context.Context, *StatusRequest) (*StatusResponse, error)
func (UnimplementedDatasourceServer) ListDatasource ¶
func (UnimplementedDatasourceServer) ListDatasource(context.Context, *ListRequest) (*ListResponse, error)
func (UnimplementedDatasourceServer) LogDatasource ¶
func (UnimplementedDatasourceServer) LogDatasource(context.Context, *LogRequest) (*LogResponse, error)
func (UnimplementedDatasourceServer) Scan ¶
func (UnimplementedDatasourceServer) Scan(context.Context, *ScanRequest) (*ScanResponse, error)
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.