data_sources

package
v3.17.1 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DataSourcesService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.data_sources.v1alpha.DataSourcesService",
	HandlerType: (*DataSourcesServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListDataSources",
			Handler:    _DataSourcesService_ListDataSources_Handler,
		},
		{
			MethodName: "GetDataSource",
			Handler:    _DataSourcesService_GetDataSource_Handler,
		},
		{
			MethodName: "UpsertDataSource",
			Handler:    _DataSourcesService_UpsertDataSource_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "strmprivacy/api/data_sources/v1alpha/data_sources_v1alpha.proto",
}

DataSourcesService_ServiceDesc is the grpc.ServiceDesc for DataSourcesService 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_strmprivacy_api_data_sources_v1alpha_data_sources_v1alpha_proto protoreflect.FileDescriptor

Functions

func RegisterDataSourcesServiceServer 

func RegisterDataSourcesServiceServer(s grpc.ServiceRegistrar, srv DataSourcesServiceServer)

Types

type DataSourcesServiceClient 

type DataSourcesServiceClient interface {
	ListDataSources(ctx context.Context, in *ListDataSourcesRequest, opts ...grpc.CallOption) (*ListDataSourcesResponse, error)
	GetDataSource(ctx context.Context, in *GetDataSourceRequest, opts ...grpc.CallOption) (*GetDataSourceResponse, error)
	// Create or update a data source.
	UpsertDataSource(ctx context.Context, in *UpsertDataSourceRequest, opts ...grpc.CallOption) (*UpsertDataSourceResponse, error)
}

DataSourcesServiceClient is the client API for DataSourcesService 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 NewDataSourcesServiceClient 

func NewDataSourcesServiceClient(cc grpc.ClientConnInterface) DataSourcesServiceClient

type DataSourcesServiceServer 

type DataSourcesServiceServer interface {
	ListDataSources(context.Context, *ListDataSourcesRequest) (*ListDataSourcesResponse, error)
	GetDataSource(context.Context, *GetDataSourceRequest) (*GetDataSourceResponse, error)
	// Create or update a data source.
	UpsertDataSource(context.Context, *UpsertDataSourceRequest) (*UpsertDataSourceResponse, error)
}

DataSourcesServiceServer is the server API for DataSourcesService service. All implementations should embed UnimplementedDataSourcesServiceServer for forward compatibility

type GetDataSourceRequest 

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

func (*GetDataSourceRequest) Descriptor deprecated 

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

Deprecated: Use GetDataSourceRequest.ProtoReflect.Descriptor instead.

func (*GetDataSourceRequest) GetId 

func (x *GetDataSourceRequest) GetId() string

func (*GetDataSourceRequest) ProtoMessage 

func (*GetDataSourceRequest) ProtoMessage()

func (*GetDataSourceRequest) ProtoReflect 

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

func (*GetDataSourceRequest) Reset 

func (x *GetDataSourceRequest) Reset()

func (*GetDataSourceRequest) String 

func (x *GetDataSourceRequest) String() string

type GetDataSourceResponse 

