plugins

package
v0.2.7 Latest Latest
Warning

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

 Go to latest Published: Jun 12, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Engine_Input_FullMethodName  = "/plugins.Engine/Input"
	Engine_Notify_FullMethodName = "/plugins.Engine/Notify"
)
View Source 
const (
	Analysis_Analyze_FullMethodName = "/plugins.Analysis/Analyze"
)
View Source 
const (
	Correlation_Correlate_FullMethodName = "/plugins.Correlation/Correlate"
)
View Source 
const (
	Integration_ProcessLog_FullMethodName = "/plugins.Integration/ProcessLog"
)
View Source 
const (
	Notification_Notify_FullMethodName = "/plugins.Notification/Notify"
)
View Source 
const NullValue_NULL_VALUE = structpb.NullValue_NULL_VALUE
View Source 
const (
	Parsing_ParseLog_FullMethodName = "/plugins.Parsing/ParseLog"
)

Variables

View Source 
var Analysis_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugins.Analysis",
	HandlerType: (*AnalysisServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Analyze",
			Handler:    _Analysis_Analyze_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugins.proto",
}

Analysis_ServiceDesc is the grpc.ServiceDesc for Analysis 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 Correlation_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugins.Correlation",
	HandlerType: (*CorrelationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Correlate",
			Handler:    _Correlation_Correlate_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugins.proto",
}

Correlation_ServiceDesc is the grpc.ServiceDesc for Correlation 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 Engine_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugins.Engine",
	HandlerType: (*EngineServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Input",
			Handler:       _Engine_Input_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "Notify",
			Handler:       _Engine_Notify_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "plugins.proto",
}

Engine_ServiceDesc is the grpc.ServiceDesc for Engine 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_plugins_proto protoreflect.FileDescriptor
View Source 
var Integration_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugins.Integration",
	HandlerType: (*IntegrationServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ProcessLog",
			Handler:       _Integration_ProcessLog_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "plugins.proto",
}

Integration_ServiceDesc is the grpc.ServiceDesc for Integration 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 Notification_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugins.Notification",
	HandlerType: (*NotificationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Notify",
			Handler:    _Notification_Notify_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugins.proto",
}

Notification_ServiceDesc is the grpc.ServiceDesc for Notification 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 NullValue_name = structpb.NullValue_name
View Source 
var NullValue_value = structpb.NullValue_value
View Source 
var Parsing_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugins.Parsing",
	HandlerType: (*ParsingServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ParseLog",
			Handler:    _Parsing_ParseLog_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugins.proto",
}

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

Functions

func RegisterAnalysisServer added in v0.2.5 

func RegisterAnalysisServer(s grpc.ServiceRegistrar, srv AnalysisServer)

func RegisterCorrelationServer added in v0.2.5 

func RegisterCorrelationServer(s grpc.ServiceRegistrar, srv CorrelationServer)

func RegisterEngineServer added in v0.2.5 

func RegisterEngineServer(s grpc.ServiceRegistrar, srv EngineServer)

func RegisterIntegrationServer added in v0.2.3 

func RegisterIntegrationServer(s grpc.ServiceRegistrar, srv IntegrationServer)

func RegisterNotificationServer added in v0.2.5 

func RegisterNotificationServer(s grpc.ServiceRegistrar, srv NotificationServer)

func RegisterParsingServer added in v0.2.5 

func RegisterParsingServer(s grpc.ServiceRegistrar, srv ParsingServer)

Types

type Ack 

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

func (*Ack) Descriptor deprecated 

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

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetLastId 

func (x *Ack) GetLastId() string

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect 

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

func (*Ack) Reset 

func (x *Ack) Reset()

func (*Ack) String 

func (x *Ack) String() string

type Alert 

