services

package
v0.0.24 Latest Latest
Warning

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

 Go to latest Published: Apr 20, 2023 License: MIT Imports: 11 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DProxy_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "services.DProxy",
	HandlerType: (*DProxyServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Auth",
			Handler:    _DProxy_Auth_Handler,
		},
		{
			MethodName: "DeleteTunnel",
			Handler:    _DProxy_DeleteTunnel_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Connect",
			Handler:       _DProxy_Connect_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "services/cs_services_dproxy.proto",
}

DProxy_ServiceDesc is the grpc.ServiceDesc for DProxy 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_services_cs_services_dproxy_proto protoreflect.FileDescriptor
View Source 
var File_services_cs_services_grpccollector_proto protoreflect.FileDescriptor
View Source 
var GRPCCollector_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "services.GRPCCollector",
	HandlerType: (*GRPCCollectorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddRecord",
			Handler:    _GRPCCollector_AddRecord_Handler,
		},
		{
			MethodName: "AddAMQPRecord",
			Handler:    _GRPCCollector_AddAMQPRecord_Handler,
		},
		{
			MethodName: "AddKafkaRecord",
			Handler:    _GRPCCollector_AddKafkaRecord_Handler,
		},
		{
			MethodName: "AddSQSRecord",
			Handler:    _GRPCCollector_AddSQSRecord_Handler,
		},
		{
			MethodName: "AddAzureRecord",
			Handler:    _GRPCCollector_AddAzureRecord_Handler,
		},
		{
			MethodName: "AddGCPRecord",
			Handler:    _GRPCCollector_AddGCPRecord_Handler,
		},
		{
			MethodName: "AddRedisRecord",
			Handler:    _GRPCCollector_AddRedisRecord_Handler,
		},
		{
			MethodName: "AddRedisStreamsRecord",
			Handler:    _GRPCCollector_AddRedisStreamsRecord_Handler,
		},
		{
			MethodName: "AddMQTTRecord",
			Handler:    _GRPCCollector_AddMQTTRecord_Handler,
		},
		{
			MethodName: "AddNSQRecord",
			Handler:    _GRPCCollector_AddNSQRecord_Handler,
		},
		{
			MethodName: "AddKubeMQRecord",
			Handler:    _GRPCCollector_AddKubeMQRecord_Handler,
		},
		{
			MethodName: "AddNATSRecord",
			Handler:    _GRPCCollector_AddNATSRecord_Handler,
		},
		{
			MethodName: "AddNATSStreamingRecord",
			Handler:    _GRPCCollector_AddNATSStreamingRecord_Handler,
		},
		{
			MethodName: "AddNATSJetStreamRecord",
			Handler:    _GRPCCollector_AddNATSJetStreamRecord_Handler,
		},
		{
			MethodName: "Test",
			Handler:    _GRPCCollector_Test_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "services/cs_services_grpccollector.proto",
}

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

Functions

func RegisterDProxyServer 

func RegisterDProxyServer(s grpc.ServiceRegistrar, srv DProxyServer)

func RegisterGRPCCollectorServer 

func RegisterGRPCCollectorServer(s grpc.ServiceRegistrar, srv GRPCCollectorServer)

Types

type AMQPRecordRequest 

type AMQPRecordRequest struct {
	Records []*records.AMQPSinkRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*AMQPRecordRequest) Descriptor deprecated 

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

Deprecated: Use AMQPRecordRequest.ProtoReflect.Descriptor instead.

func (*AMQPRecordRequest) GetRecords 

func (x *AMQPRecordRequest) GetRecords() []*records.AMQPSinkRecord

func (*AMQPRecordRequest) ProtoMessage 

func (*AMQPRecordRequest) ProtoMessage()

func (*AMQPRecordRequest) ProtoReflect added in v0.0.24 

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

func (*AMQPRecordRequest) Reset 

func (x *AMQPRecordRequest) Reset()

func (*AMQPRecordRequest) String 

func (x *AMQPRecordRequest) String() string

type AMQPRecordResponse 

type AMQPRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*AMQPRecordResponse) Descriptor deprecated 

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

Deprecated: Use AMQPRecordResponse.ProtoReflect.Descriptor instead.

func (*AMQPRecordResponse) GetNumRecordsProcessed 

func (x *AMQPRecordResponse) GetNumRecordsProcessed() int64

func (*AMQPRecordResponse) GetStatus 

func (x *AMQPRecordResponse) GetStatus() *common.Status

func (*AMQPRecordResponse) ProtoMessage 

func (*AMQPRecordResponse) ProtoMessage()

func (*AMQPRecordResponse) ProtoReflect added in v0.0.24 

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

func (*AMQPRecordResponse) Reset 

func (x *AMQPRecordResponse) Reset()

func (*AMQPRecordResponse) String 

func (x *AMQPRecordResponse) String() string

type AzureRecordRequest 