type GetDataSourceResponse struct {
	DataSource *v1alpha.DataSource `protobuf:"bytes,1,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataSourceResponse) Descriptor deprecated 

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

Deprecated: Use GetDataSourceResponse.ProtoReflect.Descriptor instead.

func (*GetDataSourceResponse) GetDataSource 

func (x *GetDataSourceResponse) GetDataSource() *v1alpha.DataSource

func (*GetDataSourceResponse) ProtoMessage 

func (*GetDataSourceResponse) ProtoMessage()

func (*GetDataSourceResponse) ProtoReflect 

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

func (*GetDataSourceResponse) Reset 

func (x *GetDataSourceResponse) Reset()

func (*GetDataSourceResponse) String 

func (x *GetDataSourceResponse) String() string

type ListDataSourcesRequest 

type ListDataSourcesRequest struct {

	// The maximum number of data sources to return. The server may return fewer than
	// this number of data sources, even if there are more data sources available.
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from a previous `ListDataSources` call. Provide this to
	// retrieve the subsequent page.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

List all data sources for an organization. The organization is derived from the calling user.

func (*ListDataSourcesRequest) Descriptor deprecated 

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

Deprecated: Use ListDataSourcesRequest.ProtoReflect.Descriptor instead.

func (*ListDataSourcesRequest) GetPageSize 

func (x *ListDataSourcesRequest) GetPageSize() int32

func (*ListDataSourcesRequest) GetPageToken 

func (x *ListDataSourcesRequest) GetPageToken() string

func (*ListDataSourcesRequest) ProtoMessage 

func (*ListDataSourcesRequest) ProtoMessage()

func (*ListDataSourcesRequest) ProtoReflect 

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

func (*ListDataSourcesRequest) Reset 

func (x *ListDataSourcesRequest) Reset()

func (*ListDataSourcesRequest) String 

func (x *ListDataSourcesRequest) String() string

type ListDataSourcesResponse 

type ListDataSourcesResponse struct {

	// DataSources returned.
	DataSources []*v1alpha.DataSource `protobuf:"bytes,1,rep,name=data_sources,json=dataSources,proto3" json:"data_sources,omitempty"`
	// A token to retrieve the next page of results. Pass this value in the
	// `page_token` field in the subsequent call to `ListDataSources` method to
	// retrieve the next page of results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDataSourcesResponse) Descriptor deprecated 

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

Deprecated: Use ListDataSourcesResponse.ProtoReflect.Descriptor instead.

func (*ListDataSourcesResponse) GetDataSources 

func (x *ListDataSourcesResponse) GetDataSources() []*v1alpha.DataSource

func (*ListDataSourcesResponse) GetNextPageToken 

func (x *ListDataSourcesResponse) GetNextPageToken() string

func (*ListDataSourcesResponse) ProtoMessage 

func (*ListDataSourcesResponse) ProtoMessage()

func (*ListDataSourcesResponse) ProtoReflect 

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

func (*ListDataSourcesResponse) Reset 

func (x *ListDataSourcesResponse) Reset()

func (*ListDataSourcesResponse) String 

func (x *ListDataSourcesResponse) String() string

type UnimplementedDataSourcesServiceServer 

type UnimplementedDataSourcesServiceServer struct {
}

UnimplementedDataSourcesServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDataSourcesServiceServer) GetDataSource 

func (UnimplementedDataSourcesServiceServer) GetDataSource(context.Context, *GetDataSourceRequest) (*GetDataSourceResponse, error)

func (UnimplementedDataSourcesServiceServer) ListDataSources 

func (UnimplementedDataSourcesServiceServer) ListDataSources(context.Context, *ListDataSourcesRequest) (*ListDataSourcesResponse, error)

func (UnimplementedDataSourcesServiceServer) UpsertDataSource 

func (UnimplementedDataSourcesServiceServer) UpsertDataSource(context.Context, *UpsertDataSourceRequest) (*UpsertDataSourceResponse, error)

type UnsafeDataSourcesServiceServer 

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

UnsafeDataSourcesServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataSourcesServiceServer will result in compilation errors.

type UpsertDataSourceRequest 

type UpsertDataSourceRequest struct {
	DataSource *v1alpha.DataSource `protobuf:"bytes,1,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	// contains filtered or unexported fields
}

To create a data source, leave its id empty. To update a data source, set its id.

func (*UpsertDataSourceRequest) Descriptor deprecated 

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

Deprecated: Use UpsertDataSourceRequest.ProtoReflect.Descriptor instead.

func (*UpsertDataSourceRequest) GetDataSource 

func (x *UpsertDataSourceRequest) GetDataSource() *v1alpha.DataSource

func (*UpsertDataSourceRequest) ProtoMessage 

func (*UpsertDataSourceRequest) ProtoMessage()

func (*UpsertDataSourceRequest) ProtoReflect 

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

func (*UpsertDataSourceRequest) Reset 

func (x *UpsertDataSourceRequest) Reset()

func (*UpsertDataSourceRequest) String 

func (x *UpsertDataSourceRequest) String() string

type UpsertDataSourceResponse 

type UpsertDataSourceResponse struct {
	DataSource *v1alpha.DataSource `protobuf:"bytes,1,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertDataSourceResponse) Descriptor deprecated 

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

Deprecated: Use UpsertDataSourceResponse.ProtoReflect.Descriptor instead.

func (*UpsertDataSourceResponse) GetDataSource 

func (x *UpsertDataSourceResponse) GetDataSource() *v1alpha.DataSource

func (*UpsertDataSourceResponse) ProtoMessage 

func (*UpsertDataSourceResponse) ProtoMessage()

func (*UpsertDataSourceResponse) ProtoReflect 

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

func (*UpsertDataSourceResponse) Reset 

func (x *UpsertDataSourceResponse) Reset()

func (*UpsertDataSourceResponse) String 

func (x *UpsertDataSourceResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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