agents

package
v3.9.0 Latest Latest
Warning

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

 Go to latest Published: Jul 19, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BatchExportersAgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.agents.v1.BatchExportersAgentService",
	HandlerType: (*BatchExportersAgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetDesiredBatchExporters",
			Handler:    _BatchExportersAgentService_GetDesiredBatchExporters_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "strmprivacy/api/agents/v1/batch_exporters_agent_v1.proto",
}

BatchExportersAgentService_ServiceDesc is the grpc.ServiceDesc for BatchExportersAgentService 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 BatchJobsAgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.agents.v1.BatchJobsAgentService",
	HandlerType: (*BatchJobsAgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetDesiredBatchJobs",
			Handler:    _BatchJobsAgentService_GetDesiredBatchJobs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "strmprivacy/api/agents/v1/batch_jobs_agent_v1.proto",
}

BatchJobsAgentService_ServiceDesc is the grpc.ServiceDesc for BatchJobsAgentService 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 DataConnectorsAgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.agents.v1.DataConnectorsAgentService",
	HandlerType: (*DataConnectorsAgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetDesiredDataConnectors",
			Handler:    _DataConnectorsAgentService_GetDesiredDataConnectors_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "strmprivacy/api/agents/v1/data_connector_agent_v1.proto",
}

DataConnectorsAgentService_ServiceDesc is the grpc.ServiceDesc for DataConnectorsAgentService 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_agents_v1_batch_exporters_agent_v1_proto protoreflect.FileDescriptor
View Source 
var File_strmprivacy_api_agents_v1_batch_jobs_agent_v1_proto protoreflect.FileDescriptor
View Source 
var File_strmprivacy_api_agents_v1_data_connector_agent_v1_proto protoreflect.FileDescriptor
View Source 
var File_strmprivacy_api_agents_v1_streams_agent_v1_proto protoreflect.FileDescriptor
View Source 
var StreamsAgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.agents.v1.StreamsAgentService",
	HandlerType: (*StreamsAgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetStreams",
			Handler:    _StreamsAgentService_GetStreams_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "strmprivacy/api/agents/v1/streams_agent_v1.proto",
}

StreamsAgentService_ServiceDesc is the grpc.ServiceDesc for StreamsAgentService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterBatchExportersAgentServiceServer 

func RegisterBatchExportersAgentServiceServer(s grpc.ServiceRegistrar, srv BatchExportersAgentServiceServer)

func RegisterBatchJobsAgentServiceServer 

func RegisterBatchJobsAgentServiceServer(s grpc.ServiceRegistrar, srv BatchJobsAgentServiceServer)

func RegisterDataConnectorsAgentServiceServer 

func RegisterDataConnectorsAgentServiceServer(s grpc.ServiceRegistrar, srv DataConnectorsAgentServiceServer)

func RegisterStreamsAgentServiceServer 

func RegisterStreamsAgentServiceServer(s grpc.ServiceRegistrar, srv StreamsAgentServiceServer)

Types

type BatchExportersAgentServiceClient 

type BatchExportersAgentServiceClient interface {
	GetDesiredBatchExporters(ctx context.Context, in *GetDesiredBatchExportersRequest, opts ...grpc.CallOption) (*GetDesiredBatchExportersResponse, error)
}

BatchExportersAgentServiceClient is the client API for BatchExportersAgentService 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 NewBatchExportersAgentServiceClient 

func NewBatchExportersAgentServiceClient(cc grpc.ClientConnInterface) BatchExportersAgentServiceClient

type BatchExportersAgentServiceServer 

type BatchExportersAgentServiceServer interface {
	GetDesiredBatchExporters(context.Context, *GetDesiredBatchExportersRequest) (*GetDesiredBatchExportersResponse, error)
}

BatchExportersAgentServiceServer is the server API for BatchExportersAgentService service. All implementations should embed UnimplementedBatchExportersAgentServiceServer for forward compatibility