type AzureRecordRequest struct {
	Records []*records.AzureSinkRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*AzureRecordRequest) Descriptor deprecated 

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

Deprecated: Use AzureRecordRequest.ProtoReflect.Descriptor instead.

func (*AzureRecordRequest) GetRecords 

func (x *AzureRecordRequest) GetRecords() []*records.AzureSinkRecord

func (*AzureRecordRequest) ProtoMessage 

func (*AzureRecordRequest) ProtoMessage()

func (*AzureRecordRequest) ProtoReflect added in v0.0.24 

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

func (*AzureRecordRequest) Reset 

func (x *AzureRecordRequest) Reset()

func (*AzureRecordRequest) String 

func (x *AzureRecordRequest) String() string

type AzureRecordResponse 

type AzureRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*AzureRecordResponse) Descriptor deprecated 

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

Deprecated: Use AzureRecordResponse.ProtoReflect.Descriptor instead.

func (*AzureRecordResponse) GetNumRecordsProcessed 

func (x *AzureRecordResponse) GetNumRecordsProcessed() int64

func (*AzureRecordResponse) GetStatus 

func (x *AzureRecordResponse) GetStatus() *common.Status

func (*AzureRecordResponse) ProtoMessage 

func (*AzureRecordResponse) ProtoMessage()

func (*AzureRecordResponse) ProtoReflect added in v0.0.24 

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

func (*AzureRecordResponse) Reset 

func (x *AzureRecordResponse) Reset()

func (*AzureRecordResponse) String 

func (x *AzureRecordResponse) String() string

type DProxyClient 

type DProxyClient interface {
	Connect(ctx context.Context, in *events.Tunnel, opts ...grpc.CallOption) (DProxy_ConnectClient, error)
	Auth(ctx context.Context, in *events.AuthRequest, opts ...grpc.CallOption) (*events.AuthResponse, error)
	DeleteTunnel(ctx context.Context, in *events.DeleteTunnelRequest, opts ...grpc.CallOption) (*events.DeleteTunnelResponse, error)
}

DProxyClient is the client API for DProxy 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 NewDProxyClient 

func NewDProxyClient(cc grpc.ClientConnInterface) DProxyClient

type DProxyServer 

type DProxyServer interface {
	Connect(*events.Tunnel, DProxy_ConnectServer) error
	Auth(context.Context, *events.AuthRequest) (*events.AuthResponse, error)
	DeleteTunnel(context.Context, *events.DeleteTunnelRequest) (*events.DeleteTunnelResponse, error)
}

DProxyServer is the server API for DProxy service. All implementations should embed UnimplementedDProxyServer for forward compatibility

type DProxy_ConnectClient 

type DProxy_ConnectClient interface {
	Recv() (*events.Tunnel, error)
	grpc.ClientStream
}

type DProxy_ConnectServer 

type DProxy_ConnectServer interface {
	Send(*events.Tunnel) error
	grpc.ServerStream
}

type GCPRecordRequest 

type GCPRecordRequest struct {
	Records []*records.GCPRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*GCPRecordRequest) Descriptor deprecated 

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

Deprecated: Use GCPRecordRequest.ProtoReflect.Descriptor instead.

func (*GCPRecordRequest) GetRecords 

func (x *GCPRecordRequest) GetRecords() []*records.GCPRecord

func (*GCPRecordRequest) ProtoMessage 

func (*GCPRecordRequest) ProtoMessage()

func (*GCPRecordRequest) ProtoReflect added in v0.0.24 

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

func (*GCPRecordRequest) Reset 

func (x *GCPRecordRequest) Reset()

func (*GCPRecordRequest) String 

func (x *GCPRecordRequest) String() string

type GCPRecordResponse 

type GCPRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GCPRecordResponse) Descriptor deprecated 

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

Deprecated: Use GCPRecordResponse.ProtoReflect.Descriptor instead.

func (*GCPRecordResponse) GetNumRecordsProcessed 

func (x *GCPRecordResponse) GetNumRecordsProcessed() int64

func (*GCPRecordResponse) GetStatus 

func (x *GCPRecordResponse) GetStatus() *common.Status

func (*GCPRecordResponse) ProtoMessage 

func (*GCPRecordResponse) ProtoMessage()

func (*GCPRecordResponse) ProtoReflect added in v0.0.24 

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

func (*GCPRecordResponse) Reset 

func (x *GCPRecordResponse) Reset()

func (*GCPRecordResponse) String 

func (x *GCPRecordResponse) String() string

type GRPCCollectorClient 