type Alert struct {
	Id          string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Timestamp   string   `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	LastUpdate  string   `protobuf:"bytes,3,opt,name=last_update,json=lastUpdate,proto3" json:"last_update,omitempty"`
	Name        string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	TenantId    string   `protobuf:"bytes,5,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	TenantName  string   `protobuf:"bytes,6,opt,name=tenant_name,json=tenantName,proto3" json:"tenant_name,omitempty"`
	DataSource  string   `protobuf:"bytes,7,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	DataType    string   `protobuf:"bytes,8,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
	Category    string   `protobuf:"bytes,9,opt,name=category,proto3" json:"category,omitempty"`
	Technique   string   `protobuf:"bytes,10,opt,name=technique,proto3" json:"technique,omitempty"`
	Description string   `protobuf:"bytes,11,opt,name=description,proto3" json:"description,omitempty"`
	References  []string `protobuf:"bytes,12,rep,name=references,proto3" json:"references,omitempty"`
	Impact      *Impact  `protobuf:"bytes,13,opt,name=impact,proto3" json:"impact,omitempty"`
	ImpactScore int32    `protobuf:"varint,14,opt,name=impact_score,json=impactScore,proto3" json:"impact_score,omitempty"`
	Severity    string   `protobuf:"bytes,15,opt,name=severity,proto3" json:"severity,omitempty"`
	Adversary   *Side    `protobuf:"bytes,16,opt,name=adversary,proto3" json:"adversary,omitempty"`
	Target      *Side    `protobuf:"bytes,17,opt,name=target,proto3" json:"target,omitempty"`
	Events      []*Event `protobuf:"bytes,18,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*Alert) Descriptor deprecated 

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

Deprecated: Use Alert.ProtoReflect.Descriptor instead.

func (*Alert) GetAdversary 

func (x *Alert) GetAdversary() *Side

func (*Alert) GetCategory 

func (x *Alert) GetCategory() string

func (*Alert) GetDataSource 

func (x *Alert) GetDataSource() string

func (*Alert) GetDataType 

func (x *Alert) GetDataType() string

func (*Alert) GetDescription 

func (x *Alert) GetDescription() string

func (*Alert) GetEvents 

func (x *Alert) GetEvents() []*Event

func (*Alert) GetId 

func (x *Alert) GetId() string

func (*Alert) GetImpact 

func (x *Alert) GetImpact() *Impact

func (*Alert) GetImpactScore 

func (x *Alert) GetImpactScore() int32

func (*Alert) GetLastUpdate 

func (x *Alert) GetLastUpdate() string

func (*Alert) GetName 

func (x *Alert) GetName() string

func (*Alert) GetReferences 

func (x *Alert) GetReferences() []string

func (*Alert) GetSeverity 

func (x *Alert) GetSeverity() string

func (*Alert) GetTarget 

func (x *Alert) GetTarget() *Side

func (*Alert) GetTechnique 

func (x *Alert) GetTechnique() string

func (*Alert) GetTenantId 

func (x *Alert) GetTenantId() string

func (*Alert) GetTenantName 

func (x *Alert) GetTenantName() string

func (*Alert) GetTimestamp 

func (x *Alert) GetTimestamp() string

func (*Alert) ProtoMessage 

func (*Alert) ProtoMessage()

func (*Alert) ProtoReflect 

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

func (*Alert) Reset 

func (x *Alert) Reset()

func (*Alert) String 

func (x *Alert) String() string

type AnalysisClient added in v0.2.5 

type AnalysisClient interface {
	Analyze(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Alert, error)
}

AnalysisClient is the client API for Analysis 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 NewAnalysisClient added in v0.2.5 

func NewAnalysisClient(cc grpc.ClientConnInterface) AnalysisClient

type AnalysisServer added in v0.2.5 

type AnalysisServer interface {
	Analyze(context.Context, *Event) (*Alert, error)
	// contains filtered or unexported methods
}

AnalysisServer is the server API for Analysis service. All implementations must embed UnimplementedAnalysisServer for forward compatibility

type CorrelationClient added in v0.2.5 

type CorrelationClient interface {
	Correlate(ctx context.Context, in *Alert, opts ...grpc.CallOption) (*Ack, error)
}

CorrelationClient is the client API for Correlation 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 NewCorrelationClient added in v0.2.5 

func NewCorrelationClient(cc grpc.ClientConnInterface) CorrelationClient

type CorrelationServer added in v0.2.5 

type CorrelationServer interface {
	Correlate(context.Context, *Alert) (*Ack, error)
	// contains filtered or unexported methods
}

CorrelationServer is the server API for Correlation service. All implementations must embed UnimplementedCorrelationServer for forward compatibility

type Empty 

type Empty = emptypb.Empty

type EngineClient added in v0.2.5 

type EngineClient interface {
	Input(ctx context.Context, opts ...grpc.CallOption) (Engine_InputClient, error)
	Notify(ctx context.Context, opts ...grpc.CallOption) (Engine_NotifyClient, error)
}

EngineClient is the client API for Engine 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 NewEngineClient added in v0.2.5 

func NewEngineClient(cc grpc.ClientConnInterface) EngineClient

type EngineServer added in v0.2.5 

type EngineServer interface {
	Input(Engine_InputServer) error
	Notify(Engine_NotifyServer) error
	// contains filtered or unexported methods
}

EngineServer is the server API for Engine service. All implementations must embed UnimplementedEngineServer for forward compatibility

type Engine_InputClient added in v0.2.5 

type Engine_InputClient interface {
	Send(*Log) error
	Recv() (*Ack, error)
	grpc.ClientStream
}

type Engine_InputServer added in v0.2.5 

type Engine_InputServer interface {
	Send(*Ack) error
	Recv() (*Log, error)
	grpc.ServerStream
}

type Engine_NotifyClient added in v0.2.5 

type Engine_NotifyClient interface {
	Send(*Message) error
	Recv() (*Ack, error)
	grpc.ClientStream
}

type Engine_NotifyServer added in v0.2.5 

type Engine_NotifyServer interface {
	Send(*Ack) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type Event 

type Event struct {
	Id               string                     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Timestamp        string                     `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	DeviceTime       string                     `protobuf:"bytes,3,opt,name=device_time,json=deviceTime,proto3" json:"device_time,omitempty"`
	DataType         string                     `protobuf:"bytes,4,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
	DataSource       string                     `protobuf:"bytes,5,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	TenantId         string                     `protobuf:"bytes,6,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	TenantName       string                     `protobuf:"bytes,7,opt,name=tenant_name,json=tenantName,proto3" json:"tenant_name,omitempty"`
	Raw              string                     `protobuf:"bytes,8,opt,name=raw,proto3" json:"raw,omitempty"`
	Log              map[string]*structpb.Value `` /* 147-byte string literal not displayed */
	Remote           *Side                      `protobuf:"bytes,10,opt,name=remote,proto3" json:"remote,omitempty"`
	Local            *Side                      `protobuf:"bytes,11,opt,name=local,proto3" json:"local,omitempty"`
	From             *Side                      `protobuf:"bytes,12,opt,name=from,proto3" json:"from,omitempty"`
	To               *Side                      `protobuf:"bytes,13,opt,name=to,proto3" json:"to,omitempty"`
	Protocol         string                     `protobuf:"bytes,14,opt,name=protocol,proto3" json:"protocol,omitempty"`
	ConnectionStatus string                     `protobuf:"bytes,15,opt,name=connection_status,json=connectionStatus,proto3" json:"connection_status,omitempty"`
	StatusCode       int64                      `protobuf:"varint,16,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetConnectionStatus 

func (x *Event) GetConnectionStatus() string

func (*Event) GetDataSource 

func (x *Event) GetDataSource() string

func (*Event) GetDataType 

func (x *Event) GetDataType() string

func (*Event) GetDeviceTime 

func (x *Event) GetDeviceTime() string

func (*Event) GetFrom 

func (x *Event) GetFrom() *Side

func (*Event) GetId 

func (x *Event) GetId() string

func (*Event) GetLocal 

func (x *Event) GetLocal() *Side

func (*Event) GetLog 

func (x *Event) GetLog() map[string]*structpb.Value

func (*Event) GetProtocol 

func (x *Event) GetProtocol() string

func (*Event) GetRaw 

func (x *Event) GetRaw() string

func (*Event) GetRemote 

func (x *Event) GetRemote() *Side

func (*Event) GetStatusCode 

func (x *Event) GetStatusCode() int64

func (*Event) GetTenantId 

func (x *Event) GetTenantId() string

func (*Event) GetTenantName 

func (x *Event) GetTenantName() string

func (*Event) GetTimestamp 

func (x *Event) GetTimestamp() string

func (*Event) GetTo 

func (x *Event) GetTo() *Side

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Geolocation 

type Geolocation struct {
	Country   string  `protobuf:"bytes,1,opt,name=country,proto3" json:"country,omitempty"`
	City      string  `protobuf:"bytes,2,opt,name=city,proto3" json:"city,omitempty"`
	Latitude  float64 `protobuf:"fixed64,3,opt,name=latitude,proto3" json:"latitude,omitempty"`
	Longitude float64 `protobuf:"fixed64,4,opt,name=longitude,proto3" json:"longitude,omitempty"`
	Asn       int64   `protobuf:"varint,5,opt,name=asn,proto3" json:"asn,omitempty"`
	Aso       string  `protobuf:"bytes,6,opt,name=aso,proto3" json:"aso,omitempty"`
	// contains filtered or unexported fields
}

func (*Geolocation) Descriptor deprecated 

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

Deprecated: Use Geolocation.ProtoReflect.Descriptor instead.

func (*Geolocation) GetAsn 

func (x *Geolocation) GetAsn() int64

func (*Geolocation) GetAso 

func (x *Geolocation) GetAso() string

func (*Geolocation) GetCity 

func (x *Geolocation) GetCity() string

func (*Geolocation) GetCountry 

func (x *Geolocation) GetCountry() string

func (*Geolocation) GetLatitude 

func (x *Geolocation) GetLatitude() float64

func (*Geolocation) GetLongitude 

func (x *Geolocation) GetLongitude() float64

func (*Geolocation) ProtoMessage 

func (*Geolocation) ProtoMessage()

func (*Geolocation) ProtoReflect 

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

func (*Geolocation) Reset 

func (x *Geolocation) Reset()

func (*Geolocation) String 

func (x *Geolocation) String() string

type Impact 

type Impact struct {
	Confidentiality int32 `protobuf:"varint,1,opt,name=confidentiality,proto3" json:"confidentiality,omitempty"`
	Integrity       int32 `protobuf:"varint,2,opt,name=integrity,proto3" json:"integrity,omitempty"`
	Availability    int32 `protobuf:"varint,3,opt,name=availability,proto3" json:"availability,omitempty"`
	// contains filtered or unexported fields
}

func (*Impact) Descriptor deprecated 

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

Deprecated: Use Impact.ProtoReflect.Descriptor instead.

func (*Impact) GetAvailability 

func (x *Impact) GetAvailability() int32

func (*Impact) GetConfidentiality 

func (x *Impact) GetConfidentiality() int32

func (*Impact) GetIntegrity 

func (x *Impact) GetIntegrity() int32

func (*Impact) ProtoMessage 

func (*Impact) ProtoMessage()

func (*Impact) ProtoReflect 

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

func (*Impact) Reset 

func (x *Impact) Reset()

func (*Impact) String 

func (x *Impact) String() string

type IntegrationClient added in v0.2.3 

type IntegrationClient interface {
	ProcessLog(ctx context.Context, opts ...grpc.CallOption) (Integration_ProcessLogClient, error)
}

IntegrationClient is the client API for Integration 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 NewIntegrationClient added in v0.2.3 

func NewIntegrationClient(cc grpc.ClientConnInterface) IntegrationClient

type IntegrationServer added in v0.2.3 

type IntegrationServer interface {
	ProcessLog(Integration_ProcessLogServer) error
	// contains filtered or unexported methods
}

IntegrationServer is the server API for Integration service. All implementations must embed UnimplementedIntegrationServer for forward compatibility

type Integration_ProcessLogClient added in v0.2.3 

type Integration_ProcessLogClient interface {
	Send(*Log) error
	Recv() (*Ack, error)
	grpc.ClientStream
}

type Integration_ProcessLogServer added in v0.2.3 

type Integration_ProcessLogServer interface {
	Send(*Ack) error
	Recv() (*Log, error)
	grpc.ServerStream
}

type JLog added in v0.2.3 

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

func (*JLog) Descriptor deprecated added in v0.2.3 

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

Deprecated: Use JLog.ProtoReflect.Descriptor instead.

func (*JLog) GetLog added in v0.2.3 

func (x *JLog) GetLog() string

func (*JLog) ProtoMessage added in v0.2.3 

func (*JLog) ProtoMessage()

func (*JLog) ProtoReflect added in v0.2.3 

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

func (*JLog) Reset added in v0.2.3 

func (x *JLog) Reset()

func (*JLog) String added in v0.2.3 

func (x *JLog) String() string

type ListValue 

type ListValue = structpb.ListValue

type Log 

type Log struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DataType   string `protobuf:"bytes,2,opt,name=dataType,proto3" json:"dataType,omitempty"`
	DataSource string `protobuf:"bytes,3,opt,name=dataSource,proto3" json:"dataSource,omitempty"`
	Timestamp  string `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	TenantId   string `protobuf:"bytes,5,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	Raw        string `protobuf:"bytes,6,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetDataSource 

func (x *Log) GetDataSource() string

func (*Log) GetDataType 

func (x *Log) GetDataType() string

func (*Log) GetId 

func (x *Log) GetId() string

func (*Log) GetRaw 

func (x *Log) GetRaw() string

func (*Log) GetTenantId 

func (x *Log) GetTenantId() string

func (*Log) GetTimestamp 

func (x *Log) GetTimestamp() string

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect 

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

func (*Log) Reset 

func (x *Log) Reset()

func (*Log) String 

func (x *Log) String() string

type Message 

type Message struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Timestamp string `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Topic     string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Message   string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetId 

func (x *Message) GetId() string

func (*Message) GetMessage 

func (x *Message) GetMessage() string

func (*Message) GetTimestamp 

func (x *Message) GetTimestamp() string

func (*Message) GetTopic 

func (x *Message) GetTopic() string

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type NotificationClient added in v0.2.5 

type NotificationClient interface {
	Notify(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Ack, error)
}

NotificationClient is the client API for Notification 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 NewNotificationClient added in v0.2.5 

func NewNotificationClient(cc grpc.ClientConnInterface) NotificationClient

type NotificationServer added in v0.2.5 

type NotificationServer interface {
	Notify(context.Context, *Message) (*Ack, error)
	// contains filtered or unexported methods
}

NotificationServer is the server API for Notification service. All implementations must embed UnimplementedNotificationServer for forward compatibility

type NullValue 

type NullValue = structpb.NullValue

type ParsingClient added in v0.2.5 

type ParsingClient interface {
	ParseLog(ctx context.Context, in *JLog, opts ...grpc.CallOption) (*JLog, error)
}

ParsingClient is the client API for Parsing 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 NewParsingClient added in v0.2.5 

func NewParsingClient(cc grpc.ClientConnInterface) ParsingClient

type ParsingServer added in v0.2.5 

type ParsingServer interface {
	ParseLog(context.Context, *JLog) (*JLog, error)
	// contains filtered or unexported methods
}

ParsingServer is the server API for Parsing service. All implementations must embed UnimplementedParsingServer for forward compatibility

type Side 

type Side struct {
	Ip               string         `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Ips              []string       `protobuf:"bytes,2,rep,name=ips,proto3" json:"ips,omitempty"`
	Host             string         `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	Hosts            []string       `protobuf:"bytes,4,rep,name=hosts,proto3" json:"hosts,omitempty"`
	User             string         `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	Users            []string       `protobuf:"bytes,6,rep,name=users,proto3" json:"users,omitempty"`
	Group            string         `protobuf:"bytes,7,opt,name=group,proto3" json:"group,omitempty"`
	Groups           []string       `protobuf:"bytes,8,rep,name=groups,proto3" json:"groups,omitempty"`
	Port             int64          `protobuf:"varint,9,opt,name=port,proto3" json:"port,omitempty"`
	Ports            []int64        `protobuf:"varint,10,rep,packed,name=ports,proto3" json:"ports,omitempty"`
	BytesSent        float64        `protobuf:"fixed64,11,opt,name=bytes_sent,json=bytesSent,proto3" json:"bytes_sent,omitempty"`
	BytesReceived    float64        `protobuf:"fixed64,12,opt,name=bytes_received,json=bytesReceived,proto3" json:"bytes_received,omitempty"`
	PackagesSent     int64          `protobuf:"varint,13,opt,name=packages_sent,json=packagesSent,proto3" json:"packages_sent,omitempty"`
	PackagesReceived int64          `protobuf:"varint,14,opt,name=packages_received,json=packagesReceived,proto3" json:"packages_received,omitempty"`
	Connections      int64          `protobuf:"varint,15,opt,name=connections,proto3" json:"connections,omitempty"`
	UsedCpuPercent   int64          `protobuf:"varint,16,opt,name=used_cpu_percent,json=usedCpuPercent,proto3" json:"used_cpu_percent,omitempty"`
	UsedMemPercent   int64          `protobuf:"varint,17,opt,name=used_mem_percent,json=usedMemPercent,proto3" json:"used_mem_percent,omitempty"`
	FreeCpuPercent   int64          `protobuf:"varint,18,opt,name=free_cpu_percent,json=freeCpuPercent,proto3" json:"free_cpu_percent,omitempty"`
	FreeMemPercent   int64          `protobuf:"varint,19,opt,name=free_mem_percent,json=freeMemPercent,proto3" json:"free_mem_percent,omitempty"`
	TotalCpuPercent  int64          `protobuf:"varint,20,opt,name=total_cpu_percent,json=totalCpuPercent,proto3" json:"total_cpu_percent,omitempty"`
	TotalMemPercent  int64          `protobuf:"varint,21,opt,name=total_mem_percent,json=totalMemPercent,proto3" json:"total_mem_percent,omitempty"`
	Domain           string         `protobuf:"bytes,22,opt,name=domain,proto3" json:"domain,omitempty"`
	Domains          []string       `protobuf:"bytes,23,rep,name=domains,proto3" json:"domains,omitempty"`
	Fqdn             string         `protobuf:"bytes,24,opt,name=fqdn,proto3" json:"fqdn,omitempty"`
	Fqdns            []string       `protobuf:"bytes,25,rep,name=fqdns,proto3" json:"fqdns,omitempty"`
	Mac              string         `protobuf:"bytes,26,opt,name=mac,proto3" json:"mac,omitempty"`
	Macs             []string       `protobuf:"bytes,27,rep,name=macs,proto3" json:"macs,omitempty"`
	Process          string         `protobuf:"bytes,28,opt,name=process,proto3" json:"process,omitempty"`
	Processes        []string       `protobuf:"bytes,29,rep,name=processes,proto3" json:"processes,omitempty"`
	Asn              int64          `protobuf:"varint,30,opt,name=asn,proto3" json:"asn,omitempty"`
	Aso              string         `protobuf:"bytes,31,opt,name=aso,proto3" json:"aso,omitempty"`
	Geolocations     []*Geolocation `protobuf:"bytes,32,rep,name=geolocations,proto3" json:"geolocations,omitempty"`
	File             string         `protobuf:"bytes,33,opt,name=file,proto3" json:"file,omitempty"`
	Files            []string       `protobuf:"bytes,34,rep,name=files,proto3" json:"files,omitempty"`
	Path             string         `protobuf:"bytes,35,opt,name=path,proto3" json:"path,omitempty"`
	Paths            []string       `protobuf:"bytes,36,rep,name=paths,proto3" json:"paths,omitempty"`
	Md5              string         `protobuf:"bytes,37,opt,name=md5,proto3" json:"md5,omitempty"`
	Md5S             []string       `protobuf:"bytes,38,rep,name=md5s,proto3" json:"md5s,omitempty"`
	Sha1             string         `protobuf:"bytes,39,opt,name=sha1,proto3" json:"sha1,omitempty"`
	Sha1S            []string       `protobuf:"bytes,40,rep,name=sha1s,proto3" json:"sha1s,omitempty"`
	Sha256           string         `protobuf:"bytes,41,opt,name=sha256,proto3" json:"sha256,omitempty"`
	Sha256S          []string       `protobuf:"bytes,42,rep,name=sha256s,proto3" json:"sha256s,omitempty"`
	Url              string         `protobuf:"bytes,43,opt,name=url,proto3" json:"url,omitempty"`
	Urls             []string       `protobuf:"bytes,44,rep,name=urls,proto3" json:"urls,omitempty"`
	Email            string         `protobuf:"bytes,45,opt,name=email,proto3" json:"email,omitempty"`
	Emails           []string       `protobuf:"bytes,46,rep,name=emails,proto3" json:"emails,omitempty"`
	Command          string         `protobuf:"bytes,47,opt,name=command,proto3" json:"command,omitempty"`
	Commands         []string       `protobuf:"bytes,48,rep,name=commands,proto3" json:"commands,omitempty"`
	// contains filtered or unexported fields
}

