rpcv1

package
v0.9.4 Latest Latest
Warning

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

 Go to latest Published: Mar 10, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AuditService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "inetmock.rpc.v1.AuditService",
	HandlerType: (*AuditServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterFileSink",
			Handler:    _AuditService_RegisterFileSink_Handler,
		},
		{
			MethodName: "RemoveFileSink",
			Handler:    _AuditService_RemoveFileSink_Handler,
		},
		{
			MethodName: "ListSinks",
			Handler:    _AuditService_ListSinks_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchEvents",
			Handler:       _AuditService_WatchEvents_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "rpc/v1/audit.proto",
}

AuditService_ServiceDesc is the grpc.ServiceDesc for AuditService 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 EndpointOrchestratorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "inetmock.rpc.v1.EndpointOrchestratorService",
	HandlerType: (*EndpointOrchestratorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListAllServingGroups",
			Handler:    _EndpointOrchestratorService_ListAllServingGroups_Handler,
		},
		{
			MethodName: "ListAllConfiguredGroups",
			Handler:    _EndpointOrchestratorService_ListAllConfiguredGroups_Handler,
		},
		{
			MethodName: "StartListenerGroup",
			Handler:    _EndpointOrchestratorService_StartListenerGroup_Handler,
		},
		{
			MethodName: "StartAllGroups",
			Handler:    _EndpointOrchestratorService_StartAllGroups_Handler,
		},
		{
			MethodName: "StopListenerGroup",
			Handler:    _EndpointOrchestratorService_StopListenerGroup_Handler,
		},
		{
			MethodName: "StopAllGroups",
			Handler:    _EndpointOrchestratorService_StopAllGroups_Handler,
		},
		{
			MethodName: "RestartListenerGroup",
			Handler:    _EndpointOrchestratorService_RestartListenerGroup_Handler,
		},
		{
			MethodName: "RestartAllGroups",
			Handler:    _EndpointOrchestratorService_RestartAllGroups_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpc/v1/endpoint.proto",
}

EndpointOrchestratorService_ServiceDesc is the grpc.ServiceDesc for EndpointOrchestratorService 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_rpc_v1_audit_proto protoreflect.FileDescriptor
View Source 
var File_rpc_v1_endpoint_proto protoreflect.FileDescriptor
View Source 
var File_rpc_v1_pcap_proto protoreflect.FileDescriptor
View Source 
var File_rpc_v1_pprof_proto protoreflect.FileDescriptor
View Source 
var PCAPService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "inetmock.rpc.v1.PCAPService",
	HandlerType: (*PCAPServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListAvailableDevices",
			Handler:    _PCAPService_ListAvailableDevices_Handler,
		},
		{
			MethodName: "ListActiveRecordings",
			Handler:    _PCAPService_ListActiveRecordings_Handler,
		},
		{
			MethodName: "StartPCAPFileRecording",
			Handler:    _PCAPService_StartPCAPFileRecording_Handler,
		},
		{
			MethodName: "StopPCAPFileRecording",
			Handler:    _PCAPService_StopPCAPFileRecording_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpc/v1/pcap.proto",
}

PCAPService_ServiceDesc is the grpc.ServiceDesc for PCAPService 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 ProfilingService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "inetmock.rpc.v1.ProfilingService",
	HandlerType: (*ProfilingServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ProfileDump",
			Handler:    _ProfilingService_ProfileDump_Handler,
		},
		{
			MethodName: "CPUProfile",
			Handler:    _ProfilingService_CPUProfile_Handler,
		},
		{
			MethodName: "Trace",
			Handler:    _ProfilingService_Trace_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpc/v1/pprof.proto",
}

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

Functions

func RegisterAuditServiceServer 

func RegisterAuditServiceServer(s grpc.ServiceRegistrar, srv AuditServiceServer)

func RegisterEndpointOrchestratorServiceServer added in v0.9.0 

func RegisterEndpointOrchestratorServiceServer(s grpc.ServiceRegistrar, srv EndpointOrchestratorServiceServer)

func RegisterPCAPServiceServer 

func RegisterPCAPServiceServer(s grpc.ServiceRegistrar, srv PCAPServiceServer)

func RegisterProfilingServiceServer added in v0.7.1 

func RegisterProfilingServiceServer(s grpc.ServiceRegistrar, srv ProfilingServiceServer)

Types

type AuditServiceClient 

type AuditServiceClient interface {
	WatchEvents(ctx context.Context, in *WatchEventsRequest, opts ...grpc.CallOption) (AuditService_WatchEventsClient, error)
	RegisterFileSink(ctx context.Context, in *RegisterFileSinkRequest, opts ...grpc.CallOption) (*RegisterFileSinkResponse, error)
	RemoveFileSink(ctx context.Context, in *RemoveFileSinkRequest, opts ...grpc.CallOption) (*RemoveFileSinkResponse, error)
	ListSinks(ctx context.Context, in *ListSinksRequest, opts ...grpc.CallOption) (*ListSinksResponse, error)
}

AuditServiceClient is the client API for AuditService 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 NewAuditServiceClient 

func NewAuditServiceClient(cc grpc.ClientConnInterface) AuditServiceClient

type AuditServiceServer 

type AuditServiceServer interface {
	WatchEvents(*WatchEventsRequest, AuditService_WatchEventsServer) error
	RegisterFileSink(context.Context, *RegisterFileSinkRequest) (*RegisterFileSinkResponse, error)
	RemoveFileSink(context.Context, *RemoveFileSinkRequest) (*RemoveFileSinkResponse, error)
	ListSinks(context.Context, *ListSinksRequest) (*ListSinksResponse, error)
	// contains filtered or unexported methods
}

AuditServiceServer is the server API for AuditService service. All implementations must embed UnimplementedAuditServiceServer for forward compatibility

type AuditService_WatchEventsClient 

type AuditService_WatchEventsClient interface {
	Recv() (*WatchEventsResponse, error)
	grpc.ClientStream
}

type AuditService_WatchEventsServer 

type AuditService_WatchEventsServer interface {
	Send(*WatchEventsResponse) error
	grpc.ServerStream
}

type CPUProfileRequest added in v0.7.1 

type CPUProfileRequest struct {
	ProfileDuration *durationpb.Duration `protobuf:"bytes,1,opt,name=profile_duration,json=profileDuration,proto3" json:"profile_duration,omitempty"`
	// contains filtered or unexported fields
}

func (*CPUProfileRequest) Descriptor deprecated added in v0.7.1 

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

Deprecated: Use CPUProfileRequest.ProtoReflect.Descriptor instead.