type GRPCCollectorClient interface {
	AddRecord(ctx context.Context, in *GenericRecordRequest, opts ...grpc.CallOption) (*GenericRecordResponse, error)
	AddAMQPRecord(ctx context.Context, in *AMQPRecordRequest, opts ...grpc.CallOption) (*AMQPRecordResponse, error)
	AddKafkaRecord(ctx context.Context, in *KafkaSinkRecordRequest, opts ...grpc.CallOption) (*KafkaSinkRecordResponse, error)
	AddSQSRecord(ctx context.Context, in *SQSRecordRequest, opts ...grpc.CallOption) (*SQSRecordResponse, error)
	AddAzureRecord(ctx context.Context, in *AzureRecordRequest, opts ...grpc.CallOption) (*AzureRecordResponse, error)
	AddGCPRecord(ctx context.Context, in *GCPRecordRequest, opts ...grpc.CallOption) (*GCPRecordResponse, error)
	AddRedisRecord(ctx context.Context, in *RedisRecordRequest, opts ...grpc.CallOption) (*RedisRecordResponse, error)
	AddRedisStreamsRecord(ctx context.Context, in *RedisStreamsRecordRequest, opts ...grpc.CallOption) (*RedisStreamsRecordResponse, error)
	AddMQTTRecord(ctx context.Context, in *MQTTRecordRequest, opts ...grpc.CallOption) (*MQTTRecordResponse, error)
	AddNSQRecord(ctx context.Context, in *NSQRecordRequest, opts ...grpc.CallOption) (*NSQRecordResponse, error)
	AddKubeMQRecord(ctx context.Context, in *KubeMQRecordRequest, opts ...grpc.CallOption) (*KubeMQRecordResponse, error)
	AddNATSRecord(ctx context.Context, in *NATSRecordRequest, opts ...grpc.CallOption) (*NATSRecordResponse, error)
	AddNATSStreamingRecord(ctx context.Context, in *NATSStreamingRecordRequest, opts ...grpc.CallOption) (*NATSStreamingRecordResponse, error)
	AddNATSJetStreamRecord(ctx context.Context, in *NATSJetStreamRecordRequest, opts ...grpc.CallOption) (*NATSJetStreamRecordResponse, error)
	Test(ctx context.Context, in *TestRequest, opts ...grpc.CallOption) (*TestResponse, error)
}

GRPCCollectorClient is the client API for GRPCCollector 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 NewGRPCCollectorClient 

func NewGRPCCollectorClient(cc grpc.ClientConnInterface) GRPCCollectorClient

type GRPCCollectorServer 

type GRPCCollectorServer interface {
	AddRecord(context.Context, *GenericRecordRequest) (*GenericRecordResponse, error)
	AddAMQPRecord(context.Context, *AMQPRecordRequest) (*AMQPRecordResponse, error)
	AddKafkaRecord(context.Context, *KafkaSinkRecordRequest) (*KafkaSinkRecordResponse, error)
	AddSQSRecord(context.Context, *SQSRecordRequest) (*SQSRecordResponse, error)
	AddAzureRecord(context.Context, *AzureRecordRequest) (*AzureRecordResponse, error)
	AddGCPRecord(context.Context, *GCPRecordRequest) (*GCPRecordResponse, error)
	AddRedisRecord(context.Context, *RedisRecordRequest) (*RedisRecordResponse, error)
	AddRedisStreamsRecord(context.Context, *RedisStreamsRecordRequest) (*RedisStreamsRecordResponse, error)
	AddMQTTRecord(context.Context, *MQTTRecordRequest) (*MQTTRecordResponse, error)
	AddNSQRecord(context.Context, *NSQRecordRequest) (*NSQRecordResponse, error)
	AddKubeMQRecord(context.Context, *KubeMQRecordRequest) (*KubeMQRecordResponse, error)
	AddNATSRecord(context.Context, *NATSRecordRequest) (*NATSRecordResponse, error)
	AddNATSStreamingRecord(context.Context, *NATSStreamingRecordRequest) (*NATSStreamingRecordResponse, error)
	AddNATSJetStreamRecord(context.Context, *NATSJetStreamRecordRequest) (*NATSJetStreamRecordResponse, error)
	Test(context.Context, *TestRequest) (*TestResponse, error)
}

GRPCCollectorServer is the server API for GRPCCollector service. All implementations should embed UnimplementedGRPCCollectorServer for forward compatibility

type GenericRecordRequest 

type GenericRecordRequest struct {
	Records []*records.GenericRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*GenericRecordRequest) Descriptor deprecated 

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

Deprecated: Use GenericRecordRequest.ProtoReflect.Descriptor instead.

func (*GenericRecordRequest) GetRecords 

func (x *GenericRecordRequest) GetRecords() []*records.GenericRecord

func (*GenericRecordRequest) ProtoMessage 

func (*GenericRecordRequest) ProtoMessage()

func (*GenericRecordRequest) ProtoReflect added in v0.0.24 

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

func (*GenericRecordRequest) Reset 

func (x *GenericRecordRequest) Reset()

func (*GenericRecordRequest) String 

func (x *GenericRecordRequest) String() string

type GenericRecordResponse 

type GenericRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GenericRecordResponse) Descriptor deprecated 

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