func (*Side) Descriptor deprecated 

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

Deprecated: Use Side.ProtoReflect.Descriptor instead.

func (*Side) GetAsn 

func (x *Side) GetAsn() int64

func (*Side) GetAso 

func (x *Side) GetAso() string

func (*Side) GetBytesReceived 

func (x *Side) GetBytesReceived() float64

func (*Side) GetBytesSent 

func (x *Side) GetBytesSent() float64

func (*Side) GetCommand 

func (x *Side) GetCommand() string

func (*Side) GetCommands 

func (x *Side) GetCommands() []string

func (*Side) GetConnections 

func (x *Side) GetConnections() int64

func (*Side) GetDomain 

func (x *Side) GetDomain() string

func (*Side) GetDomains 

func (x *Side) GetDomains() []string

func (*Side) GetEmail 

func (x *Side) GetEmail() string

func (*Side) GetEmails 

func (x *Side) GetEmails() []string

func (*Side) GetFile 

func (x *Side) GetFile() string

func (*Side) GetFiles 

func (x *Side) GetFiles() []string

func (*Side) GetFqdn 

func (x *Side) GetFqdn() string

func (*Side) GetFqdns 

func (x *Side) GetFqdns() []string

func (*Side) GetFreeCpuPercent 

func (x *Side) GetFreeCpuPercent() int64