func (*CPUProfileRequest) GetProfileDuration added in v0.7.1 

func (x *CPUProfileRequest) GetProfileDuration() *durationpb.Duration

func (*CPUProfileRequest) ProtoMessage added in v0.7.1 

func (*CPUProfileRequest) ProtoMessage()

func (*CPUProfileRequest) ProtoReflect added in v0.7.1 

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

func (*CPUProfileRequest) Reset added in v0.7.1 

func (x *CPUProfileRequest) Reset()

func (*CPUProfileRequest) String added in v0.7.1 

func (x *CPUProfileRequest) String() string

type CPUProfileResponse added in v0.7.1 

type CPUProfileResponse struct {
	ProfileData []byte `protobuf:"bytes,1,opt,name=profile_data,json=profileData,proto3" json:"profile_data,omitempty"`
	// contains filtered or unexported fields
}

func (*CPUProfileResponse) Descriptor deprecated added in v0.7.1 

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

Deprecated: Use CPUProfileResponse.ProtoReflect.Descriptor instead.

func (*CPUProfileResponse) GetProfileData added in v0.7.1 

func (x *CPUProfileResponse) GetProfileData() []byte

func (*CPUProfileResponse) ProtoMessage added in v0.7.1 

func (*CPUProfileResponse) ProtoMessage()

func (*CPUProfileResponse) ProtoReflect added in v0.7.1 

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

func (*CPUProfileResponse) Reset added in v0.7.1 

func (x *CPUProfileResponse) Reset()

func (*CPUProfileResponse) String added in v0.7.1 

func (x *CPUProfileResponse) String() string

type EndpointOrchestratorServiceClient added in v0.9.0 

type EndpointOrchestratorServiceClient interface {
	ListAllServingGroups(ctx context.Context, in *ListAllServingGroupsRequest, opts ...grpc.CallOption) (*ListAllServingGroupsResponse, error)
	ListAllConfiguredGroups(ctx context.Context, in *ListAllConfiguredGroupsRequest, opts ...grpc.CallOption) (*ListAllConfiguredGroupsResponse, error)
	StartListenerGroup(ctx context.Context, in *StartListenerGroupRequest, opts ...grpc.CallOption) (*StartListenerGroupResponse, error)
	StartAllGroups(ctx context.Context, in *StartAllGroupsRequest, opts ...grpc.CallOption) (*StartAllGroupsResponse, error)
	StopListenerGroup(ctx context.Context, in *StopListenerGroupRequest, opts ...grpc.CallOption) (*StopListenerGroupResponse, error)
	StopAllGroups(ctx context.Context, in *StopAllGroupsRequest, opts ...grpc.CallOption) (*StopAllGroupsResponse, error)
	RestartListenerGroup(ctx context.Context, in *RestartListenerGroupRequest, opts ...grpc.CallOption) (*RestartListenerGroupResponse, error)
	RestartAllGroups(ctx context.Context, in *RestartAllGroupsRequest, opts ...grpc.CallOption) (*RestartAllGroupsResponse, error)
}

EndpointOrchestratorServiceClient is the client API for EndpointOrchestratorService 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 NewEndpointOrchestratorServiceClient added in v0.9.0 

func NewEndpointOrchestratorServiceClient(cc grpc.ClientConnInterface) EndpointOrchestratorServiceClient

type EndpointOrchestratorServiceServer added in v0.9.0 

type EndpointOrchestratorServiceServer interface {
	ListAllServingGroups(context.Context, *ListAllServingGroupsRequest) (*ListAllServingGroupsResponse, error)
	ListAllConfiguredGroups(context.Context, *ListAllConfiguredGroupsRequest) (*ListAllConfiguredGroupsResponse, error)
	StartListenerGroup(context.Context, *StartListenerGroupRequest) (*StartListenerGroupResponse, error)
	StartAllGroups(context.Context, *StartAllGroupsRequest) (*StartAllGroupsResponse, error)
	StopListenerGroup(context.Context, *StopListenerGroupRequest) (*StopListenerGroupResponse, error)
	StopAllGroups(context.Context, *StopAllGroupsRequest) (*StopAllGroupsResponse, error)
	RestartListenerGroup(context.Context, *RestartListenerGroupRequest) (*RestartListenerGroupResponse, error)
	RestartAllGroups(context.Context, *RestartAllGroupsRequest) (*RestartAllGroupsResponse, error)
	// contains filtered or unexported methods
}

EndpointOrchestratorServiceServer is the server API for EndpointOrchestratorService service. All implementations must embed UnimplementedEndpointOrchestratorServiceServer for forward compatibility

type ListActiveRecordingsRequest 

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

func (*ListActiveRecordingsRequest) Descriptor deprecated 

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

Deprecated: Use ListActiveRecordingsRequest.ProtoReflect.Descriptor instead.

func (*ListActiveRecordingsRequest) ProtoMessage 

func (*ListActiveRecordingsRequest) ProtoMessage()

func (*ListActiveRecordingsRequest) ProtoReflect 

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

func (*ListActiveRecordingsRequest) Reset 

func (x *ListActiveRecordingsRequest) Reset()

func (*ListActiveRecordingsRequest) String 

func (x *ListActiveRecordingsRequest) String() string

type ListActiveRecordingsResponse 