type BatchJobsAgentServiceClient 

type BatchJobsAgentServiceClient interface {
	GetDesiredBatchJobs(ctx context.Context, in *GetDesiredBatchJobsRequest, opts ...grpc.CallOption) (*GetDesiredBatchJobsResponse, error)
}

BatchJobsAgentServiceClient is the client API for BatchJobsAgentService 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 NewBatchJobsAgentServiceClient 

func NewBatchJobsAgentServiceClient(cc grpc.ClientConnInterface) BatchJobsAgentServiceClient

type BatchJobsAgentServiceServer 

type BatchJobsAgentServiceServer interface {
	GetDesiredBatchJobs(context.Context, *GetDesiredBatchJobsRequest) (*GetDesiredBatchJobsResponse, error)
}

BatchJobsAgentServiceServer is the server API for BatchJobsAgentService service. All implementations should embed UnimplementedBatchJobsAgentServiceServer for forward compatibility

type DataConnectorsAgentServiceClient 

type DataConnectorsAgentServiceClient interface {
	GetDesiredDataConnectors(ctx context.Context, in *GetDesiredDataConnectorsRequest, opts ...grpc.CallOption) (*GetDesiredDataConnectorsResponse, error)
}

DataConnectorsAgentServiceClient is the client API for DataConnectorsAgentService 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 NewDataConnectorsAgentServiceClient 

func NewDataConnectorsAgentServiceClient(cc grpc.ClientConnInterface) DataConnectorsAgentServiceClient

type DataConnectorsAgentServiceServer 

type DataConnectorsAgentServiceServer interface {
	GetDesiredDataConnectors(context.Context, *GetDesiredDataConnectorsRequest) (*GetDesiredDataConnectorsResponse, error)
}

DataConnectorsAgentServiceServer is the server API for DataConnectorsAgentService service. All implementations should embed UnimplementedDataConnectorsAgentServiceServer for forward compatibility

type GetDesiredBatchExportersRequest 

type GetDesiredBatchExportersRequest struct {
	// contains filtered or unexported fields
}

func (*GetDesiredBatchExportersRequest) Descriptor deprecated 

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

Deprecated: Use GetDesiredBatchExportersRequest.ProtoReflect.Descriptor instead.

func (*GetDesiredBatchExportersRequest) ProtoMessage 

func (*GetDesiredBatchExportersRequest) ProtoMessage()

func (*GetDesiredBatchExportersRequest) ProtoReflect 

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

func (*GetDesiredBatchExportersRequest) Reset 

func (x *GetDesiredBatchExportersRequest) Reset()

func (*GetDesiredBatchExportersRequest) String 

func (x *GetDesiredBatchExportersRequest) String() string

type GetDesiredBatchExportersResponse 