Deprecated: Use GenericRecordResponse.ProtoReflect.Descriptor instead.

func (*GenericRecordResponse) GetNumRecordsProcessed 

func (x *GenericRecordResponse) GetNumRecordsProcessed() int64

func (*GenericRecordResponse) GetStatus 

func (x *GenericRecordResponse) GetStatus() *common.Status

func (*GenericRecordResponse) ProtoMessage 

func (*GenericRecordResponse) ProtoMessage()

func (*GenericRecordResponse) ProtoReflect added in v0.0.24 

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

func (*GenericRecordResponse) Reset 

func (x *GenericRecordResponse) Reset()

func (*GenericRecordResponse) String 

func (x *GenericRecordResponse) String() string

type KafkaSinkRecordRequest 

type KafkaSinkRecordRequest struct {
	Records []*records.KafkaSinkRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaSinkRecordRequest) Descriptor deprecated 

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

Deprecated: Use KafkaSinkRecordRequest.ProtoReflect.Descriptor instead.

func (*KafkaSinkRecordRequest) GetRecords 

func (x *KafkaSinkRecordRequest) GetRecords() []*records.KafkaSinkRecord

func (*KafkaSinkRecordRequest) ProtoMessage 

func (*KafkaSinkRecordRequest) ProtoMessage()

func (*KafkaSinkRecordRequest) ProtoReflect added in v0.0.24 

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

func (*KafkaSinkRecordRequest) Reset 

func (x *KafkaSinkRecordRequest) Reset()

func (*KafkaSinkRecordRequest) String 

func (x *KafkaSinkRecordRequest) String() string

type KafkaSinkRecordResponse 

type KafkaSinkRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaSinkRecordResponse) Descriptor deprecated 

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

Deprecated: Use KafkaSinkRecordResponse.ProtoReflect.Descriptor instead.

func (*KafkaSinkRecordResponse) GetNumRecordsProcessed 

func (x *KafkaSinkRecordResponse) GetNumRecordsProcessed() int64

func (*KafkaSinkRecordResponse) GetStatus 

func (x *KafkaSinkRecordResponse) GetStatus() *common.Status

func (*KafkaSinkRecordResponse) ProtoMessage 

func (*KafkaSinkRecordResponse) ProtoMessage()

func (*KafkaSinkRecordResponse) ProtoReflect added in v0.0.24 

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

func (*KafkaSinkRecordResponse) Reset 

func (x *KafkaSinkRecordResponse) Reset()

func (*KafkaSinkRecordResponse) String 

func (x *KafkaSinkRecordResponse) String() string

type KubeMQRecordRequest 

type KubeMQRecordRequest struct {
	Records []*records.KubeMQRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*KubeMQRecordRequest) Descriptor deprecated 

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

Deprecated: Use KubeMQRecordRequest.ProtoReflect.Descriptor instead.

func (*KubeMQRecordRequest) GetRecords 

func (x *KubeMQRecordRequest) GetRecords() []*records.KubeMQRecord

func (*KubeMQRecordRequest) ProtoMessage 

func (*KubeMQRecordRequest) ProtoMessage()

func (*KubeMQRecordRequest) ProtoReflect added in v0.0.24 

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

func (*KubeMQRecordRequest) Reset 

func (x *KubeMQRecordRequest) Reset()

func (*KubeMQRecordRequest) String 

func (x *KubeMQRecordRequest) String() string

type KubeMQRecordResponse 

type KubeMQRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*KubeMQRecordResponse) Descriptor deprecated 

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

Deprecated: Use KubeMQRecordResponse.ProtoReflect.Descriptor instead.

func (*KubeMQRecordResponse) GetNumRecordsProcessed 

func (x *KubeMQRecordResponse) GetNumRecordsProcessed() int64

func (*KubeMQRecordResponse) GetStatus 

func (x *KubeMQRecordResponse) GetStatus() *common.Status

func (*KubeMQRecordResponse) ProtoMessage 

func (*KubeMQRecordResponse) ProtoMessage()

func (*KubeMQRecordResponse) ProtoReflect added in v0.0.24 

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

func (*KubeMQRecordResponse) Reset 

func (x *KubeMQRecordResponse) Reset()

func (*KubeMQRecordResponse) String 

func (x *KubeMQRecordResponse) String() string

type MQTTRecordRequest 

type MQTTRecordRequest struct {
	Records []*records.MQTTRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*MQTTRecordRequest) Descriptor deprecated 

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

Deprecated: Use MQTTRecordRequest.ProtoReflect.Descriptor instead.

func (*MQTTRecordRequest) GetRecords 

func (x *MQTTRecordRequest) GetRecords() []*records.MQTTRecord

func (*MQTTRecordRequest) ProtoMessage 

func (*MQTTRecordRequest) ProtoMessage()

func (*MQTTRecordRequest) ProtoReflect added in v0.0.24 

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

func (*MQTTRecordRequest) Reset 