func (*Side) GetFreeMemPercent 

func (x *Side) GetFreeMemPercent() int64

func (*Side) GetGeolocations 

func (x *Side) GetGeolocations() []*Geolocation

func (*Side) GetGroup 

func (x *Side) GetGroup() string

func (*Side) GetGroups 

func (x *Side) GetGroups() []string

func (*Side) GetHost 

func (x *Side) GetHost() string

func (*Side) GetHosts 

func (x *Side) GetHosts() []string

func (*Side) GetIp 

func (x *Side) GetIp() string

func (*Side) GetIps 

func (x *Side) GetIps() []string

func (*Side) GetMac 

func (x *Side) GetMac() string

func (*Side) GetMacs 

func (x *Side) GetMacs() []string

func (*Side) GetMd5 

func (x *Side) GetMd5() string

func (*Side) GetMd5S 

func (x *Side) GetMd5S() []string

func (*Side) GetPackagesReceived 

func (x *Side) GetPackagesReceived() int64

func (*Side) GetPackagesSent 

func (x *Side) GetPackagesSent() int64

func (*Side) GetPath 

func (x *Side) GetPath() string

func (*Side) GetPaths 

func (x *Side) GetPaths() []string

func (*Side) GetPort 

func (x *Side) GetPort() int64

func (*Side) GetPorts 