type GetDesiredBatchExportersResponse struct {
	Exporters []*v1.ExtendedBatchExporter `protobuf:"bytes,1,rep,name=exporters,proto3" json:"exporters,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDesiredBatchExportersResponse) Descriptor deprecated 

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

Deprecated: Use GetDesiredBatchExportersResponse.ProtoReflect.Descriptor instead.

func (*GetDesiredBatchExportersResponse) GetExporters 

func (x *GetDesiredBatchExportersResponse) GetExporters() []*v1.ExtendedBatchExporter

func (*GetDesiredBatchExportersResponse) ProtoMessage 

func (*GetDesiredBatchExportersResponse) ProtoMessage()

func (*GetDesiredBatchExportersResponse) ProtoReflect 

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

func (*GetDesiredBatchExportersResponse) Reset 

func (x *GetDesiredBatchExportersResponse) Reset()

func (*GetDesiredBatchExportersResponse) String 

func (x *GetDesiredBatchExportersResponse) String() string

type GetDesiredBatchJobsRequest 

type GetDesiredBatchJobsRequest struct {
	// contains filtered or unexported fields
}

func (*GetDesiredBatchJobsRequest) Descriptor deprecated 

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

Deprecated: Use GetDesiredBatchJobsRequest.ProtoReflect.Descriptor instead.

func (*GetDesiredBatchJobsRequest) ProtoMessage 

func (*GetDesiredBatchJobsRequest) ProtoMessage()

func (*GetDesiredBatchJobsRequest) ProtoReflect 

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

func (*GetDesiredBatchJobsRequest) Reset 

func (x *GetDesiredBatchJobsRequest) Reset()

func (*GetDesiredBatchJobsRequest) String 

func (x *GetDesiredBatchJobsRequest) String() string

type GetDesiredBatchJobsResponse 

type GetDesiredBatchJobsResponse struct {
	ExtendedBatchJobs []*v1.ExtendedBatchJob `protobuf:"bytes,1,rep,name=extended_batch_jobs,json=extendedBatchJobs,proto3" json:"extended_batch_jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDesiredBatchJobsResponse) Descriptor deprecated 

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

Deprecated: Use GetDesiredBatchJobsResponse.ProtoReflect.Descriptor instead.

func (*GetDesiredBatchJobsResponse) GetExtendedBatchJobs 

func (x *GetDesiredBatchJobsResponse) GetExtendedBatchJobs() []*v1.ExtendedBatchJob

func (*GetDesiredBatchJobsResponse) ProtoMessage 

func (*GetDesiredBatchJobsResponse) ProtoMessage()

func (*GetDesiredBatchJobsResponse) ProtoReflect 

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

func (*GetDesiredBatchJobsResponse) Reset 

func (x *GetDesiredBatchJobsResponse) Reset()

func (*GetDesiredBatchJobsResponse) String 

func (x *GetDesiredBatchJobsResponse) String() string

type GetDesiredDataConnectorsRequest 

type GetDesiredDataConnectorsRequest struct {
	// contains filtered or unexported fields
}

func (*GetDesiredDataConnectorsRequest) Descriptor deprecated 

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

Deprecated: Use GetDesiredDataConnectorsRequest.ProtoReflect.Descriptor instead.

func (*GetDesiredDataConnectorsRequest) ProtoMessage 

func (*GetDesiredDataConnectorsRequest) ProtoMessage()

func (*GetDesiredDataConnectorsRequest) ProtoReflect 

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

func (*GetDesiredDataConnectorsRequest) Reset 

func (x *GetDesiredDataConnectorsRequest) Reset()

func (*GetDesiredDataConnectorsRequest) String 

func (x *GetDesiredDataConnectorsRequest) String() string

type GetDesiredDataConnectorsResponse 

type GetDesiredDataConnectorsResponse struct {
	DataConnectors []*v1.DataConnector `protobuf:"bytes,1,rep,name=data_connectors,json=dataConnectors,proto3" json:"data_connectors,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDesiredDataConnectorsResponse) Descriptor deprecated 

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

Deprecated: Use GetDesiredDataConnectorsResponse.ProtoReflect.Descriptor instead.

func (*GetDesiredDataConnectorsResponse) GetDataConnectors 

func (x *GetDesiredDataConnectorsResponse) GetDataConnectors() []*v1.DataConnector

func (*GetDesiredDataConnectorsResponse) ProtoMessage 

func (*GetDesiredDataConnectorsResponse) ProtoMessage()

func (*GetDesiredDataConnectorsResponse) ProtoReflect 

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

func (*GetDesiredDataConnectorsResponse) Reset 

func (x *GetDesiredDataConnectorsResponse) Reset()

func (*GetDesiredDataConnectorsResponse) String 

func (x *GetDesiredDataConnectorsResponse) String() string

type GetStreamsRequest 

type GetStreamsRequest struct {
	// contains filtered or unexported fields
}

func (*GetStreamsRequest) Descriptor deprecated 

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

Deprecated: Use GetStreamsRequest.ProtoReflect.Descriptor instead.

func (*GetStreamsRequest) ProtoMessage 

func (*GetStreamsRequest) ProtoMessage()

func (*GetStreamsRequest) ProtoReflect 

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

func (*GetStreamsRequest) Reset 

func (x *GetStreamsRequest) Reset()

func (*GetStreamsRequest) String 

func (x *GetStreamsRequest) String() string

type GetStreamsResponse 

type GetStreamsResponse struct {
	ExtendedStreams []*v1.ExtendedStream `protobuf:"bytes,1,rep,name=extended_streams,json=extendedStreams,proto3" json:"extended_streams,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamsResponse) Descriptor deprecated 

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

Deprecated: Use GetStreamsResponse.ProtoReflect.Descriptor instead.

func (*GetStreamsResponse) GetExtendedStreams 

func (x *GetStreamsResponse) GetExtendedStreams() []*v1.ExtendedStream

func (*GetStreamsResponse) ProtoMessage 

func (*GetStreamsResponse) ProtoMessage()

func (*GetStreamsResponse) ProtoReflect 

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

func (*GetStreamsResponse) Reset 

func (x *GetStreamsResponse) Reset()

func (*GetStreamsResponse) String 

func (x *GetStreamsResponse) String() string

type StreamsAgentServiceClient 

type StreamsAgentServiceClient interface {
	GetStreams(ctx context.Context, in *GetStreamsRequest, opts ...grpc.CallOption) (*GetStreamsResponse, error)
}

StreamsAgentServiceClient is the client API for StreamsAgentService 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 NewStreamsAgentServiceClient 

func NewStreamsAgentServiceClient(cc grpc.ClientConnInterface) StreamsAgentServiceClient

type StreamsAgentServiceServer 

type StreamsAgentServiceServer interface {
	GetStreams(context.Context, *GetStreamsRequest) (*GetStreamsResponse, error)
}

StreamsAgentServiceServer is the server API for StreamsAgentService service. All implementations should embed UnimplementedStreamsAgentServiceServer for forward compatibility

type UnimplementedBatchExportersAgentServiceServer 

type UnimplementedBatchExportersAgentServiceServer struct {
}

UnimplementedBatchExportersAgentServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedBatchExportersAgentServiceServer) GetDesiredBatchExporters 

func (UnimplementedBatchExportersAgentServiceServer) GetDesiredBatchExporters(context.Context, *GetDesiredBatchExportersRequest) (*GetDesiredBatchExportersResponse, error)

type UnimplementedBatchJobsAgentServiceServer 

type UnimplementedBatchJobsAgentServiceServer struct {
}

UnimplementedBatchJobsAgentServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedBatchJobsAgentServiceServer) GetDesiredBatchJobs 

func (UnimplementedBatchJobsAgentServiceServer) GetDesiredBatchJobs(context.Context, *GetDesiredBatchJobsRequest) (*GetDesiredBatchJobsResponse, error)

type UnimplementedDataConnectorsAgentServiceServer 

type UnimplementedDataConnectorsAgentServiceServer struct {
}

UnimplementedDataConnectorsAgentServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDataConnectorsAgentServiceServer) GetDesiredDataConnectors 

func (UnimplementedDataConnectorsAgentServiceServer) GetDesiredDataConnectors(context.Context, *GetDesiredDataConnectorsRequest) (*GetDesiredDataConnectorsResponse, error)

type UnimplementedStreamsAgentServiceServer 

type UnimplementedStreamsAgentServiceServer struct {
}

UnimplementedStreamsAgentServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedStreamsAgentServiceServer) GetStreams 

func (UnimplementedStreamsAgentServiceServer) GetStreams(context.Context, *GetStreamsRequest) (*GetStreamsResponse, error)

type UnsafeBatchExportersAgentServiceServer 

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

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

type UnsafeBatchJobsAgentServiceServer 

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

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

type UnsafeDataConnectorsAgentServiceServer 

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

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

type UnsafeStreamsAgentServiceServer 

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

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

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.