func (x *MQTTRecordRequest) Reset()

func (*MQTTRecordRequest) String 

func (x *MQTTRecordRequest) String() string

type MQTTRecordResponse 

type MQTTRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*MQTTRecordResponse) Descriptor deprecated 

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

Deprecated: Use MQTTRecordResponse.ProtoReflect.Descriptor instead.

func (*MQTTRecordResponse) GetNumRecordsProcessed 

func (x *MQTTRecordResponse) GetNumRecordsProcessed() int64

func (*MQTTRecordResponse) GetStatus 

func (x *MQTTRecordResponse) GetStatus() *common.Status

func (*MQTTRecordResponse) ProtoMessage 

func (*MQTTRecordResponse) ProtoMessage()

func (*MQTTRecordResponse) ProtoReflect added in v0.0.24 

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

func (*MQTTRecordResponse) Reset 

func (x *MQTTRecordResponse) Reset()

func (*MQTTRecordResponse) String 

func (x *MQTTRecordResponse) String() string

type NATSJetStreamRecordRequest added in v0.0.7 

type NATSJetStreamRecordRequest struct {
	Records []*records.NATSJetStreamRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*NATSJetStreamRecordRequest) Descriptor deprecated added in v0.0.7 

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

Deprecated: Use NATSJetStreamRecordRequest.ProtoReflect.Descriptor instead.

func (*NATSJetStreamRecordRequest) GetRecords added in v0.0.7 

func (x *NATSJetStreamRecordRequest) GetRecords() []*records.NATSJetStreamRecord

func (*NATSJetStreamRecordRequest) ProtoMessage added in v0.0.7 

func (*NATSJetStreamRecordRequest) ProtoMessage()

func (*NATSJetStreamRecordRequest) ProtoReflect added in v0.0.24 

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

func (*NATSJetStreamRecordRequest) Reset added in v0.0.7 

func (x *NATSJetStreamRecordRequest) Reset()

func (*NATSJetStreamRecordRequest) String added in v0.0.7 

func (x *NATSJetStreamRecordRequest) String() string

type NATSJetStreamRecordResponse added in v0.0.7 

type NATSJetStreamRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*NATSJetStreamRecordResponse) Descriptor deprecated added in v0.0.7 

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

Deprecated: Use NATSJetStreamRecordResponse.ProtoReflect.Descriptor instead.

func (*NATSJetStreamRecordResponse) GetNumRecordsProcessed added in v0.0.7 

func (x *NATSJetStreamRecordResponse) GetNumRecordsProcessed() int64

func (*NATSJetStreamRecordResponse) GetStatus added in v0.0.7 

func (x *NATSJetStreamRecordResponse) GetStatus() *common.Status

func (*NATSJetStreamRecordResponse) ProtoMessage added in v0.0.7 

func (*NATSJetStreamRecordResponse) ProtoMessage()

func (*NATSJetStreamRecordResponse) ProtoReflect added in v0.0.24 

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

func (*NATSJetStreamRecordResponse) Reset added in v0.0.7 

func (x *NATSJetStreamRecordResponse) Reset()

func (*NATSJetStreamRecordResponse) String added in v0.0.7 

func (x *NATSJetStreamRecordResponse) String() string

type NATSRecordRequest added in v0.0.7 

type NATSRecordRequest struct {
	Records []*records.NATSRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*NATSRecordRequest) Descriptor deprecated added in v0.0.7 

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

Deprecated: Use NATSRecordRequest.ProtoReflect.Descriptor instead.

func (*NATSRecordRequest) GetRecords added in v0.0.7 

func (x *NATSRecordRequest) GetRecords() []*records.NATSRecord

func (*NATSRecordRequest) ProtoMessage added in v0.0.7 

func (*NATSRecordRequest) ProtoMessage()

func (*NATSRecordRequest) ProtoReflect added in v0.0.24 

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

func (*NATSRecordRequest) Reset added in v0.0.7 

func (x *NATSRecordRequest) Reset()

func (*NATSRecordRequest) String added in v0.0.7 

func (x *NATSRecordRequest) String() string

type NATSRecordResponse added in v0.0.7 

type NATSRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*NATSRecordResponse) Descriptor deprecated added in v0.0.7 

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

Deprecated: Use NATSRecordResponse.ProtoReflect.Descriptor instead.

func (*NATSRecordResponse) GetNumRecordsProcessed added in v0.0.7 

func (x *NATSRecordResponse) GetNumRecordsProcessed() int64

func (*NATSRecordResponse) GetStatus added in v0.0.7 

func (x *NATSRecordResponse) GetStatus() *common.Status

func (*NATSRecordResponse) ProtoMessage added in v0.0.7 

func (*NATSRecordResponse) ProtoMessage()

func (*NATSRecordResponse) ProtoReflect added in v0.0.24 

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

func (*NATSRecordResponse) Reset added in v0.0.7 