type ListActiveRecordingsResponse struct {
	Subscriptions []string `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListActiveRecordingsResponse) Descriptor deprecated 

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

Deprecated: Use ListActiveRecordingsResponse.ProtoReflect.Descriptor instead.

func (*ListActiveRecordingsResponse) GetSubscriptions 

func (x *ListActiveRecordingsResponse) GetSubscriptions() []string

func (*ListActiveRecordingsResponse) ProtoMessage 

func (*ListActiveRecordingsResponse) ProtoMessage()

func (*ListActiveRecordingsResponse) ProtoReflect 

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

func (*ListActiveRecordingsResponse) Reset 

func (x *ListActiveRecordingsResponse) Reset()

func (*ListActiveRecordingsResponse) String 

func (x *ListActiveRecordingsResponse) String() string

type ListAllConfiguredGroupsRequest added in v0.9.0 

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

func (*ListAllConfiguredGroupsRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ListAllConfiguredGroupsRequest.ProtoReflect.Descriptor instead.

func (*ListAllConfiguredGroupsRequest) ProtoMessage added in v0.9.0 

func (*ListAllConfiguredGroupsRequest) ProtoMessage()

func (*ListAllConfiguredGroupsRequest) ProtoReflect added in v0.9.0 

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

func (*ListAllConfiguredGroupsRequest) Reset added in v0.9.0 

func (x *ListAllConfiguredGroupsRequest) Reset()

func (*ListAllConfiguredGroupsRequest) String added in v0.9.0 

func (x *ListAllConfiguredGroupsRequest) String() string

type ListAllConfiguredGroupsResponse added in v0.9.0 

type ListAllConfiguredGroupsResponse struct {
	Groups []*ListenerGroup `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAllConfiguredGroupsResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ListAllConfiguredGroupsResponse.ProtoReflect.Descriptor instead.

func (*ListAllConfiguredGroupsResponse) GetGroups added in v0.9.0 

func (x *ListAllConfiguredGroupsResponse) GetGroups() []*ListenerGroup

func (*ListAllConfiguredGroupsResponse) ProtoMessage added in v0.9.0 

func (*ListAllConfiguredGroupsResponse) ProtoMessage()

func (*ListAllConfiguredGroupsResponse) ProtoReflect added in v0.9.0 

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

func (*ListAllConfiguredGroupsResponse) Reset added in v0.9.0 

func (x *ListAllConfiguredGroupsResponse) Reset()

func (*ListAllConfiguredGroupsResponse) String added in v0.9.0 

func (x *ListAllConfiguredGroupsResponse) String() string

type ListAllServingGroupsRequest added in v0.9.0 

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

func (*ListAllServingGroupsRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ListAllServingGroupsRequest.ProtoReflect.Descriptor instead.

func (*ListAllServingGroupsRequest) ProtoMessage added in v0.9.0 

func (*ListAllServingGroupsRequest) ProtoMessage()

func (*ListAllServingGroupsRequest) ProtoReflect added in v0.9.0 

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

func (*ListAllServingGroupsRequest) Reset added in v0.9.0 

func (x *ListAllServingGroupsRequest) Reset()

func (*ListAllServingGroupsRequest) String added in v0.9.0 

func (x *ListAllServingGroupsRequest) String() string

type ListAllServingGroupsResponse added in v0.9.0 

type ListAllServingGroupsResponse struct {
	Groups []*ListenerGroup `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAllServingGroupsResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ListAllServingGroupsResponse.ProtoReflect.Descriptor instead.

func (*ListAllServingGroupsResponse) GetGroups added in v0.9.0 

func (x *ListAllServingGroupsResponse) GetGroups() []*ListenerGroup

func (*ListAllServingGroupsResponse) ProtoMessage added in v0.9.0 

func (*ListAllServingGroupsResponse) ProtoMessage()

func (*ListAllServingGroupsResponse) ProtoReflect added in v0.9.0 

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

func (*ListAllServingGroupsResponse) Reset added in v0.9.0 

func (x *ListAllServingGroupsResponse) Reset()

func (*ListAllServingGroupsResponse) String added in v0.9.0 

func (x *ListAllServingGroupsResponse) String() string

type ListAvailableDevicesRequest 

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

func (*ListAvailableDevicesRequest) Descriptor deprecated 

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

Deprecated: Use ListAvailableDevicesRequest.ProtoReflect.Descriptor instead.

func (*ListAvailableDevicesRequest) ProtoMessage 

func (*ListAvailableDevicesRequest) ProtoMessage()

func (*ListAvailableDevicesRequest) ProtoReflect 

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

func (*ListAvailableDevicesRequest) Reset 

func (x *ListAvailableDevicesRequest) Reset()

func (*ListAvailableDevicesRequest) String 

func (x *ListAvailableDevicesRequest) String() string

type ListAvailableDevicesResponse 

type ListAvailableDevicesResponse struct {
	AvailableDevices []*ListAvailableDevicesResponse_PCAPDevice `protobuf:"bytes,1,rep,name=available_devices,json=availableDevices,proto3" json:"available_devices,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAvailableDevicesResponse) Descriptor deprecated 

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

Deprecated: Use ListAvailableDevicesResponse.ProtoReflect.Descriptor instead.

func (*ListAvailableDevicesResponse) GetAvailableDevices 

func (x *ListAvailableDevicesResponse) GetAvailableDevices() []*ListAvailableDevicesResponse_PCAPDevice

func (*ListAvailableDevicesResponse) ProtoMessage 

func (*ListAvailableDevicesResponse) ProtoMessage()

func (*ListAvailableDevicesResponse) ProtoReflect 

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

func (*ListAvailableDevicesResponse) Reset 

func (x *ListAvailableDevicesResponse) Reset()

func (*ListAvailableDevicesResponse) String 

func (x *ListAvailableDevicesResponse) String() string

type ListAvailableDevicesResponse_PCAPDevice 

type ListAvailableDevicesResponse_PCAPDevice struct {
	Name      string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Addresses [][]byte `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAvailableDevicesResponse_PCAPDevice) Descriptor deprecated 

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

Deprecated: Use ListAvailableDevicesResponse_PCAPDevice.ProtoReflect.Descriptor instead.

func (*ListAvailableDevicesResponse_PCAPDevice) GetAddresses 

func (x *ListAvailableDevicesResponse_PCAPDevice) GetAddresses() [][]byte

func (*ListAvailableDevicesResponse_PCAPDevice) GetName 

func (x *ListAvailableDevicesResponse_PCAPDevice) GetName() string

func (*ListAvailableDevicesResponse_PCAPDevice) ProtoMessage 

func (*ListAvailableDevicesResponse_PCAPDevice) ProtoMessage()

func (*ListAvailableDevicesResponse_PCAPDevice) ProtoReflect 

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

func (*ListAvailableDevicesResponse_PCAPDevice) Reset 

func (x *ListAvailableDevicesResponse_PCAPDevice) Reset()

func (*ListAvailableDevicesResponse_PCAPDevice) String 

func (x *ListAvailableDevicesResponse_PCAPDevice) String() string

type ListSinksRequest 

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

func (*ListSinksRequest) Descriptor deprecated 

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

Deprecated: Use ListSinksRequest.ProtoReflect.Descriptor instead.

func (*ListSinksRequest) ProtoMessage 

func (*ListSinksRequest) ProtoMessage()

func (*ListSinksRequest) ProtoReflect 

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

func (*ListSinksRequest) Reset 

func (x *ListSinksRequest) Reset()

func (*ListSinksRequest) String 

func (x *ListSinksRequest) String() string

type ListSinksResponse 

type ListSinksResponse struct {
	Sinks []string `protobuf:"bytes,1,rep,name=sinks,proto3" json:"sinks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSinksResponse) Descriptor deprecated 

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

Deprecated: Use ListSinksResponse.ProtoReflect.Descriptor instead.

func (*ListSinksResponse) GetSinks 

func (x *ListSinksResponse) GetSinks() []string

func (*ListSinksResponse) ProtoMessage 

func (*ListSinksResponse) ProtoMessage()

func (*ListSinksResponse) ProtoReflect 

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

func (*ListSinksResponse) Reset 

func (x *ListSinksResponse) Reset()

func (*ListSinksResponse) String 

func (x *ListSinksResponse) String() string

type ListenerGroup added in v0.9.0 

type ListenerGroup struct {
	Name      string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Endpoints []string `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*ListenerGroup) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ListenerGroup.ProtoReflect.Descriptor instead.

func (*ListenerGroup) GetEndpoints added in v0.9.0 

func (x *ListenerGroup) GetEndpoints() []string

func (*ListenerGroup) GetName added in v0.9.0 

func (x *ListenerGroup) GetName() string

func (*ListenerGroup) ProtoMessage added in v0.9.0 

func (*ListenerGroup) ProtoMessage()

func (*ListenerGroup) ProtoReflect added in v0.9.0 

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

func (*ListenerGroup) Reset added in v0.9.0 

func (x *ListenerGroup) Reset()

func (*ListenerGroup) String added in v0.9.0 

func (x *ListenerGroup) String() string

type PCAPServiceClient 

type PCAPServiceClient interface {
	ListAvailableDevices(ctx context.Context, in *ListAvailableDevicesRequest, opts ...grpc.CallOption) (*ListAvailableDevicesResponse, error)
	ListActiveRecordings(ctx context.Context, in *ListActiveRecordingsRequest, opts ...grpc.CallOption) (*ListActiveRecordingsResponse, error)
	StartPCAPFileRecording(ctx context.Context, in *StartPCAPFileRecordingRequest, opts ...grpc.CallOption) (*StartPCAPFileRecordingResponse, error)
	StopPCAPFileRecording(ctx context.Context, in *StopPCAPFileRecordingRequest, opts ...grpc.CallOption) (*StopPCAPFileRecordingResponse, error)
}

PCAPServiceClient is the client API for PCAPService 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 NewPCAPServiceClient 

func NewPCAPServiceClient(cc grpc.ClientConnInterface) PCAPServiceClient

type PCAPServiceServer 

type PCAPServiceServer interface {
	ListAvailableDevices(context.Context, *ListAvailableDevicesRequest) (*ListAvailableDevicesResponse, error)
	ListActiveRecordings(context.Context, *ListActiveRecordingsRequest) (*ListActiveRecordingsResponse, error)
	StartPCAPFileRecording(context.Context, *StartPCAPFileRecordingRequest) (*StartPCAPFileRecordingResponse, error)
	StopPCAPFileRecording(context.Context, *StopPCAPFileRecordingRequest) (*StopPCAPFileRecordingResponse, error)
	// contains filtered or unexported methods
}

PCAPServiceServer is the server API for PCAPService service. All implementations must embed UnimplementedPCAPServiceServer for forward compatibility

type ProfileDumpRequest added in v0.7.1 

type ProfileDumpRequest struct {
	ProfileName string `protobuf:"bytes,1,opt,name=profile_name,json=profileName,proto3" json:"profile_name,omitempty"`
	Debug       int32  `protobuf:"varint,2,opt,name=debug,proto3" json:"debug,omitempty"`
	// this applies only for 'heap' profile
	GcBeforeDump bool `protobuf:"varint,3,opt,name=gc_before_dump,json=gcBeforeDump,proto3" json:"gc_before_dump,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileDumpRequest) Descriptor deprecated added in v0.7.1 

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

Deprecated: Use ProfileDumpRequest.ProtoReflect.Descriptor instead.

func (*ProfileDumpRequest) GetDebug added in v0.7.1 

func (x *ProfileDumpRequest) GetDebug() int32

func (*ProfileDumpRequest) GetGcBeforeDump added in v0.7.1 

func (x *ProfileDumpRequest) GetGcBeforeDump() bool

func (*ProfileDumpRequest) GetProfileName added in v0.7.1 

func (x *ProfileDumpRequest) GetProfileName() string

func (*ProfileDumpRequest) ProtoMessage added in v0.7.1 

func (*ProfileDumpRequest) ProtoMessage()

func (*ProfileDumpRequest) ProtoReflect added in v0.7.1 

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

func (*ProfileDumpRequest) Reset added in v0.7.1 

func (x *ProfileDumpRequest) Reset()

func (*ProfileDumpRequest) String added in v0.7.1 

func (x *ProfileDumpRequest) String() string

type ProfileDumpResponse added in v0.7.1 

type ProfileDumpResponse struct {
	ProfileData []byte `protobuf:"bytes,1,opt,name=profile_data,json=profileData,proto3" json:"profile_data,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileDumpResponse) Descriptor deprecated added in v0.7.1 

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

Deprecated: Use ProfileDumpResponse.ProtoReflect.Descriptor instead.

func (*ProfileDumpResponse) GetProfileData added in v0.7.1 

func (x *ProfileDumpResponse) GetProfileData() []byte

func (*ProfileDumpResponse) ProtoMessage added in v0.7.1 

func (*ProfileDumpResponse) ProtoMessage()

func (*ProfileDumpResponse) ProtoReflect added in v0.7.1 

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

func (*ProfileDumpResponse) Reset added in v0.7.1 

func (x *ProfileDumpResponse) Reset()

func (*ProfileDumpResponse) String added in v0.7.1 

func (x *ProfileDumpResponse) String() string

type ProfilingServiceClient added in v0.7.1 

type ProfilingServiceClient interface {
	ProfileDump(ctx context.Context, in *ProfileDumpRequest, opts ...grpc.CallOption) (*ProfileDumpResponse, error)
	CPUProfile(ctx context.Context, in *CPUProfileRequest, opts ...grpc.CallOption) (*CPUProfileResponse, error)
	Trace(ctx context.Context, in *TraceRequest, opts ...grpc.CallOption) (*TraceResponse, error)
}

ProfilingServiceClient is the client API for ProfilingService 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 NewProfilingServiceClient added in v0.7.1 

func NewProfilingServiceClient(cc grpc.ClientConnInterface) ProfilingServiceClient

type ProfilingServiceServer added in v0.7.1 

type ProfilingServiceServer interface {
	ProfileDump(context.Context, *ProfileDumpRequest) (*ProfileDumpResponse, error)
	CPUProfile(context.Context, *CPUProfileRequest) (*CPUProfileResponse, error)
	Trace(context.Context, *TraceRequest) (*TraceResponse, error)
	// contains filtered or unexported methods
}

ProfilingServiceServer is the server API for ProfilingService service. All implementations must embed UnimplementedProfilingServiceServer for forward compatibility

type RegisterFileSinkRequest 

type RegisterFileSinkRequest struct {
	TargetPath string `protobuf:"bytes,1,opt,name=target_path,json=targetPath,proto3" json:"target_path,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterFileSinkRequest) Descriptor deprecated 

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

Deprecated: Use RegisterFileSinkRequest.ProtoReflect.Descriptor instead.

func (*RegisterFileSinkRequest) GetTargetPath 

func (x *RegisterFileSinkRequest) GetTargetPath() string

func (*RegisterFileSinkRequest) ProtoMessage 

func (*RegisterFileSinkRequest) ProtoMessage()

func (*RegisterFileSinkRequest) ProtoReflect 

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

func (*RegisterFileSinkRequest) Reset 

func (x *RegisterFileSinkRequest) Reset()

func (*RegisterFileSinkRequest) String 

func (x *RegisterFileSinkRequest) String() string

type RegisterFileSinkResponse 

type RegisterFileSinkResponse struct {
	ResolvedPath string `protobuf:"bytes,1,opt,name=resolved_path,json=resolvedPath,proto3" json:"resolved_path,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterFileSinkResponse) Descriptor deprecated 

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

Deprecated: Use RegisterFileSinkResponse.ProtoReflect.Descriptor instead.

func (*RegisterFileSinkResponse) GetResolvedPath 

func (x *RegisterFileSinkResponse) GetResolvedPath() string

func (*RegisterFileSinkResponse) ProtoMessage 

func (*RegisterFileSinkResponse) ProtoMessage()

func (*RegisterFileSinkResponse) ProtoReflect 

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

func (*RegisterFileSinkResponse) Reset 

func (x *RegisterFileSinkResponse) Reset()

func (*RegisterFileSinkResponse) String 

func (x *RegisterFileSinkResponse) String() string

type RemoveFileSinkRequest 

type RemoveFileSinkRequest struct {
	TargetPath string `protobuf:"bytes,1,opt,name=target_path,json=targetPath,proto3" json:"target_path,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveFileSinkRequest) Descriptor deprecated 

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

Deprecated: Use RemoveFileSinkRequest.ProtoReflect.Descriptor instead.

func (*RemoveFileSinkRequest) GetTargetPath 

func (x *RemoveFileSinkRequest) GetTargetPath() string

func (*RemoveFileSinkRequest) ProtoMessage 

func (*RemoveFileSinkRequest) ProtoMessage()

func (*RemoveFileSinkRequest) ProtoReflect 

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

func (*RemoveFileSinkRequest) Reset 

func (x *RemoveFileSinkRequest) Reset()

func (*RemoveFileSinkRequest) String 

func (x *RemoveFileSinkRequest) String() string

type RemoveFileSinkResponse 

type RemoveFileSinkResponse struct {
	SinkGotRemoved bool `protobuf:"varint,1,opt,name=sink_got_removed,json=sinkGotRemoved,proto3" json:"sink_got_removed,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveFileSinkResponse) Descriptor deprecated 

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

Deprecated: Use RemoveFileSinkResponse.ProtoReflect.Descriptor instead.

func (*RemoveFileSinkResponse) GetSinkGotRemoved 

func (x *RemoveFileSinkResponse) GetSinkGotRemoved() bool

func (*RemoveFileSinkResponse) ProtoMessage 

func (*RemoveFileSinkResponse) ProtoMessage()

func (*RemoveFileSinkResponse) ProtoReflect 

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

func (*RemoveFileSinkResponse) Reset 

func (x *RemoveFileSinkResponse) Reset()

func (*RemoveFileSinkResponse) String 

func (x *RemoveFileSinkResponse) String() string

type RestartAllGroupsRequest added in v0.9.0 

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

func (*RestartAllGroupsRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use RestartAllGroupsRequest.ProtoReflect.Descriptor instead.

func (*RestartAllGroupsRequest) ProtoMessage added in v0.9.0 

func (*RestartAllGroupsRequest) ProtoMessage()

func (*RestartAllGroupsRequest) ProtoReflect added in v0.9.0 

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

func (*RestartAllGroupsRequest) Reset added in v0.9.0 

func (x *RestartAllGroupsRequest) Reset()

func (*RestartAllGroupsRequest) String added in v0.9.0 

func (x *RestartAllGroupsRequest) String() string

type RestartAllGroupsResponse added in v0.9.0 

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

func (*RestartAllGroupsResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use RestartAllGroupsResponse.ProtoReflect.Descriptor instead.

func (*RestartAllGroupsResponse) ProtoMessage added in v0.9.0 

func (*RestartAllGroupsResponse) ProtoMessage()

func (*RestartAllGroupsResponse) ProtoReflect added in v0.9.0 

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

func (*RestartAllGroupsResponse) Reset added in v0.9.0 

func (x *RestartAllGroupsResponse) Reset()

func (*RestartAllGroupsResponse) String added in v0.9.0 

func (x *RestartAllGroupsResponse) String() string

type RestartListenerGroupRequest added in v0.9.0 

type RestartListenerGroupRequest struct {
	GroupName string `protobuf:"bytes,1,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RestartListenerGroupRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use RestartListenerGroupRequest.ProtoReflect.Descriptor instead.

func (*RestartListenerGroupRequest) GetGroupName added in v0.9.0 

func (x *RestartListenerGroupRequest) GetGroupName() string

func (*RestartListenerGroupRequest) ProtoMessage added in v0.9.0 

func (*RestartListenerGroupRequest) ProtoMessage()

func (*RestartListenerGroupRequest) ProtoReflect added in v0.9.0 

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

func (*RestartListenerGroupRequest) Reset added in v0.9.0 

func (x *RestartListenerGroupRequest) Reset()

func (*RestartListenerGroupRequest) String added in v0.9.0 

func (x *RestartListenerGroupRequest) String() string

type RestartListenerGroupResponse added in v0.9.0 

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

func (*RestartListenerGroupResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use RestartListenerGroupResponse.ProtoReflect.Descriptor instead.

func (*RestartListenerGroupResponse) ProtoMessage added in v0.9.0 

func (*RestartListenerGroupResponse) ProtoMessage()

func (*RestartListenerGroupResponse) ProtoReflect added in v0.9.0 

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

func (*RestartListenerGroupResponse) Reset added in v0.9.0 

func (x *RestartListenerGroupResponse) Reset()

func (*RestartListenerGroupResponse) String added in v0.9.0 

func (x *RestartListenerGroupResponse) String() string

type StartAllGroupsRequest added in v0.9.0 

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

func (*StartAllGroupsRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use StartAllGroupsRequest.ProtoReflect.Descriptor instead.

func (*StartAllGroupsRequest) ProtoMessage added in v0.9.0 

func (*StartAllGroupsRequest) ProtoMessage()

func (*StartAllGroupsRequest) ProtoReflect added in v0.9.0 

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

func (*StartAllGroupsRequest) Reset added in v0.9.0 

func (x *StartAllGroupsRequest) Reset()

func (*StartAllGroupsRequest) String added in v0.9.0 

func (x *StartAllGroupsRequest) String() string

type StartAllGroupsResponse added in v0.9.0 

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

func (*StartAllGroupsResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use StartAllGroupsResponse.ProtoReflect.Descriptor instead.

func (*StartAllGroupsResponse) ProtoMessage added in v0.9.0 

func (*StartAllGroupsResponse) ProtoMessage()

func (*StartAllGroupsResponse) ProtoReflect added in v0.9.0 

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

func (*StartAllGroupsResponse) Reset added in v0.9.0 

func (x *StartAllGroupsResponse) Reset()

func (*StartAllGroupsResponse) String added in v0.9.0 

func (x *StartAllGroupsResponse) String() string

type StartListenerGroupRequest added in v0.9.0 

type StartListenerGroupRequest struct {
	GroupName string `protobuf:"bytes,1,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// contains filtered or unexported fields
}

func (*StartListenerGroupRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use StartListenerGroupRequest.ProtoReflect.Descriptor instead.

func (*StartListenerGroupRequest) GetGroupName added in v0.9.0 

func (x *StartListenerGroupRequest) GetGroupName() string

func (*StartListenerGroupRequest) ProtoMessage added in v0.9.0 

func (*StartListenerGroupRequest) ProtoMessage()

func (*StartListenerGroupRequest) ProtoReflect added in v0.9.0 

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

func (*StartListenerGroupRequest) Reset added in v0.9.0 

func (x *StartListenerGroupRequest) Reset()

func (*StartListenerGroupRequest) String added in v0.9.0 

func (x *StartListenerGroupRequest) String() string

type StartListenerGroupResponse added in v0.9.0 

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

func (*StartListenerGroupResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use StartListenerGroupResponse.ProtoReflect.Descriptor instead.

func (*StartListenerGroupResponse) ProtoMessage added in v0.9.0 

func (*StartListenerGroupResponse) ProtoMessage()

func (*StartListenerGroupResponse) ProtoReflect added in v0.9.0 

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

func (*StartListenerGroupResponse) Reset added in v0.9.0 

func (x *StartListenerGroupResponse) Reset()

func (*StartListenerGroupResponse) String added in v0.9.0 

func (x *StartListenerGroupResponse) String() string

type StartPCAPFileRecordingRequest 

type StartPCAPFileRecordingRequest struct {
	Device      string               `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	TargetPath  string               `protobuf:"bytes,2,opt,name=target_path,json=targetPath,proto3" json:"target_path,omitempty"`
	Promiscuous bool                 `protobuf:"varint,3,opt,name=promiscuous,proto3" json:"promiscuous,omitempty"`
	ReadTimeout *durationpb.Duration `protobuf:"bytes,4,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*StartPCAPFileRecordingRequest) Descriptor deprecated 

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

Deprecated: Use StartPCAPFileRecordingRequest.ProtoReflect.Descriptor instead.

func (*StartPCAPFileRecordingRequest) GetDevice 

func (x *StartPCAPFileRecordingRequest) GetDevice() string

func (*StartPCAPFileRecordingRequest) GetPromiscuous 

func (x *StartPCAPFileRecordingRequest) GetPromiscuous() bool

func (*StartPCAPFileRecordingRequest) GetReadTimeout 

func (x *StartPCAPFileRecordingRequest) GetReadTimeout() *durationpb.Duration

func (*StartPCAPFileRecordingRequest) GetTargetPath 

func (x *StartPCAPFileRecordingRequest) GetTargetPath() string

func (*StartPCAPFileRecordingRequest) ProtoMessage 

func (*StartPCAPFileRecordingRequest) ProtoMessage()

func (*StartPCAPFileRecordingRequest) ProtoReflect 

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

func (*StartPCAPFileRecordingRequest) Reset 

func (x *StartPCAPFileRecordingRequest) Reset()

func (*StartPCAPFileRecordingRequest) String 

func (x *StartPCAPFileRecordingRequest) String() string

type StartPCAPFileRecordingResponse 

type StartPCAPFileRecordingResponse struct {
	ResolvedPath string `protobuf:"bytes,1,opt,name=resolved_path,json=resolvedPath,proto3" json:"resolved_path,omitempty"`
	ConsumerKey  string `protobuf:"bytes,2,opt,name=consumer_key,json=consumerKey,proto3" json:"consumer_key,omitempty"`
	// contains filtered or unexported fields
}

func (*StartPCAPFileRecordingResponse) Descriptor deprecated 

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

Deprecated: Use StartPCAPFileRecordingResponse.ProtoReflect.Descriptor instead.

func (*StartPCAPFileRecordingResponse) GetConsumerKey added in v0.5.1 

func (x *StartPCAPFileRecordingResponse) GetConsumerKey() string

func (*StartPCAPFileRecordingResponse) GetResolvedPath 

func (x *StartPCAPFileRecordingResponse) GetResolvedPath() string

func (*StartPCAPFileRecordingResponse) ProtoMessage 

func (*StartPCAPFileRecordingResponse) ProtoMessage()

func (*StartPCAPFileRecordingResponse) ProtoReflect 

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

func (*StartPCAPFileRecordingResponse) Reset 

func (x *StartPCAPFileRecordingResponse) Reset()

func (*StartPCAPFileRecordingResponse) String 

func (x *StartPCAPFileRecordingResponse) String() string

type StopAllGroupsRequest added in v0.9.0 

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

func (*StopAllGroupsRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use StopAllGroupsRequest.ProtoReflect.Descriptor instead.

func (*StopAllGroupsRequest) ProtoMessage added in v0.9.0 

func (*StopAllGroupsRequest) ProtoMessage()

func (*StopAllGroupsRequest) ProtoReflect added in v0.9.0 

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

func (*StopAllGroupsRequest) Reset added in v0.9.0 

func (x *StopAllGroupsRequest) Reset()

func (*StopAllGroupsRequest) String added in v0.9.0 

func (x *StopAllGroupsRequest) String() string

type StopAllGroupsResponse added in v0.9.0 

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

func (*StopAllGroupsResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use StopAllGroupsResponse.ProtoReflect.Descriptor instead.

func (*StopAllGroupsResponse) ProtoMessage added in v0.9.0 

func (*StopAllGroupsResponse) ProtoMessage()

func (*StopAllGroupsResponse) ProtoReflect added in v0.9.0 

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

func (*StopAllGroupsResponse) Reset added in v0.9.0 

func (x *StopAllGroupsResponse) Reset()

func (*StopAllGroupsResponse) String added in v0.9.0 

func (x *StopAllGroupsResponse) String() string

type StopListenerGroupRequest added in v0.9.0 

type StopListenerGroupRequest struct {
	GroupName string `protobuf:"bytes,1,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// contains filtered or unexported fields
}

func (*StopListenerGroupRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use StopListenerGroupRequest.ProtoReflect.Descriptor instead.

func (*StopListenerGroupRequest) GetGroupName added in v0.9.0 

func (x *StopListenerGroupRequest) GetGroupName() string

func (*StopListenerGroupRequest) ProtoMessage added in v0.9.0 

func (*StopListenerGroupRequest) ProtoMessage()

func (*StopListenerGroupRequest) ProtoReflect added in v0.9.0 

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

func (*StopListenerGroupRequest) Reset added in v0.9.0 

func (x *StopListenerGroupRequest) Reset()

func (*StopListenerGroupRequest) String added in v0.9.0 

func (x *StopListenerGroupRequest) String() string

type StopListenerGroupResponse added in v0.9.0 

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

func (*StopListenerGroupResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use StopListenerGroupResponse.ProtoReflect.Descriptor instead.

func (*StopListenerGroupResponse) ProtoMessage added in v0.9.0 

func (*StopListenerGroupResponse) ProtoMessage()

func (*StopListenerGroupResponse) ProtoReflect added in v0.9.0 

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

func (*StopListenerGroupResponse) Reset added in v0.9.0 

func (x *StopListenerGroupResponse) Reset()

func (*StopListenerGroupResponse) String added in v0.9.0 

func (x *StopListenerGroupResponse) String() string

type StopPCAPFileRecordingRequest added in v0.4.0 

type StopPCAPFileRecordingRequest struct {
	ConsumerKey string `protobuf:"bytes,1,opt,name=consumer_key,json=consumerKey,proto3" json:"consumer_key,omitempty"`
	// contains filtered or unexported fields
}

func (*StopPCAPFileRecordingRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use StopPCAPFileRecordingRequest.ProtoReflect.Descriptor instead.

func (*StopPCAPFileRecordingRequest) GetConsumerKey added in v0.4.0 

func (x *StopPCAPFileRecordingRequest) GetConsumerKey() string

func (*StopPCAPFileRecordingRequest) ProtoMessage added in v0.4.0 

func (*StopPCAPFileRecordingRequest) ProtoMessage()

func (*StopPCAPFileRecordingRequest) ProtoReflect added in v0.4.0 

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

func (*StopPCAPFileRecordingRequest) Reset added in v0.4.0 

func (x *StopPCAPFileRecordingRequest) Reset()

func (*StopPCAPFileRecordingRequest) String added in v0.4.0 

func (x *StopPCAPFileRecordingRequest) String() string

type StopPCAPFileRecordingResponse added in v0.4.0 

type StopPCAPFileRecordingResponse struct {
	Removed bool `protobuf:"varint,1,opt,name=removed,proto3" json:"removed,omitempty"`
	// contains filtered or unexported fields
}

func (*StopPCAPFileRecordingResponse) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use StopPCAPFileRecordingResponse.ProtoReflect.Descriptor instead.

func (*StopPCAPFileRecordingResponse) GetRemoved added in v0.4.0 

func (x *StopPCAPFileRecordingResponse) GetRemoved() bool

func (*StopPCAPFileRecordingResponse) ProtoMessage added in v0.4.0 

func (*StopPCAPFileRecordingResponse) ProtoMessage()

func (*StopPCAPFileRecordingResponse) ProtoReflect added in v0.4.0 

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

func (*StopPCAPFileRecordingResponse) Reset added in v0.4.0 

func (x *StopPCAPFileRecordingResponse) Reset()

func (*StopPCAPFileRecordingResponse) String added in v0.4.0 

func (x *StopPCAPFileRecordingResponse) String() string

type TraceRequest added in v0.7.1 

type TraceRequest struct {
	TraceDuration *durationpb.Duration `protobuf:"bytes,1,opt,name=trace_duration,json=traceDuration,proto3" json:"trace_duration,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceRequest) Descriptor deprecated added in v0.7.1 

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

Deprecated: Use TraceRequest.ProtoReflect.Descriptor instead.

func (*TraceRequest) GetTraceDuration added in v0.7.1 

func (x *TraceRequest) GetTraceDuration() *durationpb.Duration

func (*TraceRequest) ProtoMessage added in v0.7.1 

func (*TraceRequest) ProtoMessage()

func (*TraceRequest) ProtoReflect added in v0.7.1 

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

func (*TraceRequest) Reset added in v0.7.1 

func (x *TraceRequest) Reset()

func (*TraceRequest) String added in v0.7.1 

func (x *TraceRequest) String() string

type TraceResponse added in v0.7.1 

type TraceResponse struct {
	ProfileData []byte `protobuf:"bytes,1,opt,name=profile_data,json=profileData,proto3" json:"profile_data,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceResponse) Descriptor deprecated added in v0.7.1 

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

Deprecated: Use TraceResponse.ProtoReflect.Descriptor instead.

func (*TraceResponse) GetProfileData added in v0.7.1 

func (x *TraceResponse) GetProfileData() []byte

func (*TraceResponse) ProtoMessage added in v0.7.1 

func (*TraceResponse) ProtoMessage()

func (*TraceResponse) ProtoReflect added in v0.7.1 

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

func (*TraceResponse) Reset added in v0.7.1 

func (x *TraceResponse) Reset()

func (*TraceResponse) String added in v0.7.1 

func (x *TraceResponse) String() string

type UnimplementedAuditServiceServer 

type UnimplementedAuditServiceServer struct {
}

UnimplementedAuditServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAuditServiceServer) ListSinks 

func (UnimplementedAuditServiceServer) ListSinks(context.Context, *ListSinksRequest) (*ListSinksResponse, error)

func (UnimplementedAuditServiceServer) RegisterFileSink 

func (UnimplementedAuditServiceServer) RegisterFileSink(context.Context, *RegisterFileSinkRequest) (*RegisterFileSinkResponse, error)

func (UnimplementedAuditServiceServer) RemoveFileSink 

func (UnimplementedAuditServiceServer) RemoveFileSink(context.Context, *RemoveFileSinkRequest) (*RemoveFileSinkResponse, error)

func (UnimplementedAuditServiceServer) WatchEvents 

func (UnimplementedAuditServiceServer) WatchEvents(*WatchEventsRequest, AuditService_WatchEventsServer) error

type UnimplementedEndpointOrchestratorServiceServer added in v0.9.0 

type UnimplementedEndpointOrchestratorServiceServer struct {
}

UnimplementedEndpointOrchestratorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEndpointOrchestratorServiceServer) ListAllConfiguredGroups added in v0.9.0 

func (UnimplementedEndpointOrchestratorServiceServer) ListAllConfiguredGroups(context.Context, *ListAllConfiguredGroupsRequest) (*ListAllConfiguredGroupsResponse, error)

func (UnimplementedEndpointOrchestratorServiceServer) ListAllServingGroups added in v0.9.0 

func (UnimplementedEndpointOrchestratorServiceServer) ListAllServingGroups(context.Context, *ListAllServingGroupsRequest) (*ListAllServingGroupsResponse, error)

func (UnimplementedEndpointOrchestratorServiceServer) RestartAllGroups added in v0.9.0 

func (UnimplementedEndpointOrchestratorServiceServer) RestartAllGroups(context.Context, *RestartAllGroupsRequest) (*RestartAllGroupsResponse, error)

func (UnimplementedEndpointOrchestratorServiceServer) RestartListenerGroup added in v0.9.0 

func (UnimplementedEndpointOrchestratorServiceServer) RestartListenerGroup(context.Context, *RestartListenerGroupRequest) (*RestartListenerGroupResponse, error)

func (UnimplementedEndpointOrchestratorServiceServer) StartAllGroups added in v0.9.0 

func (UnimplementedEndpointOrchestratorServiceServer) StartAllGroups(context.Context, *StartAllGroupsRequest) (*StartAllGroupsResponse, error)

func (UnimplementedEndpointOrchestratorServiceServer) StartListenerGroup added in v0.9.0 

func (UnimplementedEndpointOrchestratorServiceServer) StartListenerGroup(context.Context, *StartListenerGroupRequest) (*StartListenerGroupResponse, error)

func (UnimplementedEndpointOrchestratorServiceServer) StopAllGroups added in v0.9.0 

func (UnimplementedEndpointOrchestratorServiceServer) StopAllGroups(context.Context, *StopAllGroupsRequest) (*StopAllGroupsResponse, error)

func (UnimplementedEndpointOrchestratorServiceServer) StopListenerGroup added in v0.9.0 

func (UnimplementedEndpointOrchestratorServiceServer) StopListenerGroup(context.Context, *StopListenerGroupRequest) (*StopListenerGroupResponse, error)

type UnimplementedPCAPServiceServer 

type UnimplementedPCAPServiceServer struct {
}

UnimplementedPCAPServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPCAPServiceServer) ListActiveRecordings 

func (UnimplementedPCAPServiceServer) ListActiveRecordings(context.Context, *ListActiveRecordingsRequest) (*ListActiveRecordingsResponse, error)

func (UnimplementedPCAPServiceServer) ListAvailableDevices 

func (UnimplementedPCAPServiceServer) ListAvailableDevices(context.Context, *ListAvailableDevicesRequest) (*ListAvailableDevicesResponse, error)

func (UnimplementedPCAPServiceServer) StartPCAPFileRecording 

func (UnimplementedPCAPServiceServer) StartPCAPFileRecording(context.Context, *StartPCAPFileRecordingRequest) (*StartPCAPFileRecordingResponse, error)

func (UnimplementedPCAPServiceServer) StopPCAPFileRecording added in v0.4.0 

func (UnimplementedPCAPServiceServer) StopPCAPFileRecording(context.Context, *StopPCAPFileRecordingRequest) (*StopPCAPFileRecordingResponse, error)

type UnimplementedProfilingServiceServer added in v0.7.1 

type UnimplementedProfilingServiceServer struct {
}

UnimplementedProfilingServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProfilingServiceServer) CPUProfile added in v0.7.1 

func (UnimplementedProfilingServiceServer) CPUProfile(context.Context, *CPUProfileRequest) (*CPUProfileResponse, error)

func (UnimplementedProfilingServiceServer) ProfileDump added in v0.7.1 

func (UnimplementedProfilingServiceServer) ProfileDump(context.Context, *ProfileDumpRequest) (*ProfileDumpResponse, error)

func (UnimplementedProfilingServiceServer) Trace added in v0.7.1 

func (UnimplementedProfilingServiceServer) Trace(context.Context, *TraceRequest) (*TraceResponse, error)

type UnsafeAuditServiceServer 

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

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

type UnsafeEndpointOrchestratorServiceServer added in v0.9.0 

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

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

type UnsafePCAPServiceServer 

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

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

type UnsafeProfilingServiceServer added in v0.7.1 

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

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

type WatchEventsRequest 

type WatchEventsRequest struct {
	WatcherName string `protobuf:"bytes,1,opt,name=watcher_name,json=watcherName,proto3" json:"watcher_name,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchEventsRequest) Descriptor deprecated 

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

Deprecated: Use WatchEventsRequest.ProtoReflect.Descriptor instead.

func (*WatchEventsRequest) GetWatcherName 

func (x *WatchEventsRequest) GetWatcherName() string

func (*WatchEventsRequest) ProtoMessage 

func (*WatchEventsRequest) ProtoMessage()

func (*WatchEventsRequest) ProtoReflect 

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

func (*WatchEventsRequest) Reset 

func (x *WatchEventsRequest) Reset()

func (*WatchEventsRequest) String 

func (x *WatchEventsRequest) String() string

type WatchEventsResponse 

type WatchEventsResponse struct {
	Entity *v1.EventEntity `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchEventsResponse) Descriptor deprecated 

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

Deprecated: Use WatchEventsResponse.ProtoReflect.Descriptor instead.

func (*WatchEventsResponse) GetEntity 

func (x *WatchEventsResponse) GetEntity() *v1.EventEntity

func (*WatchEventsResponse) ProtoMessage 

func (*WatchEventsResponse) ProtoMessage()

func (*WatchEventsResponse) ProtoReflect 

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

func (*WatchEventsResponse) Reset 

func (x *WatchEventsResponse) Reset()

func (*WatchEventsResponse) String 

func (x *WatchEventsResponse) 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.