func (x *Side) GetPorts() []int64

func (*Side) GetProcess 

func (x *Side) GetProcess() string

func (*Side) GetProcesses 

func (x *Side) GetProcesses() []string

func (*Side) GetSha1 

func (x *Side) GetSha1() string

func (*Side) GetSha1S 

func (x *Side) GetSha1S() []string

func (*Side) GetSha256 

func (x *Side) GetSha256() string

func (*Side) GetSha256S 

func (x *Side) GetSha256S() []string

func (*Side) GetTotalCpuPercent 

func (x *Side) GetTotalCpuPercent() int64

func (*Side) GetTotalMemPercent 

func (x *Side) GetTotalMemPercent() int64

func (*Side) GetUrl 

func (x *Side) GetUrl() string

func (*Side) GetUrls 

func (x *Side) GetUrls() []string

func (*Side) GetUsedCpuPercent 

func (x *Side) GetUsedCpuPercent() int64

func (*Side) GetUsedMemPercent 

func (x *Side) GetUsedMemPercent() int64

func (*Side) GetUser 

func (x *Side) GetUser() string

func (*Side) GetUsers 

func (x *Side) GetUsers() []string

func (*Side) ProtoMessage 

func (*Side) ProtoMessage()

func (*Side) ProtoReflect 

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