func (x *NATSRecordResponse) Reset()

func (*NATSRecordResponse) String added in v0.0.7 

func (x *NATSRecordResponse) String() string

type NATSStreamingRecordRequest added in v0.0.7 

type NATSStreamingRecordRequest struct {
	Records []*records.NATSStreamingRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*NATSStreamingRecordRequest) Descriptor deprecated added in v0.0.7 

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

Deprecated: Use NATSStreamingRecordRequest.ProtoReflect.Descriptor instead.

func (*NATSStreamingRecordRequest) GetRecords added in v0.0.7 

func (x *NATSStreamingRecordRequest) GetRecords() []*records.NATSStreamingRecord

func (*NATSStreamingRecordRequest) ProtoMessage added in v0.0.7 

func (*NATSStreamingRecordRequest) ProtoMessage()

func (*NATSStreamingRecordRequest) ProtoReflect added in v0.0.24 

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

func (*NATSStreamingRecordRequest) Reset added in v0.0.7 

func (x *NATSStreamingRecordRequest) Reset()

func (*NATSStreamingRecordRequest) String added in v0.0.7 

func (x *NATSStreamingRecordRequest) String() string

type NATSStreamingRecordResponse added in v0.0.7 

type NATSStreamingRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*NATSStreamingRecordResponse) Descriptor deprecated added in v0.0.7 

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

Deprecated: Use NATSStreamingRecordResponse.ProtoReflect.Descriptor instead.

func (*NATSStreamingRecordResponse) GetNumRecordsProcessed added in v0.0.7 

func (x *NATSStreamingRecordResponse) GetNumRecordsProcessed() int64

func (*NATSStreamingRecordResponse) GetStatus added in v0.0.7 

func (x *NATSStreamingRecordResponse) GetStatus() *common.Status

func (*NATSStreamingRecordResponse) ProtoMessage added in v0.0.7 

func (*NATSStreamingRecordResponse) ProtoMessage()

func (*NATSStreamingRecordResponse) ProtoReflect added in v0.0.24 

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

func (*NATSStreamingRecordResponse) Reset added in v0.0.7 

func (x *NATSStreamingRecordResponse) Reset()

func (*NATSStreamingRecordResponse) String added in v0.0.7 

func (x *NATSStreamingRecordResponse) String() string

type NSQRecordRequest 

type NSQRecordRequest struct {
	Records []*records.NSQRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*NSQRecordRequest) Descriptor deprecated 

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

Deprecated: Use NSQRecordRequest.ProtoReflect.Descriptor instead.

func (*NSQRecordRequest) GetRecords 

func (x *NSQRecordRequest) GetRecords() []*records.NSQRecord

func (*NSQRecordRequest) ProtoMessage 

func (*NSQRecordRequest) ProtoMessage()

func (*NSQRecordRequest) ProtoReflect added in v0.0.24 

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

func (*NSQRecordRequest) Reset 

func (x *NSQRecordRequest) Reset()

func (*NSQRecordRequest) String 

func (x *NSQRecordRequest) String() string

type NSQRecordResponse 

type NSQRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*NSQRecordResponse) Descriptor deprecated 

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

Deprecated: Use NSQRecordResponse.ProtoReflect.Descriptor instead.

func (*NSQRecordResponse) GetNumRecordsProcessed 

func (x *NSQRecordResponse) GetNumRecordsProcessed() int64

func (*NSQRecordResponse) GetStatus 

func (x *NSQRecordResponse) GetStatus() *common.Status

func (*NSQRecordResponse) ProtoMessage 

func (*NSQRecordResponse) ProtoMessage()

func (*NSQRecordResponse) ProtoReflect added in v0.0.24 

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

func (*NSQRecordResponse) Reset 

func (x *NSQRecordResponse) Reset()

func (*NSQRecordResponse) String 

func (x *NSQRecordResponse) String() string

type RedisRecordRequest 

type RedisRecordRequest struct {
	Records []*records.RedisRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*RedisRecordRequest) Descriptor deprecated 

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

Deprecated: Use RedisRecordRequest.ProtoReflect.Descriptor instead.

func (*RedisRecordRequest) GetRecords 

func (x *RedisRecordRequest) GetRecords() []*records.RedisRecord

func (*RedisRecordRequest) ProtoMessage 

func (*RedisRecordRequest) ProtoMessage()

func (*RedisRecordRequest) ProtoReflect added in v0.0.24 

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

func (*RedisRecordRequest) Reset 

func (x *RedisRecordRequest) Reset()

func (*RedisRecordRequest) String 

func (x *RedisRecordRequest) String() string

type RedisRecordResponse 

type RedisRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RedisRecordResponse) Descriptor deprecated 

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

Deprecated: Use RedisRecordResponse.ProtoReflect.Descriptor instead.

func (*RedisRecordResponse) GetNumRecordsProcessed 

func (x *RedisRecordResponse) GetNumRecordsProcessed() int64

