go_sdk

package module
v0.10.2 Latest Latest
Warning

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

 Go to latest Published: Sep 26, 2024 License: MIT Imports: 30 Imported by: 3

README

ThreatWinds Go SDK

Documentation

Index

Constants

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

Variables

View Source 
var Analysis_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gosdk.Analysis",
	HandlerType: (*AnalysisServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Analyze",
			Handler:       _Analysis_Analyze_Handler,
			ServerStreams: true,
		},
	},
	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: "gosdk.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: "gosdk.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: "gosdk.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: "gosdk.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: "gosdk.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 CastBool added in v0.9.0 

func CastBool(value interface{}) bool

func CastFloat64 added in v0.9.0 

func CastFloat64(value interface{}) float64

func CastInt64 added in v0.9.0 

func CastInt64(value interface{}) int64

func CastString added in v0.9.0 

func CastString(value interface{}) string

func DoReq added in v0.9.0 

func DoReq[response any](url string,
	data []byte, method string,
	headers map[string]string) (response, int, *logger.Error)

func Download added in v0.9.0 

func Download(url, file string) *logger.Error

func GetCelType added in v0.9.0 

func GetCelType(t string) *cel.Type

func GetMainIP added in v0.9.0 

func GetMainIP() (string, *logger.Error)

func GetValueOf added in v0.9.0 

func GetValueOf(value gjson.Result) interface{}

func ListFiles added in v0.9.0 

func ListFiles(route string, filter string) []string

func Logger added in v0.9.0 

func Logger() *logger.Logger

func PluginCfg added in v0.9.0 

func PluginCfg[t any](name string) (*t, *logger.Error)

func PointerOf added in v0.10.1 

func PointerOf[t any](s t) *t

func ReadCSV added in v0.9.0 

func ReadCSV(url string) ([][]string, *logger.Error)

func ReadJSON added in v0.9.0 

func ReadJSON[t any](f string) (*t, *logger.Error)

func ReadYAML added in v0.9.0 

func ReadYAML[t any](f string) (*t, *logger.Error)

func RegisterAnalysisServer added in v0.9.0 

func RegisterAnalysisServer(s grpc.ServiceRegistrar, srv AnalysisServer)

func RegisterCorrelationServer added in v0.9.0 

func RegisterCorrelationServer(s grpc.ServiceRegistrar, srv CorrelationServer)

func RegisterEngineServer added in v0.9.0 

func RegisterEngineServer(s grpc.ServiceRegistrar, srv EngineServer)

func RegisterIntegrationServer added in v0.9.0 

func RegisterIntegrationServer(s grpc.ServiceRegistrar, srv IntegrationServer)

func RegisterNotificationServer added in v0.9.0 

func RegisterNotificationServer(s grpc.ServiceRegistrar, srv NotificationServer)

func RegisterParsingServer added in v0.9.0 

func RegisterParsingServer(s grpc.ServiceRegistrar, srv ParsingServer)

func ToObject added in v0.9.0 

func ToObject(str *string, object protoreflect.ProtoMessage) *logger.Error

func ToString added in v0.9.0 

func ToString(object protoreflect.ProtoMessage) (*string, *logger.Error)

Types

type Ack added in v0.9.0 

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

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

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

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetLastId added in v0.9.0 

func (x *Ack) GetLastId() string

func (*Ack) ProtoMessage added in v0.9.0 

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect added in v0.9.0 

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

func (*Ack) Reset added in v0.9.0 

func (x *Ack) Reset()

func (*Ack) String added in v0.9.0 

func (x *Ack) String() string

type Add added in v0.9.0 