func (*Side) Reset 

func (x *Side) Reset()

func (*Side) String 

func (x *Side) String() string

type Struct 

type Struct = structpb.Struct

type UnimplementedAnalysisServer added in v0.2.5 

type UnimplementedAnalysisServer struct {
}

UnimplementedAnalysisServer must be embedded to have forward compatible implementations.

func (UnimplementedAnalysisServer) Analyze added in v0.2.5 

func (UnimplementedAnalysisServer) Analyze(context.Context, *Event) (*Alert, error)

type UnimplementedCorrelationServer added in v0.2.5 

type UnimplementedCorrelationServer struct {
}

UnimplementedCorrelationServer must be embedded to have forward compatible implementations.

func (UnimplementedCorrelationServer) Correlate added in v0.2.5 

func (UnimplementedCorrelationServer) Correlate(context.Context, *Alert) (*Ack, error)

type UnimplementedEngineServer added in v0.2.5 

type UnimplementedEngineServer struct {
}

UnimplementedEngineServer must be embedded to have forward compatible implementations.

func (UnimplementedEngineServer) Input added in v0.2.5 

func (UnimplementedEngineServer) Input(Engine_InputServer) error

func (UnimplementedEngineServer) Notify added in v0.2.5 

func (UnimplementedEngineServer) Notify(Engine_NotifyServer) error