func (*RedisRecordResponse) GetStatus 

func (x *RedisRecordResponse) GetStatus() *common.Status

func (*RedisRecordResponse) ProtoMessage 

func (*RedisRecordResponse) ProtoMessage()

func (*RedisRecordResponse) ProtoReflect added in v0.0.24 

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

func (*RedisRecordResponse) Reset 

func (x *RedisRecordResponse) Reset()

func (*RedisRecordResponse) String 

func (x *RedisRecordResponse) String() string

type RedisStreamsRecordRequest 

type RedisStreamsRecordRequest struct {
	Records []*records.RedisStreamsRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*RedisStreamsRecordRequest) Descriptor deprecated 

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

Deprecated: Use RedisStreamsRecordRequest.ProtoReflect.Descriptor instead.

func (*RedisStreamsRecordRequest) GetRecords 

func (x *RedisStreamsRecordRequest) GetRecords() []*records.RedisStreamsRecord

func (*RedisStreamsRecordRequest) ProtoMessage 

func (*RedisStreamsRecordRequest) ProtoMessage()

func (*RedisStreamsRecordRequest) ProtoReflect added in v0.0.24 

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

func (*RedisStreamsRecordRequest) Reset 

func (x *RedisStreamsRecordRequest) Reset()

func (*RedisStreamsRecordRequest) String 

func (x *RedisStreamsRecordRequest) String() string

type RedisStreamsRecordResponse 

type RedisStreamsRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RedisStreamsRecordResponse) Descriptor deprecated 

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

Deprecated: Use RedisStreamsRecordResponse.ProtoReflect.Descriptor instead.

func (*RedisStreamsRecordResponse) GetNumRecordsProcessed 

func (x *RedisStreamsRecordResponse) GetNumRecordsProcessed() int64

func (*RedisStreamsRecordResponse) GetStatus 

func (x *RedisStreamsRecordResponse) GetStatus() *common.Status

func (*RedisStreamsRecordResponse) ProtoMessage 

func (*RedisStreamsRecordResponse) ProtoMessage()

func (*RedisStreamsRecordResponse) ProtoReflect added in v0.0.24 

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

func (*RedisStreamsRecordResponse) Reset 

func (x *RedisStreamsRecordResponse) Reset()

func (*RedisStreamsRecordResponse) String 

func (x *RedisStreamsRecordResponse) String() string

type SQSRecordRequest 

type SQSRecordRequest struct {
	Records []*records.SQSRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*SQSRecordRequest) Descriptor deprecated 

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

Deprecated: Use SQSRecordRequest.ProtoReflect.Descriptor instead.

func (*SQSRecordRequest) GetRecords 

func (x *SQSRecordRequest) GetRecords() []*records.SQSRecord

func (*SQSRecordRequest) ProtoMessage 

func (*SQSRecordRequest) ProtoMessage()

func (*SQSRecordRequest) ProtoReflect added in v0.0.24 

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

func (*SQSRecordRequest) Reset 

func (x *SQSRecordRequest) Reset()

func (*SQSRecordRequest) String 

func (x *SQSRecordRequest) String() string

type SQSRecordResponse 

type SQSRecordResponse struct {
	NumRecordsProcessed int64          `protobuf:"varint,1,opt,name=num_records_processed,json=numRecordsProcessed,proto3" json:"num_records_processed,omitempty"`
	Status              *common.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*SQSRecordResponse) Descriptor deprecated 

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

Deprecated: Use SQSRecordResponse.ProtoReflect.Descriptor instead.

func (*SQSRecordResponse) GetNumRecordsProcessed 

func (x *SQSRecordResponse) GetNumRecordsProcessed() int64

func (*SQSRecordResponse) GetStatus 

func (x *SQSRecordResponse) GetStatus() *common.Status

func (*SQSRecordResponse) ProtoMessage 

func (*SQSRecordResponse) ProtoMessage()

func (*SQSRecordResponse) ProtoReflect added in v0.0.24 

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

func (*SQSRecordResponse) Reset 

func (x *SQSRecordResponse) Reset()

func (*SQSRecordResponse) String 

func (x *SQSRecordResponse) String() string

type TestRequest 

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

func (*TestRequest) Descriptor deprecated 

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

Deprecated: Use TestRequest.ProtoReflect.Descriptor instead.

func (*TestRequest) ProtoMessage 

func (*TestRequest) ProtoMessage()

func (*TestRequest) ProtoReflect added in v0.0.24 

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

func (*TestRequest) Reset 

func (x *TestRequest) Reset()

func (*TestRequest) String 

func (x *TestRequest) String() string

type TestResponse 

type TestResponse struct {
	Status *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*TestResponse) Descriptor deprecated 

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

Deprecated: Use TestResponse.ProtoReflect.Descriptor instead.

func (*TestResponse) GetStatus 

func (x *TestResponse) GetStatus() *common.Status