type Add struct {
	Function string                `protobuf:"bytes,1,opt,name=function,proto3" json:"function,omitempty"`
	Params   map[string]*anypb.Any `` /* 153-byte string literal not displayed */
	Where    *Where                `protobuf:"bytes,3,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Add.ProtoReflect.Descriptor instead.

func (*Add) GetFunction added in v0.9.0 

func (x *Add) GetFunction() string

func (*Add) GetParams added in v0.9.0 

func (x *Add) GetParams() map[string]*anypb.Any

func (*Add) GetWhere added in v0.9.0 

func (x *Add) GetWhere() *Where

func (*Add) ProtoMessage added in v0.9.0 

func (*Add) ProtoMessage()

func (*Add) ProtoReflect added in v0.9.0 

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

func (*Add) Reset added in v0.9.0 

func (x *Add) Reset()

func (*Add) String added in v0.9.0 

func (x *Add) 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,json=@timestamp,proto3" json:"timestamp,omitempty"`
	LastUpdate  string   `protobuf:"bytes,3,opt,name=lastUpdate,proto3" json:"lastUpdate,omitempty"`
	Name        string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	TenantId    string   `protobuf:"bytes,5,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	TenantName  string   `protobuf:"bytes,6,opt,name=tenantName,proto3" json:"tenantName,omitempty"`
	DataSource  string   `protobuf:"bytes,7,opt,name=dataSource,proto3" json:"dataSource,omitempty"`
	DataType    string   `protobuf:"bytes,8,opt,name=dataType,proto3" json:"dataType,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=impactScore,proto3" json:"impactScore,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 added in v0.9.0 

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

Deprecated: Use Alert.ProtoReflect.Descriptor instead.

func (*Alert) GetAdversary added in v0.9.0 

func (x *Alert) GetAdversary() *Side

func (*Alert) GetCategory added in v0.9.0 

func (x *Alert) GetCategory() string

func (*Alert) GetDataSource added in v0.9.0 

func (x *Alert) GetDataSource() string

func (*Alert) GetDataType added in v0.9.0 

func (x *Alert) GetDataType() string

func (*Alert) GetDescription added in v0.9.0 

func (x *Alert) GetDescription() string

func (*Alert) GetEvents added in v0.9.0 

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

func (*Alert) GetId added in v0.9.0 

func (x *Alert) GetId() string

func (*Alert) GetImpact added in v0.9.0 

func (x *Alert) GetImpact() *Impact

func (*Alert) GetImpactScore added in v0.9.0 

func (x *Alert) GetImpactScore() int32

func (*Alert) GetLastUpdate added in v0.9.0 

func (x *Alert) GetLastUpdate() string

func (*Alert) GetName added in v0.9.0 

func (x *Alert) GetName() string

func (*Alert) GetReferences added in v0.9.0 

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

func (*Alert) GetSeverity added in v0.9.0 

func (x *Alert) GetSeverity() string

func (*Alert) GetTarget added in v0.9.0 

func (x *Alert) GetTarget() *Side

func (*Alert) GetTechnique added in v0.9.0 

func (x *Alert) GetTechnique() string

func (*Alert) GetTenantId added in v0.9.0 

func (x *Alert) GetTenantId() string

func (*Alert) GetTenantName added in v0.9.0 

func (x *Alert) GetTenantName() string

func (*Alert) GetTimestamp added in v0.9.0 

func (x *Alert) GetTimestamp() string

func (*Alert) ProtoMessage added in v0.9.0 

func (*Alert) ProtoMessage()

func (*Alert) ProtoReflect added in v0.9.0 

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

func (*Alert) Reset added in v0.9.0 

func (x *Alert) Reset()

func (*Alert) String added in v0.9.0 

func (x *Alert) String() string

type AnalysisClient added in v0.9.0 

type AnalysisClient interface {
	Analyze(ctx context.Context, in *Event, opts ...grpc.CallOption) (grpc.ServerStreamingClient[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.9.0 

func NewAnalysisClient(cc grpc.ClientConnInterface) AnalysisClient

type AnalysisServer added in v0.9.0 

type AnalysisServer interface {
	Analyze(*Event, grpc.ServerStreamingServer[Alert]) error
	// contains filtered or unexported methods
}

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

type Analysis_AnalyzeClient added in v0.10.2 

type Analysis_AnalyzeClient = grpc.ServerStreamingClient[Alert]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Analysis_AnalyzeServer added in v0.10.2 

type Analysis_AnalyzeServer = grpc.ServerStreamingServer[Alert]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Any added in v0.9.0 

type Any = anypb.Any

type Asset added in v0.9.0 

type Asset struct {
	Name            string   `yaml:"name"`
	Hostnames       []string `yaml:"hostnames,omitempty"`
	IPs             []string `yaml:"ips,omitempty"`
	Confidentiality int32    `yaml:"confidentiality"`
	Availability    int32    `yaml:"availability"`
	Integrity       int32    `yaml:"integrity"`
}

type Cast added in v0.9.0 

type Cast struct {
	To     string   `protobuf:"bytes,1,opt,name=to,proto3" json:"to,omitempty"`
	Fields []string `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	Where  *Where   `protobuf:"bytes,3,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Cast.ProtoReflect.Descriptor instead.

func (*Cast) GetFields added in v0.9.0 

func (x *Cast) GetFields() []string

func (*Cast) GetTo added in v0.9.0 

func (x *Cast) GetTo() string

func (*Cast) GetWhere added in v0.10.0 

func (x *Cast) GetWhere() *Where

func (*Cast) ProtoMessage added in v0.9.0 

func (*Cast) ProtoMessage()

func (*Cast) ProtoReflect added in v0.9.0 

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

func (*Cast) Reset added in v0.9.0 

func (x *Cast) Reset()

func (*Cast) String added in v0.9.0 

func (x *Cast) String() string

type Config added in v0.9.0 

type Config struct {
	Pipeline      []Pipeline                        `yaml:"pipeline,omitempty"`
	DisabledRules []int64                           `yaml:"disabledRules,omitempty"`
	Tenants       []Tenant                          `yaml:"tenants,omitempty"`
	Patterns      map[string]string                 `yaml:"patterns,omitempty"`
	Plugins       map[string]map[string]interface{} `yaml:"plugins,omitempty"`
	Env           Env                               `yaml:"-"`
}

func GetCfg added in v0.9.0 

func GetCfg() *Config

type CorrelationClient added in v0.9.0 

type CorrelationClient interface {
	Correlate(ctx context.Context, in *Alert, opts ...grpc.CallOption) (*emptypb.Empty, 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.9.0 

func NewCorrelationClient(cc grpc.ClientConnInterface) CorrelationClient

type CorrelationServer added in v0.9.0 

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

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

type Csv added in v0.9.0 

type Csv struct {
	Source    string   `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Separator string   `protobuf:"bytes,2,opt,name=separator,proto3" json:"separator,omitempty"`
	Headers   []string `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
	Where     *Where   `protobuf:"bytes,4,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Csv.ProtoReflect.Descriptor instead.

func (*Csv) GetHeaders added in v0.9.0 

func (x *Csv) GetHeaders() []string

func (*Csv) GetSeparator added in v0.9.0 

func (x *Csv) GetSeparator() string

func (*Csv) GetSource added in v0.9.0 

func (x *Csv) GetSource() string

func (*Csv) GetWhere added in v0.10.0 

func (x *Csv) GetWhere() *Where

func (*Csv) ProtoMessage added in v0.9.0 

func (*Csv) ProtoMessage()

func (*Csv) ProtoReflect added in v0.9.0 

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

func (*Csv) Reset added in v0.9.0 

func (x *Csv) Reset()

func (*Csv) String added in v0.9.0 

func (x *Csv) String() string

type Delete added in v0.9.0 

type Delete struct {
	Fields []string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	Where  *Where   `protobuf:"bytes,2,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Delete.ProtoReflect.Descriptor instead.

func (*Delete) GetFields added in v0.9.0 

func (x *Delete) GetFields() []string

func (*Delete) GetWhere added in v0.10.0 

func (x *Delete) GetWhere() *Where

func (*Delete) ProtoMessage added in v0.9.0 

func (*Delete) ProtoMessage()

func (*Delete) ProtoReflect added in v0.9.0 

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

func (*Delete) Reset added in v0.9.0 

func (x *Delete) Reset()

func (*Delete) String added in v0.9.0 

func (x *Delete) String() string

type Drop added in v0.9.0 

type Drop struct {
	Where *Where `protobuf:"bytes,1,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Drop.ProtoReflect.Descriptor instead.

func (*Drop) GetWhere added in v0.9.0 

func (x *Drop) GetWhere() *Where

func (*Drop) ProtoMessage added in v0.9.0 

func (*Drop) ProtoMessage()

func (*Drop) ProtoReflect added in v0.9.0 

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

func (*Drop) Reset added in v0.9.0 

func (x *Drop) Reset()

func (*Drop) String added in v0.9.0 

func (x *Drop) String() string

type Dynamic added in v0.9.0 

type Dynamic struct {
	Plugin string                `protobuf:"bytes,1,opt,name=plugin,proto3" json:"plugin,omitempty"`
	Params map[string]*anypb.Any `` /* 153-byte string literal not displayed */
	Where  *Where                `protobuf:"bytes,3,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Dynamic.ProtoReflect.Descriptor instead.

func (*Dynamic) GetParams added in v0.9.0 

func (x *Dynamic) GetParams() map[string]*anypb.Any

func (*Dynamic) GetPlugin added in v0.9.0 

func (x *Dynamic) GetPlugin() string

func (*Dynamic) GetWhere added in v0.10.0 

func (x *Dynamic) GetWhere() *Where

func (*Dynamic) ProtoMessage added in v0.9.0 

func (*Dynamic) ProtoMessage()

func (*Dynamic) ProtoReflect added in v0.9.0 

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

func (*Dynamic) Reset added in v0.9.0 

func (x *Dynamic) Reset()

func (*Dynamic) String added in v0.9.0 

func (x *Dynamic) String() string

type Empty added in v0.9.0 

type Empty = emptypb.Empty

type EngineClient added in v0.9.0 

type EngineClient interface {
	Input(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[Log, Ack], error)
	Notify(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[Message, Ack], 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.9.0 

func NewEngineClient(cc grpc.ClientConnInterface) EngineClient

type EngineServer added in v0.9.0 

type EngineServer interface {
	Input(grpc.BidiStreamingServer[Log, Ack]) error
	Notify(grpc.BidiStreamingServer[Message, Ack]) 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.9.0 

type Engine_InputClient = grpc.BidiStreamingClient[Log, Ack]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Engine_InputServer added in v0.9.0 

type Engine_InputServer = grpc.BidiStreamingServer[Log, Ack]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Engine_NotifyClient added in v0.9.0 

type Engine_NotifyClient = grpc.BidiStreamingClient[Message, Ack]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Engine_NotifyServer added in v0.9.0 

type Engine_NotifyServer = grpc.BidiStreamingServer[Message, Ack]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Env added in v0.9.0 

type Env struct {
	NodeName   string
	NodeGroups []string
	Workdir    string
	LogLevel   int
}

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,json=@timestamp,proto3" json:"timestamp,omitempty"`
	DeviceTime       string                     `protobuf:"bytes,3,opt,name=deviceTime,proto3" json:"deviceTime,omitempty"`
	DataType         string                     `protobuf:"bytes,4,opt,name=dataType,proto3" json:"dataType,omitempty"`
	DataSource       string                     `protobuf:"bytes,5,opt,name=dataSource,proto3" json:"dataSource,omitempty"`
	TenantId         string                     `protobuf:"bytes,6,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	TenantName       string                     `protobuf:"bytes,7,opt,name=tenantName,proto3" json:"tenantName,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=connectionStatus,proto3" json:"connectionStatus,omitempty"`
	StatusCode       int64                      `protobuf:"varint,16,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	ActionResult     string                     `protobuf:"bytes,17,opt,name=actionResult,proto3" json:"actionResult,omitempty"`
	Action           string                     `protobuf:"bytes,18,opt,name=action,proto3" json:"action,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAction added in v0.9.0 

func (x *Event) GetAction() string

func (*Event) GetActionResult added in v0.9.0 

func (x *Event) GetActionResult() string

func (*Event) GetConnectionStatus added in v0.9.0 

func (x *Event) GetConnectionStatus() string

func (*Event) GetDataSource added in v0.9.0 

func (x *Event) GetDataSource() string

func (*Event) GetDataType added in v0.9.0 

func (x *Event) GetDataType() string

func (*Event) GetDeviceTime added in v0.9.0 

func (x *Event) GetDeviceTime() string

func (*Event) GetFrom added in v0.9.0 

func (x *Event) GetFrom() *Side

func (*Event) GetId added in v0.9.0 

func (x *Event) GetId() string

func (*Event) GetLocal added in v0.9.0 

func (x *Event) GetLocal() *Side

func (*Event) GetLog added in v0.9.0 

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

func (*Event) GetProtocol added in v0.9.0 

func (x *Event) GetProtocol() string

func (*Event) GetRaw added in v0.9.0 

func (x *Event) GetRaw() string

func (*Event) GetRemote added in v0.9.0 

func (x *Event) GetRemote() *Side

func (*Event) GetStatusCode added in v0.9.0 

func (x *Event) GetStatusCode() int64

func (*Event) GetTenantId added in v0.9.0 

func (x *Event) GetTenantId() string

func (*Event) GetTenantName added in v0.9.0 

func (x *Event) GetTenantName() string

func (*Event) GetTimestamp added in v0.9.0 

func (x *Event) GetTimestamp() string

func (*Event) GetTo added in v0.9.0 

func (x *Event) GetTo() *Side

func (*Event) ProtoMessage added in v0.9.0 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect added in v0.9.0 

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

func (*Event) Reset added in v0.9.0 

func (x *Event) Reset()

func (*Event) String added in v0.9.0 

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"`
	CountryCode string  `protobuf:"bytes,7,opt,name=countryCode,proto3" json:"countryCode,omitempty"`
	Accuracy    int32   `protobuf:"varint,8,opt,name=accuracy,proto3" json:"accuracy,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Geolocation.ProtoReflect.Descriptor instead.

func (*Geolocation) GetAccuracy added in v0.9.0 

func (x *Geolocation) GetAccuracy() int32

func (*Geolocation) GetAsn added in v0.9.0 

func (x *Geolocation) GetAsn() int64

func (*Geolocation) GetAso added in v0.9.0 

func (x *Geolocation) GetAso() string

func (*Geolocation) GetCity added in v0.9.0 

func (x *Geolocation) GetCity() string

func (*Geolocation) GetCountry added in v0.9.0 

func (x *Geolocation) GetCountry() string

func (*Geolocation) GetCountryCode added in v0.9.0 

func (x *Geolocation) GetCountryCode() string

func (*Geolocation) GetLatitude added in v0.9.0 

func (x *Geolocation) GetLatitude() float64

func (*Geolocation) GetLongitude added in v0.9.0 

func (x *Geolocation) GetLongitude() float64

func (*Geolocation) ProtoMessage added in v0.9.0 

func (*Geolocation) ProtoMessage()

func (*Geolocation) ProtoReflect added in v0.9.0 

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

func (*Geolocation) Reset added in v0.9.0 

func (x *Geolocation) Reset()

func (*Geolocation) String added in v0.9.0 

func (x *Geolocation) String() string

type Grok added in v0.9.0 

type Grok struct {
	Patterns []*Pattern `protobuf:"bytes,1,rep,name=patterns,proto3" json:"patterns,omitempty"`
	Source   string     `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Where    *Where     `protobuf:"bytes,3,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Grok.ProtoReflect.Descriptor instead.

func (*Grok) GetPatterns added in v0.9.0 

func (x *Grok) GetPatterns() []*Pattern

func (*Grok) GetSource added in v0.9.5 

func (x *Grok) GetSource() string

func (*Grok) GetWhere added in v0.10.0 

func (x *Grok) GetWhere() *Where

func (*Grok) ProtoMessage added in v0.9.0 

func (*Grok) ProtoMessage()

func (*Grok) ProtoReflect added in v0.9.0 

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

func (*Grok) Reset added in v0.9.0 

func (x *Grok) Reset()

func (*Grok) String added in v0.9.0 

func (x *Grok) 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 added in v0.9.0 

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

Deprecated: Use Impact.ProtoReflect.Descriptor instead.

func (*Impact) GetAvailability added in v0.9.0 

func (x *Impact) GetAvailability() int32

func (*Impact) GetConfidentiality added in v0.9.0 

func (x *Impact) GetConfidentiality() int32

func (*Impact) GetIntegrity added in v0.9.0 

func (x *Impact) GetIntegrity() int32

func (*Impact) ProtoMessage added in v0.9.0 

func (*Impact) ProtoMessage()

func (*Impact) ProtoReflect added in v0.9.0 

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

func (*Impact) Reset added in v0.9.0 

func (x *Impact) Reset()

func (*Impact) String added in v0.9.0 

func (x *Impact) String() string

type IntegrationClient added in v0.9.0 

type IntegrationClient interface {
	ProcessLog(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[Log, Ack], 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.9.0 

func NewIntegrationClient(cc grpc.ClientConnInterface) IntegrationClient

type IntegrationServer added in v0.9.0 

type IntegrationServer interface {
	ProcessLog(grpc.BidiStreamingServer[Log, Ack]) 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.9.0 

type Integration_ProcessLogClient = grpc.BidiStreamingClient[Log, Ack]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Integration_ProcessLogServer added in v0.9.0 

type Integration_ProcessLogServer = grpc.BidiStreamingServer[Log, Ack]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type JLog added in v0.9.0 

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.9.0 

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

Deprecated: Use JLog.ProtoReflect.Descriptor instead.

func (*JLog) GetLog added in v0.9.0 

func (x *JLog) GetLog() string

func (*JLog) ProtoMessage added in v0.9.0 

func (*JLog) ProtoMessage()

func (*JLog) ProtoReflect added in v0.9.0 

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

func (*JLog) Reset added in v0.9.0 

func (x *JLog) Reset()

func (*JLog) String added in v0.9.0 

func (x *JLog) String() string

type Json added in v0.9.0 

type Json struct {
	Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Where  *Where `protobuf:"bytes,2,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Json.ProtoReflect.Descriptor instead.

func (*Json) GetSource added in v0.9.0 

func (x *Json) GetSource() string

func (*Json) GetWhere added in v0.10.0 

func (x *Json) GetWhere() *Where

func (*Json) ProtoMessage added in v0.9.0 

func (*Json) ProtoMessage()

func (*Json) ProtoReflect added in v0.9.0 

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

func (*Json) Reset added in v0.9.0 

func (x *Json) Reset()

func (*Json) String added in v0.9.0 

func (x *Json) String() string

type Kv added in v0.9.0 

type Kv struct {
	FieldSplit string `protobuf:"bytes,1,opt,name=fieldSplit,proto3" json:"fieldSplit,omitempty"`
	ValueSplit string `protobuf:"bytes,2,opt,name=valueSplit,proto3" json:"valueSplit,omitempty"`
	Source     string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Where      *Where `protobuf:"bytes,4,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Kv.ProtoReflect.Descriptor instead.

func (*Kv) GetFieldSplit added in v0.9.0 

func (x *Kv) GetFieldSplit() string

func (*Kv) GetSource added in v0.9.5 

func (x *Kv) GetSource() string

func (*Kv) GetValueSplit added in v0.9.0 

func (x *Kv) GetValueSplit() string

func (*Kv) GetWhere added in v0.10.0 

func (x *Kv) GetWhere() *Where

func (*Kv) ProtoMessage added in v0.9.0 

func (*Kv) ProtoMessage()

func (*Kv) ProtoReflect added in v0.9.0 

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

func (*Kv) Reset added in v0.9.0 

func (x *Kv) Reset()

func (*Kv) String added in v0.9.0 

func (x *Kv) String() string

type ListValue added in v0.9.0 

type ListValue = structpb.ListValue

type Log added in v0.9.0 

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,json=@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 added in v0.9.0 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetDataSource added in v0.9.0 

func (x *Log) GetDataSource() string

func (*Log) GetDataType added in v0.9.0 

func (x *Log) GetDataType() string

func (*Log) GetId added in v0.9.0 

func (x *Log) GetId() string

func (*Log) GetRaw added in v0.9.0 

func (x *Log) GetRaw() string

func (*Log) GetTenantId added in v0.9.0 

func (x *Log) GetTenantId() string

func (*Log) GetTimestamp added in v0.9.0 

func (x *Log) GetTimestamp() string

func (*Log) ProtoMessage added in v0.9.0 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect added in v0.9.0 

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

func (*Log) Reset added in v0.9.0 

func (x *Log) Reset()

func (*Log) String added in v0.9.0 

func (x *Log) String() string

type Message added in v0.9.0 

type Message struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Timestamp string `protobuf:"bytes,2,opt,name=timestamp,json=@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 added in v0.9.0 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetId added in v0.9.0 

func (x *Message) GetId() string

func (*Message) GetMessage added in v0.9.0 

func (x *Message) GetMessage() string

func (*Message) GetTimestamp added in v0.9.0 

func (x *Message) GetTimestamp() string

func (*Message) GetTopic added in v0.9.0 

func (x *Message) GetTopic() string

func (*Message) ProtoMessage added in v0.9.0 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect added in v0.9.0 

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

func (*Message) Reset added in v0.9.0 

func (x *Message) Reset()

func (*Message) String added in v0.9.0 

func (x *Message) String() string

type NotificationClient added in v0.9.0 

type NotificationClient interface {
	Notify(ctx context.Context, in *Message, opts ...grpc.CallOption) (*emptypb.Empty, 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.9.0 

func NewNotificationClient(cc grpc.ClientConnInterface) NotificationClient

type NotificationServer added in v0.9.0 

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

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

type NullValue added in v0.9.0 

type NullValue = structpb.NullValue

type ParsingClient added in v0.9.0 

type ParsingClient interface {
	ParseLog(ctx context.Context, in *Transform, 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.9.0 

func NewParsingClient(cc grpc.ClientConnInterface) ParsingClient

type ParsingServer added in v0.9.0 

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

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

type Pattern added in v0.9.0 

type Pattern struct {
	FieldName string `protobuf:"bytes,1,opt,name=fieldName,proto3" json:"fieldName,omitempty"`
	Pattern   string `protobuf:"bytes,2,opt,name=pattern,proto3" json:"pattern,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Pattern.ProtoReflect.Descriptor instead.

func (*Pattern) GetFieldName added in v0.9.0 

func (x *Pattern) GetFieldName() string

func (*Pattern) GetPattern added in v0.9.0 

func (x *Pattern) GetPattern() string

func (*Pattern) ProtoMessage added in v0.9.0 

func (*Pattern) ProtoMessage()

func (*Pattern) ProtoReflect added in v0.9.0 

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

func (*Pattern) Reset added in v0.9.0 

func (x *Pattern) Reset()

func (*Pattern) String added in v0.9.0 

func (x *Pattern) String() string

type Pipeline added in v0.9.0 

type Pipeline struct {
	DataTypes []string `yaml:"dataTypes,omitempty"`
	Steps     []Step   `yaml:"steps,omitempty"`
}

type Reformat added in v0.9.0 

type Reformat struct {
	Fields     []string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	Function   string   `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"`
	FromFormat string   `protobuf:"bytes,3,opt,name=fromFormat,proto3" json:"fromFormat,omitempty"`
	ToFormat   string   `protobuf:"bytes,4,opt,name=toFormat,proto3" json:"toFormat,omitempty"`
	Where      *Where   `protobuf:"bytes,5,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Reformat.ProtoReflect.Descriptor instead.

func (*Reformat) GetFields added in v0.9.0 

func (x *Reformat) GetFields() []string

func (*Reformat) GetFromFormat added in v0.9.0 

func (x *Reformat) GetFromFormat() string

func (*Reformat) GetFunction added in v0.9.0 

func (x *Reformat) GetFunction() string

func (*Reformat) GetToFormat added in v0.9.0 

func (x *Reformat) GetToFormat() string

func (*Reformat) GetWhere added in v0.10.0 

func (x *Reformat) GetWhere() *Where

func (*Reformat) ProtoMessage added in v0.9.0 

func (*Reformat) ProtoMessage()

func (*Reformat) ProtoReflect added in v0.9.0 

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

func (*Reformat) Reset added in v0.9.0 

func (x *Reformat) Reset()

func (*Reformat) String added in v0.9.0 

func (x *Reformat) String() string

type Rename added in v0.9.0 

type Rename struct {
	To    string   `protobuf:"bytes,1,opt,name=to,proto3" json:"to,omitempty"`
	From  []string `protobuf:"bytes,2,rep,name=from,proto3" json:"from,omitempty"`
	Where *Where   `protobuf:"bytes,3,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Rename.ProtoReflect.Descriptor instead.

func (*Rename) GetFrom added in v0.9.0 

func (x *Rename) GetFrom() []string

func (*Rename) GetTo added in v0.9.0 

func (x *Rename) GetTo() string

func (*Rename) GetWhere added in v0.10.0 

func (x *Rename) GetWhere() *Where

func (*Rename) ProtoMessage added in v0.9.0 

func (*Rename) ProtoMessage()

func (*Rename) ProtoReflect added in v0.9.0 

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

func (*Rename) Reset added in v0.9.0 

func (x *Rename) Reset()

func (*Rename) String added in v0.9.0 

func (x *Rename) String() string

type Side 

type Side struct {
	BytesSent        float64        `protobuf:"fixed64,1,opt,name=bytesSent,proto3" json:"bytesSent,omitempty"`
	BytesReceived    float64        `protobuf:"fixed64,2,opt,name=bytesReceived,proto3" json:"bytesReceived,omitempty"`
	PackagesSent     int64          `protobuf:"varint,3,opt,name=packagesSent,proto3" json:"packagesSent,omitempty"`
	PackagesReceived int64          `protobuf:"varint,4,opt,name=packagesReceived,proto3" json:"packagesReceived,omitempty"`
	Connections      int64          `protobuf:"varint,5,opt,name=connections,proto3" json:"connections,omitempty"`
	UsedCpuPercent   int64          `protobuf:"varint,6,opt,name=usedCpuPercent,proto3" json:"usedCpuPercent,omitempty"`
	UsedMemPercent   int64          `protobuf:"varint,7,opt,name=usedMemPercent,proto3" json:"usedMemPercent,omitempty"`
	FreeCpuPercent   int64          `protobuf:"varint,8,opt,name=freeCpuPercent,proto3" json:"freeCpuPercent,omitempty"`
	FreeMemPercent   int64          `protobuf:"varint,9,opt,name=freeMemPercent,proto3" json:"freeMemPercent,omitempty"`
	TotalCpuPercent  int64          `protobuf:"varint,10,opt,name=totalCpuPercent,proto3" json:"totalCpuPercent,omitempty"`
	TotalMemPercent  int64          `protobuf:"varint,11,opt,name=totalMemPercent,proto3" json:"totalMemPercent,omitempty"`
	Ip               string         `protobuf:"bytes,12,opt,name=ip,proto3" json:"ip,omitempty"`
	Ips              []string       `protobuf:"bytes,13,rep,name=ips,proto3" json:"ips,omitempty"`
	Host             string         `protobuf:"bytes,14,opt,name=host,proto3" json:"host,omitempty"`
	Hosts            []string       `protobuf:"bytes,15,rep,name=hosts,proto3" json:"hosts,omitempty"`
	User             string         `protobuf:"bytes,16,opt,name=user,proto3" json:"user,omitempty"`
	Users            []string       `protobuf:"bytes,17,rep,name=users,proto3" json:"users,omitempty"`
	Group            string         `protobuf:"bytes,18,opt,name=group,proto3" json:"group,omitempty"`
	Groups           []string       `protobuf:"bytes,19,rep,name=groups,proto3" json:"groups,omitempty"`
	Port             int64          `protobuf:"varint,20,opt,name=port,proto3" json:"port,omitempty"`
	Ports            []int64        `protobuf:"varint,21,rep,packed,name=ports,proto3" json:"ports,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"`
	Geolocation      *Geolocation   `protobuf:"bytes,30,opt,name=geolocation,proto3" json:"geolocation,omitempty"`
	Geolocations     []*Geolocation `protobuf:"bytes,31,rep,name=geolocations,proto3" json:"geolocations,omitempty"`
	File             string         `protobuf:"bytes,32,opt,name=file,proto3" json:"file,omitempty"`
	Files            []string       `protobuf:"bytes,33,rep,name=files,proto3" json:"files,omitempty"`
	Path             string         `protobuf:"bytes,34,opt,name=path,proto3" json:"path,omitempty"`
	Paths            []string       `protobuf:"bytes,35,rep,name=paths,proto3" json:"paths,omitempty"`
	Md5              string         `protobuf:"bytes,36,opt,name=md5,proto3" json:"md5,omitempty"`
	Md5S             []string       `protobuf:"bytes,37,rep,name=md5s,proto3" json:"md5s,omitempty"`
	Sha1             string         `protobuf:"bytes,38,opt,name=sha1,proto3" json:"sha1,omitempty"`
	Sha1S            []string       `protobuf:"bytes,39,rep,name=sha1s,proto3" json:"sha1s,omitempty"`
	Sha256           string         `protobuf:"bytes,40,opt,name=sha256,proto3" json:"sha256,omitempty"`
	Sha256S          []string       `protobuf:"bytes,41,rep,name=sha256s,proto3" json:"sha256s,omitempty"`
	Url              string         `protobuf:"bytes,42,opt,name=url,proto3" json:"url,omitempty"`
	Urls             []string       `protobuf:"bytes,43,rep,name=urls,proto3" json:"urls,omitempty"`
	Email            string         `protobuf:"bytes,44,opt,name=email,proto3" json:"email,omitempty"`
	Emails           []string       `protobuf:"bytes,45,rep,name=emails,proto3" json:"emails,omitempty"`
	Command          string         `protobuf:"bytes,46,opt,name=command,proto3" json:"command,omitempty"`
	Commands         []string       `protobuf:"bytes,47,rep,name=commands,proto3" json:"commands,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Side.ProtoReflect.Descriptor instead.

func (*Side) GetBytesReceived added in v0.9.0 

func (x *Side) GetBytesReceived() float64

func (*Side) GetBytesSent added in v0.9.0 

func (x *Side) GetBytesSent() float64

func (*Side) GetCommand added in v0.9.0 

func (x *Side) GetCommand() string

func (*Side) GetCommands added in v0.9.0 

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

func (*Side) GetConnections added in v0.9.0 

func (x *Side) GetConnections() int64

func (*Side) GetDomain added in v0.9.0 

func (x *Side) GetDomain() string

func (*Side) GetDomains added in v0.9.0 

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

func (*Side) GetEmail added in v0.9.0 

func (x *Side) GetEmail() string

func (*Side) GetEmails added in v0.9.0 

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

func (*Side) GetFile added in v0.9.0 

func (x *Side) GetFile() string

func (*Side) GetFiles added in v0.9.0 

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

func (*Side) GetFqdn added in v0.9.0 

func (x *Side) GetFqdn() string

func (*Side) GetFqdns added in v0.9.0 

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

func (*Side) GetFreeCpuPercent added in v0.9.0 

func (x *Side) GetFreeCpuPercent() int64

func (*Side) GetFreeMemPercent added in v0.9.0 

func (x *Side) GetFreeMemPercent() int64

func (*Side) GetGeolocation added in v0.9.0 

func (x *Side) GetGeolocation() *Geolocation

func (*Side) GetGeolocations added in v0.9.0 

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

func (*Side) GetGroup added in v0.9.0 

func (x *Side) GetGroup() string

func (*Side) GetGroups added in v0.9.0 

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

func (*Side) GetHost added in v0.9.0 

func (x *Side) GetHost() string

func (*Side) GetHosts added in v0.9.0 

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

func (*Side) GetIp added in v0.9.0 

func (x *Side) GetIp() string

func (*Side) GetIps added in v0.9.0 

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

func (*Side) GetMac added in v0.9.0 

func (x *Side) GetMac() string

func (*Side) GetMacs added in v0.9.0 

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

func (*Side) GetMd5 added in v0.9.0 

func (x *Side) GetMd5() string

func (*Side) GetMd5S added in v0.9.0 

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

func (*Side) GetPackagesReceived added in v0.9.0 

func (x *Side) GetPackagesReceived() int64

func (*Side) GetPackagesSent added in v0.9.0 

func (x *Side) GetPackagesSent() int64

func (*Side) GetPath added in v0.9.0 

func (x *Side) GetPath() string

func (*Side) GetPaths added in v0.9.0 

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

func (*Side) GetPort added in v0.9.0 

func (x *Side) GetPort() int64

func (*Side) GetPorts added in v0.9.0 

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

func (*Side) GetProcess added in v0.9.0 

func (x *Side) GetProcess() string

func (*Side) GetProcesses added in v0.9.0 

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

func (*Side) GetSha1 added in v0.9.0 

func (x *Side) GetSha1() string

func (*Side) GetSha1S added in v0.9.0 

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

func (*Side) GetSha256 added in v0.9.0 

func (x *Side) GetSha256() string

func (*Side) GetSha256S added in v0.9.0 

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

func (*Side) GetTotalCpuPercent added in v0.9.0 

func (x *Side) GetTotalCpuPercent() int64

func (*Side) GetTotalMemPercent added in v0.9.0 

func (x *Side) GetTotalMemPercent() int64

func (*Side) GetUrl added in v0.9.0 

func (x *Side) GetUrl() string

func (*Side) GetUrls added in v0.9.0 

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

func (*Side) GetUsedCpuPercent added in v0.9.0 

func (x *Side) GetUsedCpuPercent() int64

func (*Side) GetUsedMemPercent added in v0.9.0 

func (x *Side) GetUsedMemPercent() int64

func (*Side) GetUser added in v0.9.0 

func (x *Side) GetUser() string

func (*Side) GetUsers added in v0.9.0 

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

func (*Side) ProtoMessage added in v0.9.0 

func (*Side) ProtoMessage()

func (*Side) ProtoReflect added in v0.9.0 

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

func (*Side) Reset added in v0.9.0 

func (x *Side) Reset()

func (*Side) String added in v0.9.0 

func (x *Side) String() string

type Step added in v0.9.0 

type Step struct {
	Kv       *Kv       `protobuf:"bytes,1,opt,name=kv,proto3" json:"kv,omitempty"`
	Grok     *Grok     `protobuf:"bytes,2,opt,name=grok,proto3" json:"grok,omitempty"`
	Trim     *Trim     `protobuf:"bytes,3,opt,name=trim,proto3" json:"trim,omitempty"`
	Json     *Json     `protobuf:"bytes,4,opt,name=json,proto3" json:"json,omitempty"`
	Csv      *Csv      `protobuf:"bytes,5,opt,name=csv,proto3" json:"csv,omitempty"`
	Rename   *Rename   `protobuf:"bytes,6,opt,name=rename,proto3" json:"rename,omitempty"`
	Cast     *Cast     `protobuf:"bytes,7,opt,name=cast,proto3" json:"cast,omitempty"`
	Reformat *Reformat `protobuf:"bytes,8,opt,name=reformat,proto3" json:"reformat,omitempty"`
	Delete   *Delete   `protobuf:"bytes,9,opt,name=delete,proto3" json:"delete,omitempty"`
	Drop     *Drop     `protobuf:"bytes,10,opt,name=drop,proto3" json:"drop,omitempty"`
	Add      *Add      `protobuf:"bytes,11,opt,name=add,proto3" json:"add,omitempty"`
	Dynamic  *Dynamic  `protobuf:"bytes,12,opt,name=dynamic,proto3" json:"dynamic,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Step.ProtoReflect.Descriptor instead.

func (*Step) GetAdd added in v0.9.0 

func (x *Step) GetAdd() *Add

func (*Step) GetCast added in v0.9.0 

func (x *Step) GetCast() *Cast

func (*Step) GetCsv added in v0.9.0 

func (x *Step) GetCsv() *Csv

func (*Step) GetDelete added in v0.9.0 

func (x *Step) GetDelete() *Delete

func (*Step) GetDrop added in v0.9.0 

func (x *Step) GetDrop() *Drop

func (*Step) GetDynamic added in v0.9.0 

func (x *Step) GetDynamic() *Dynamic

func (*Step) GetGrok added in v0.9.0 

func (x *Step) GetGrok() *Grok

func (*Step) GetJson added in v0.9.0 

func (x *Step) GetJson() *Json

func (*Step) GetKv added in v0.9.0 

func (x *Step) GetKv() *Kv

func (*Step) GetReformat added in v0.9.0 

func (x *Step) GetReformat() *Reformat

func (*Step) GetRename added in v0.9.0 

func (x *Step) GetRename() *Rename

func (*Step) GetTrim added in v0.9.0 

func (x *Step) GetTrim() *Trim

func (*Step) ProtoMessage added in v0.9.0 

func (*Step) ProtoMessage()

func (*Step) ProtoReflect added in v0.9.0 

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

func (*Step) Reset added in v0.9.0 

func (x *Step) Reset()

func (*Step) String added in v0.9.0 

func (x *Step) String() string

type Struct added in v0.9.0 

type Struct = structpb.Struct

type Tenant added in v0.9.0 

type Tenant struct {
	Name          string  `yaml:"name"`
	Id            string  `yaml:"id"`
	Assets        []Asset `yaml:"assets,omitempty"`
	DisabledRules []int64 `yaml:"disabledRules,omitempty"`
}

type Transform added in v0.9.0 

type Transform struct {
	Jlog *JLog `protobuf:"bytes,1,opt,name=jlog,proto3" json:"jlog,omitempty"`
	Step *Step `protobuf:"bytes,2,opt,name=step,proto3" json:"step,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Transform.ProtoReflect.Descriptor instead.

func (*Transform) GetJlog added in v0.9.0 

func (x *Transform) GetJlog() *JLog

func (*Transform) GetStep added in v0.9.0 

func (x *Transform) GetStep() *Step

func (*Transform) ProtoMessage added in v0.9.0 

func (*Transform) ProtoMessage()

func (*Transform) ProtoReflect added in v0.9.0 

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

func (*Transform) Reset added in v0.9.0 

func (x *Transform) Reset()

func (*Transform) String added in v0.9.0 

func (x *Transform) String() string

type Trim added in v0.9.0 

type Trim struct {
	Function  string   `protobuf:"bytes,1,opt,name=function,proto3" json:"function,omitempty"`
	Substring string   `protobuf:"bytes,2,opt,name=substring,proto3" json:"substring,omitempty"`
	Fields    []string `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	Where     *Where   `protobuf:"bytes,4,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Trim.ProtoReflect.Descriptor instead.

func (*Trim) GetFields added in v0.9.0 

func (x *Trim) GetFields() []string

func (*Trim) GetFunction added in v0.9.0 

func (x *Trim) GetFunction() string

func (*Trim) GetSubstring added in v0.9.0 

func (x *Trim) GetSubstring() string

func (*Trim) GetWhere added in v0.10.0 

func (x *Trim) GetWhere() *Where

func (*Trim) ProtoMessage added in v0.9.0 

func (*Trim) ProtoMessage()

func (*Trim) ProtoReflect added in v0.9.0 

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

func (*Trim) Reset added in v0.9.0 

func (x *Trim) Reset()

func (*Trim) String added in v0.9.0 

func (x *Trim) String() string

type UnimplementedAnalysisServer added in v0.9.0 

type UnimplementedAnalysisServer struct{}

UnimplementedAnalysisServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAnalysisServer) Analyze added in v0.9.0 

func (UnimplementedAnalysisServer) Analyze(*Event, grpc.ServerStreamingServer[Alert]) error

type UnimplementedCorrelationServer added in v0.9.0 

type UnimplementedCorrelationServer struct{}

UnimplementedCorrelationServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedCorrelationServer) Correlate added in v0.9.0 

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

type UnimplementedEngineServer added in v0.9.0 

type UnimplementedEngineServer struct{}

UnimplementedEngineServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedEngineServer) Input added in v0.9.0 

func (UnimplementedEngineServer) Input(grpc.BidiStreamingServer[Log, Ack]) error

func (UnimplementedEngineServer) Notify added in v0.9.0 

func (UnimplementedEngineServer) Notify(grpc.BidiStreamingServer[Message, Ack]) error

type UnimplementedIntegrationServer added in v0.9.0 

type UnimplementedIntegrationServer struct{}

UnimplementedIntegrationServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedIntegrationServer) ProcessLog added in v0.9.0 

func (UnimplementedIntegrationServer) ProcessLog(grpc.BidiStreamingServer[Log, Ack]) error

type UnimplementedNotificationServer added in v0.9.0 

type UnimplementedNotificationServer struct{}

UnimplementedNotificationServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedNotificationServer) Notify added in v0.9.0 

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

type UnimplementedParsingServer added in v0.9.0 

type UnimplementedParsingServer struct{}

UnimplementedParsingServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedParsingServer) ParseLog added in v0.9.0 

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

type UnsafeAnalysisServer added in v0.9.0 

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.9.0 

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.9.0 

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.9.0 

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.9.0 

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.9.0 

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 added in v0.9.0 

type Value = structpb.Value

type Value_BoolValue added in v0.9.0 

type Value_BoolValue = structpb.Value_BoolValue

type Value_ListValue added in v0.9.0 

type Value_ListValue = structpb.Value_ListValue

type Value_NullValue added in v0.9.0 

type Value_NullValue = structpb.Value_NullValue

type Value_NumberValue added in v0.9.0 

type Value_NumberValue = structpb.Value_NumberValue

type Value_StringValue added in v0.9.0 

type Value_StringValue = structpb.Value_StringValue

type Value_StructValue added in v0.9.0 

type Value_StructValue = structpb.Value_StructValue

type Variable added in v0.9.0 

type Variable struct {
	Get    string `protobuf:"bytes,1,opt,name=get,proto3" json:"get,omitempty"`
	As     string `protobuf:"bytes,2,opt,name=as,proto3" json:"as,omitempty"`
	OfType string `protobuf:"bytes,3,opt,name=ofType,proto3" json:"ofType,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Variable.ProtoReflect.Descriptor instead.

func (*Variable) GetAs added in v0.9.0 

func (x *Variable) GetAs() string

func (*Variable) GetGet added in v0.9.0 

func (x *Variable) GetGet() string

func (*Variable) GetOfType added in v0.9.0 

func (x *Variable) GetOfType() string

func (*Variable) ProtoMessage added in v0.9.0 

func (*Variable) ProtoMessage()

func (*Variable) ProtoReflect added in v0.9.0 

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

func (*Variable) Reset added in v0.9.0 

func (x *Variable) Reset()

func (*Variable) String added in v0.9.0 

func (x *Variable) String() string

type Where added in v0.9.0 

type Where struct {
	Variables  []*Variable `protobuf:"bytes,1,rep,name=variables,proto3" json:"variables,omitempty"`
	Expression string      `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Where.ProtoReflect.Descriptor instead.

func (*Where) Evaluate added in v0.9.0 

func (def *Where) Evaluate(event *string) bool

func (*Where) GetExpression added in v0.9.0 

func (x *Where) GetExpression() string

func (*Where) GetVariables added in v0.9.0 

func (x *Where) GetVariables() []*Variable

func (*Where) ProtoMessage added in v0.9.0 

func (*Where) ProtoMessage()

func (*Where) ProtoReflect added in v0.9.0 

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

func (*Where) Reset added in v0.9.0 

func (x *Where) Reset()

func (*Where) String added in v0.9.0 

func (x *Where) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.