type UnimplementedIntegrationServer added in v0.2.3 

type UnimplementedIntegrationServer struct {
}

UnimplementedIntegrationServer must be embedded to have forward compatible implementations.

func (UnimplementedIntegrationServer) ProcessLog added in v0.2.3 

func (UnimplementedIntegrationServer) ProcessLog(Integration_ProcessLogServer) error

type UnimplementedNotificationServer added in v0.2.5 

type UnimplementedNotificationServer struct {
}

UnimplementedNotificationServer must be embedded to have forward compatible implementations.

func (UnimplementedNotificationServer) Notify added in v0.2.5 

func (UnimplementedNotificationServer) Notify(context.Context, *Message) (*Ack, error)

type UnimplementedParsingServer added in v0.2.5 

type UnimplementedParsingServer struct {
}

UnimplementedParsingServer must be embedded to have forward compatible implementations.

func (UnimplementedParsingServer) ParseLog added in v0.2.5 

func (UnimplementedParsingServer) ParseLog(context.Context, *JLog) (*JLog, error)

type UnsafeAnalysisServer added in v0.2.5 

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

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

type UnsafeCorrelationServer added in v0.2.5 

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

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

type UnsafeEngineServer added in v0.2.5 

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

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

type UnsafeIntegrationServer added in v0.2.3 

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

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

type UnsafeNotificationServer added in v0.2.5 

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

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

type UnsafeParsingServer added in v0.2.5 

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

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

type Value 

type Value = structpb.Value

type Value_BoolValue 

type Value_BoolValue = structpb.Value_BoolValue

type Value_ListValue 

type Value_ListValue = structpb.Value_ListValue

type Value_NullValue 

type Value_NullValue = structpb.Value_NullValue

type Value_NumberValue 

type Value_NumberValue = structpb.Value_NumberValue

type Value_StringValue 

type Value_StringValue = structpb.Value_StringValue

type Value_StructValue 

type Value_StructValue = structpb.Value_StructValue

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.