func (*TestResponse) ProtoMessage 

func (*TestResponse) ProtoMessage()

func (*TestResponse) ProtoReflect added in v0.0.24 

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

func (*TestResponse) Reset 

func (x *TestResponse) Reset()

func (*TestResponse) String 

func (x *TestResponse) String() string

type UnimplementedDProxyServer 

type UnimplementedDProxyServer struct {
}

UnimplementedDProxyServer should be embedded to have forward compatible implementations.

func (UnimplementedDProxyServer) Auth added in v0.0.10 

func (UnimplementedDProxyServer) Auth(context.Context, *events.AuthRequest) (*events.AuthResponse, error)

func (UnimplementedDProxyServer) Connect 

func (UnimplementedDProxyServer) Connect(*events.Tunnel, DProxy_ConnectServer) error

func (UnimplementedDProxyServer) DeleteTunnel added in v0.0.16 

func (UnimplementedDProxyServer) DeleteTunnel(context.Context, *events.DeleteTunnelRequest) (*events.DeleteTunnelResponse, error)

type UnimplementedGRPCCollectorServer 

type UnimplementedGRPCCollectorServer struct {
}

UnimplementedGRPCCollectorServer should be embedded to have forward compatible implementations.

func (UnimplementedGRPCCollectorServer) AddAMQPRecord 

func (UnimplementedGRPCCollectorServer) AddAMQPRecord(context.Context, *AMQPRecordRequest) (*AMQPRecordResponse, error)

func (UnimplementedGRPCCollectorServer) AddAzureRecord 

func (UnimplementedGRPCCollectorServer) AddAzureRecord(context.Context, *AzureRecordRequest) (*AzureRecordResponse, error)

func (UnimplementedGRPCCollectorServer) AddGCPRecord 

func (UnimplementedGRPCCollectorServer) AddGCPRecord(context.Context, *GCPRecordRequest) (*GCPRecordResponse, error)

func (UnimplementedGRPCCollectorServer) AddKafkaRecord 

func (UnimplementedGRPCCollectorServer) AddKafkaRecord(context.Context, *KafkaSinkRecordRequest) (*KafkaSinkRecordResponse, error)

func (UnimplementedGRPCCollectorServer) AddKubeMQRecord 

func (UnimplementedGRPCCollectorServer) AddKubeMQRecord(context.Context, *KubeMQRecordRequest) (*KubeMQRecordResponse, error)

func (UnimplementedGRPCCollectorServer) AddMQTTRecord 

func (UnimplementedGRPCCollectorServer) AddMQTTRecord(context.Context, *MQTTRecordRequest) (*MQTTRecordResponse, error)

func (UnimplementedGRPCCollectorServer) AddNATSJetStreamRecord added in v0.0.8 

func (UnimplementedGRPCCollectorServer) AddNATSJetStreamRecord(context.Context, *NATSJetStreamRecordRequest) (*NATSJetStreamRecordResponse, error)

func (UnimplementedGRPCCollectorServer) AddNATSRecord added in v0.0.7 

func (UnimplementedGRPCCollectorServer) AddNATSRecord(context.Context, *NATSRecordRequest) (*NATSRecordResponse, error)

func (UnimplementedGRPCCollectorServer) AddNATSStreamingRecord added in v0.0.8 

func (UnimplementedGRPCCollectorServer) AddNATSStreamingRecord(context.Context, *NATSStreamingRecordRequest) (*NATSStreamingRecordResponse, error)

func (UnimplementedGRPCCollectorServer) AddNSQRecord 

func (UnimplementedGRPCCollectorServer) AddNSQRecord(context.Context, *NSQRecordRequest) (*NSQRecordResponse, error)

func (UnimplementedGRPCCollectorServer) AddRecord 

func (UnimplementedGRPCCollectorServer) AddRecord(context.Context, *GenericRecordRequest) (*GenericRecordResponse, error)

func (UnimplementedGRPCCollectorServer) AddRedisRecord 

func (UnimplementedGRPCCollectorServer) AddRedisRecord(context.Context, *RedisRecordRequest) (*RedisRecordResponse, error)

func (UnimplementedGRPCCollectorServer) AddRedisStreamsRecord 

func (UnimplementedGRPCCollectorServer) AddRedisStreamsRecord(context.Context, *RedisStreamsRecordRequest) (*RedisStreamsRecordResponse, error)

func (UnimplementedGRPCCollectorServer) AddSQSRecord 

func (UnimplementedGRPCCollectorServer) AddSQSRecord(context.Context, *SQSRecordRequest) (*SQSRecordResponse, error)

func (UnimplementedGRPCCollectorServer) Test 

func (UnimplementedGRPCCollectorServer) Test(context.Context, *TestRequest) (*TestResponse, error)

type UnsafeDProxyServer added in v0.0.24 

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

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

type UnsafeGRPCCollectorServer added in v0.0.24 

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

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