api

README

Install tools

From the repository root run the following:

inv install-tools

to install the correct version of required tools

Generate api.pb.go

From the repository root run the following:

inv -e system-probe.generate-event-monitor-proto

Documentation

Index

• Variables
• func RegisterEventMonitoringModuleServer(s grpc.ServiceRegistrar, srv EventMonitoringModuleServer)
• type EventMonitoringModuleClient
  • func NewEventMonitoringModuleClient(cc grpc.ClientConnInterface) EventMonitoringModuleClient
• type EventMonitoringModuleServer
• type EventMonitoringModule_GetProcessEventsClient
• type EventMonitoringModule_GetProcessEventsServer
• type GetProcessEventParams
  • func (*GetProcessEventParams) Descriptor() ([]byte, []int)
  • func (x *GetProcessEventParams) GetTimeoutSeconds() int32
  • func (m *GetProcessEventParams) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *GetProcessEventParams) MarshalToVT(dAtA []byte) (int, error)
  • func (m *GetProcessEventParams) MarshalVT() (dAtA []byte, err error)
  • func (*GetProcessEventParams) ProtoMessage()
  • func (x *GetProcessEventParams) ProtoReflect() protoreflect.Message
  • func (x *GetProcessEventParams) Reset()
  • func (m *GetProcessEventParams) SizeVT() (n int)
  • func (x *GetProcessEventParams) String() string
  • func (m *GetProcessEventParams) UnmarshalVT(dAtA []byte) error
• type ProcessEventMessage
  • func (*ProcessEventMessage) Descriptor() ([]byte, []int)
  • func (x *ProcessEventMessage) GetData() []byte
  • func (m *ProcessEventMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *ProcessEventMessage) MarshalToVT(dAtA []byte) (int, error)
  • func (m *ProcessEventMessage) MarshalVT() (dAtA []byte, err error)
  • func (*ProcessEventMessage) ProtoMessage()
  • func (x *ProcessEventMessage) ProtoReflect() protoreflect.Message
  • func (x *ProcessEventMessage) Reset()
  • func (m *ProcessEventMessage) SizeVT() (n int)
  • func (x *ProcessEventMessage) String() string
  • func (m *ProcessEventMessage) UnmarshalVT(dAtA []byte) error
• type UnimplementedEventMonitoringModuleServer
  • func (UnimplementedEventMonitoringModuleServer) GetProcessEvents(*GetProcessEventParams, EventMonitoringModule_GetProcessEventsServer) error
• type UnsafeEventMonitoringModuleServer

Variables

var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)

var EventMonitoringModule_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.EventMonitoringModule",
	HandlerType: (*EventMonitoringModuleServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetProcessEvents",
			Handler:       _EventMonitoringModule_GetProcessEvents_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/eventmonitor/proto/api/api.proto",
}

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

var File_pkg_eventmonitor_proto_api_api_proto protoreflect.FileDescriptor

Functions

func RegisterEventMonitoringModuleServer

func RegisterEventMonitoringModuleServer(s grpc.ServiceRegistrar, srv EventMonitoringModuleServer)

Types

type EventMonitoringModuleClient

type EventMonitoringModuleClient interface {
	GetProcessEvents(ctx context.Context, in *GetProcessEventParams, opts ...grpc.CallOption) (EventMonitoringModule_GetProcessEventsClient, error)
}

EventMonitoringModuleClient is the client API for EventMonitoringModule 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 NewEventMonitoringModuleClient

func NewEventMonitoringModuleClient(cc grpc.ClientConnInterface) EventMonitoringModuleClient

type EventMonitoringModuleServer

type EventMonitoringModuleServer interface {
	GetProcessEvents(*GetProcessEventParams, EventMonitoringModule_GetProcessEventsServer) error
	// contains filtered or unexported methods
}

EventMonitoringModuleServer is the server API for EventMonitoringModule service. All implementations must embed UnimplementedEventMonitoringModuleServer for forward compatibility

type EventMonitoringModule_GetProcessEventsClient

type EventMonitoringModule_GetProcessEventsClient interface {
	Recv() (*ProcessEventMessage, error)
	grpc.ClientStream
}

type EventMonitoringModule_GetProcessEventsServer

type EventMonitoringModule_GetProcessEventsServer interface {
	Send(*ProcessEventMessage) error
	grpc.ServerStream
}

type GetProcessEventParams

type GetProcessEventParams struct {
	TimeoutSeconds int32 `protobuf:"varint,1,opt,name=TimeoutSeconds,proto3" json:"TimeoutSeconds,omitempty"`
	// contains filtered or unexported fields
}

func (*GetProcessEventParams) Descriptor

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

Deprecated: Use GetProcessEventParams.ProtoReflect.Descriptor instead.

func (*GetProcessEventParams) GetTimeoutSeconds

func (x *GetProcessEventParams) GetTimeoutSeconds() int32

func (*GetProcessEventParams) MarshalToSizedBufferVT

func (m *GetProcessEventParams) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetProcessEventParams) MarshalToVT

func (m *GetProcessEventParams) MarshalToVT(dAtA []byte) (int, error)

func (*GetProcessEventParams) MarshalVT

func (m *GetProcessEventParams) MarshalVT() (dAtA []byte, err error)

func (*GetProcessEventParams) ProtoMessage

func (*GetProcessEventParams) ProtoMessage()

func (*GetProcessEventParams) ProtoReflect

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

func (*GetProcessEventParams) Reset

func (x *GetProcessEventParams) Reset()

func (*GetProcessEventParams) SizeVT

func (m *GetProcessEventParams) SizeVT() (n int)

func (*GetProcessEventParams) String

func (x *GetProcessEventParams) String() string

func (*GetProcessEventParams) UnmarshalVT

func (m *GetProcessEventParams) UnmarshalVT(dAtA []byte) error

type ProcessEventMessage

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

func (*ProcessEventMessage) Descriptor

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

Deprecated: Use ProcessEventMessage.ProtoReflect.Descriptor instead.

func (*ProcessEventMessage) GetData

func (x *ProcessEventMessage) GetData() []byte

func (*ProcessEventMessage) MarshalToSizedBufferVT

func (m *ProcessEventMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ProcessEventMessage) MarshalToVT

func (m *ProcessEventMessage) MarshalToVT(dAtA []byte) (int, error)

func (*ProcessEventMessage) MarshalVT

func (m *ProcessEventMessage) MarshalVT() (dAtA []byte, err error)

func (*ProcessEventMessage) ProtoMessage

func (*ProcessEventMessage) ProtoMessage()

func (*ProcessEventMessage) ProtoReflect

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

func (*ProcessEventMessage) Reset

func (x *ProcessEventMessage) Reset()

func (*ProcessEventMessage) SizeVT

func (m *ProcessEventMessage) SizeVT() (n int)

func (*ProcessEventMessage) String

func (x *ProcessEventMessage) String() string

func (*ProcessEventMessage) UnmarshalVT

func (m *ProcessEventMessage) UnmarshalVT(dAtA []byte) error

type UnimplementedEventMonitoringModuleServer

type UnimplementedEventMonitoringModuleServer struct {
}

UnimplementedEventMonitoringModuleServer must be embedded to have forward compatible implementations.

func (UnimplementedEventMonitoringModuleServer) GetProcessEvents

func (UnimplementedEventMonitoringModuleServer) GetProcessEvents(*GetProcessEventParams, EventMonitoringModule_GetProcessEventsServer) error

type UnsafeEventMonitoringModuleServer

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

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