pb

package
v0.0.0-...-dd22d64 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2021 License: AGPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EventType_name = map[int32]string{
		0: "UNDEFINED",
		1: "SECURITY",
	}
	EventType_value = map[string]int32{
		"UNDEFINED": 0,
		"SECURITY":  1,
	}
)

Enum value maps for EventType.

View Source 
var (
	EventLevel_name = map[int32]string{
		0: "INFO",
		1: "LOW",
		2: "MEDIUM",
		3: "HIGH",
		4: "CRITICAL",
	}
	EventLevel_value = map[string]int32{
		"INFO":     0,
		"LOW":      1,
		"MEDIUM":   2,
		"HIGH":     3,
		"CRITICAL": 4,
	}
)

Enum value maps for EventLevel.

View Source 
var (
	EventData_DataEnc_name = map[int32]string{
		0: "NODATA",
		1: "JSON",
	}
	EventData_DataEnc_value = map[string]int32{
		"NODATA": 0,
		"JSON":   1,
	}
)

Enum value maps for EventData_DataEnc.

View Source 
var File_github_com_luids_io_api_schemas_event_archive_proto protoreflect.FileDescriptor
View Source 
var File_github_com_luids_io_api_schemas_event_common_proto protoreflect.FileDescriptor
View Source 
var File_github_com_luids_io_api_schemas_event_forward_proto protoreflect.FileDescriptor
View Source 
var File_github_com_luids_io_api_schemas_event_notify_proto protoreflect.FileDescriptor

Functions

func RegisterArchiveServer 

func RegisterArchiveServer(s *grpc.Server, srv ArchiveServer)

func RegisterForwardServer 

func RegisterForwardServer(s *grpc.Server, srv ForwardServer)

func RegisterNotifyServer 

func RegisterNotifyServer(s *grpc.Server, srv NotifyServer)

Types

type ArchiveClient 

type ArchiveClient interface {
	SaveEvent(ctx context.Context, in *SaveEventRequest, opts ...grpc.CallOption) (*SaveEventResponse, error)
}

ArchiveClient is the client API for Archive service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewArchiveClient 

func NewArchiveClient(cc grpc.ClientConnInterface) ArchiveClient

type ArchiveServer 

type ArchiveServer interface {
	SaveEvent(context.Context, *SaveEventRequest) (*SaveEventResponse, error)
}

ArchiveServer is the server API for Archive service.

type EventData 

type EventData struct {
	DataEnc EventData_DataEnc `protobuf:"varint,1,opt,name=dataEnc,proto3,enum=luids.event.v1.EventData_DataEnc" json:"dataEnc,omitempty"`
	Data    []byte            `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*EventData) Descriptor deprecated 

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

Deprecated: Use EventData.ProtoReflect.Descriptor instead.

func (*EventData) GetData 

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

func (*EventData) GetDataEnc 

func (x *EventData) GetDataEnc() EventData_DataEnc

func (*EventData) ProtoMessage 

func (*EventData) ProtoMessage()

func (*EventData) ProtoReflect 

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

func (*EventData) Reset 

func (x *EventData) Reset()

func (*EventData) String 

func (x *EventData) String() string

type EventData_DataEnc 

type EventData_DataEnc int32
const (
	EventData_NODATA EventData_DataEnc = 0
	EventData_JSON   EventData_DataEnc = 1
)

func (EventData_DataEnc) Descriptor 

func (EventData_DataEnc) Descriptor() protoreflect.EnumDescriptor

func (EventData_DataEnc) Enum 

func (x EventData_DataEnc) Enum() *EventData_DataEnc

func (EventData_DataEnc) EnumDescriptor deprecated 

func (EventData_DataEnc) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventData_DataEnc.Descriptor instead.

func (EventData_DataEnc) Number 

func (x EventData_DataEnc) Number() protoreflect.EnumNumber

func (EventData_DataEnc) String 

func (x EventData_DataEnc) String() string

func (EventData_DataEnc) Type 

func (EventData_DataEnc) Type() protoreflect.EnumType

type EventLevel 

type EventLevel int32
const (
	EventLevel_INFO     EventLevel = 0
	EventLevel_LOW      EventLevel = 1
	EventLevel_MEDIUM   EventLevel = 2
	EventLevel_HIGH     EventLevel = 3
	EventLevel_CRITICAL EventLevel = 4
)

func (EventLevel) Descriptor 

func (EventLevel) Descriptor() protoreflect.EnumDescriptor

func (EventLevel) Enum 

func (x EventLevel) Enum() *EventLevel

func (EventLevel) EnumDescriptor deprecated 

func (EventLevel) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventLevel.Descriptor instead.

func (EventLevel) Number 

func (x EventLevel) Number() protoreflect.EnumNumber

func (EventLevel) String 

func (x EventLevel) String() string

func (EventLevel) Type 

func (EventLevel) Type() protoreflect.EnumType

type EventSource 

type EventSource struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Program  string `protobuf:"bytes,2,opt,name=program,proto3" json:"program,omitempty"`
	Instance string `protobuf:"bytes,3,opt,name=instance,proto3" json:"instance,omitempty"`
	Pid      uint32 `protobuf:"varint,4,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*EventSource) Descriptor deprecated 

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

Deprecated: Use EventSource.ProtoReflect.Descriptor instead.

func (*EventSource) GetHostname 

func (x *EventSource) GetHostname() string

func (*EventSource) GetInstance 

func (x *EventSource) GetInstance() string

func (*EventSource) GetPid 

func (x *EventSource) GetPid() uint32

func (*EventSource) GetProgram 

func (x *EventSource) GetProgram() string

func (*EventSource) ProtoMessage 

func (*EventSource) ProtoMessage()

func (*EventSource) ProtoReflect 

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

func (*EventSource) Reset 

func (x *EventSource) Reset()

func (*EventSource) String 

func (x *EventSource) String() string

type EventType 

type EventType int32
const (
	EventType_UNDEFINED EventType = 0
	EventType_SECURITY  EventType = 1
)

func (EventType) Descriptor 

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum 

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated 

func (EventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number 

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String 

func (x EventType) String() string

func (EventType) Type 

func (EventType) Type() protoreflect.EnumType

type ForwardClient 

type ForwardClient interface {
	ForwardEvent(ctx context.Context, in *ForwardEventRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

ForwardClient is the client API for Forward service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewForwardClient 

func NewForwardClient(cc grpc.ClientConnInterface) ForwardClient

type ForwardEventRequest 

type ForwardEventRequest struct {
	Id          string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type        EventType            `protobuf:"varint,2,opt,name=type,proto3,enum=luids.event.v1.EventType" json:"type,omitempty"`
	Code        int32                `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`
	Level       EventLevel           `protobuf:"varint,4,opt,name=level,proto3,enum=luids.event.v1.EventLevel" json:"level,omitempty"`
	CreatedTs   *timestamp.Timestamp `protobuf:"bytes,5,opt,name=created_ts,json=createdTs,proto3" json:"created_ts,omitempty"`
	ReceivedTs  *timestamp.Timestamp `protobuf:"bytes,6,opt,name=received_ts,json=receivedTs,proto3" json:"received_ts,omitempty"`
	Source      *EventSource         `protobuf:"bytes,7,opt,name=source,proto3" json:"source,omitempty"`
	Processors  []*ProcessInfo       `protobuf:"bytes,8,rep,name=processors,proto3" json:"processors,omitempty"`
	Data        *EventData           `protobuf:"bytes,9,opt,name=data,proto3" json:"data,omitempty"`
	Duplicates  int32                `protobuf:"varint,10,opt,name=duplicates,proto3" json:"duplicates,omitempty"`
	Codename    string               `protobuf:"bytes,11,opt,name=codename,proto3" json:"codename,omitempty"`
	Description string               `protobuf:"bytes,12,opt,name=description,proto3" json:"description,omitempty"`
	Tags        []string             `protobuf:"bytes,13,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardEventRequest) Descriptor deprecated 

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

Deprecated: Use ForwardEventRequest.ProtoReflect.Descriptor instead.

func (*ForwardEventRequest) GetCode 

func (x *ForwardEventRequest) GetCode() int32

func (*ForwardEventRequest) GetCodename 

func (x *ForwardEventRequest) GetCodename() string

func (*ForwardEventRequest) GetCreatedTs 

func (x *ForwardEventRequest) GetCreatedTs() *timestamp.Timestamp

func (*ForwardEventRequest) GetData 

func (x *ForwardEventRequest) GetData() *EventData

func (*ForwardEventRequest) GetDescription 

func (x *ForwardEventRequest) GetDescription() string

func (*ForwardEventRequest) GetDuplicates 

func (x *ForwardEventRequest) GetDuplicates() int32

func (*ForwardEventRequest) GetId 

func (x *ForwardEventRequest) GetId() string

func (*ForwardEventRequest) GetLevel 

func (x *ForwardEventRequest) GetLevel() EventLevel

func (*ForwardEventRequest) GetProcessors 

func (x *ForwardEventRequest) GetProcessors() []*ProcessInfo

func (*ForwardEventRequest) GetReceivedTs 

func (x *ForwardEventRequest) GetReceivedTs() *timestamp.Timestamp

func (*ForwardEventRequest) GetSource 

func (x *ForwardEventRequest) GetSource() *EventSource

func (*ForwardEventRequest) GetTags 

func (x *ForwardEventRequest) GetTags() []string

func (*ForwardEventRequest) GetType 

func (x *ForwardEventRequest) GetType() EventType

func (*ForwardEventRequest) ProtoMessage 

func (*ForwardEventRequest) ProtoMessage()

func (*ForwardEventRequest) ProtoReflect 

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

func (*ForwardEventRequest) Reset 

func (x *ForwardEventRequest) Reset()

func (*ForwardEventRequest) String 

func (x *ForwardEventRequest) String() string

type ForwardServer 

type ForwardServer interface {
	ForwardEvent(context.Context, *ForwardEventRequest) (*empty.Empty, error)
}

ForwardServer is the server API for Forward service.

type NotifyClient 

type NotifyClient interface {
	NotifyEvent(ctx context.Context, in *NotifyEventRequest, opts ...grpc.CallOption) (*NotifyEventResponse, error)
}

NotifyClient is the client API for Notify service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNotifyClient 

func NewNotifyClient(cc grpc.ClientConnInterface) NotifyClient

type NotifyEventRequest 

type NotifyEventRequest struct {
	Code       int32                `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Level      EventLevel           `protobuf:"varint,2,opt,name=level,proto3,enum=luids.event.v1.EventLevel" json:"level,omitempty"`
	CreatedTs  *timestamp.Timestamp `protobuf:"bytes,3,opt,name=created_ts,json=createdTs,proto3" json:"created_ts,omitempty"`
	Source     *EventSource         `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	Data       *EventData           `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	Duplicates int32                `protobuf:"varint,6,opt,name=duplicates,proto3" json:"duplicates,omitempty"`
	// contains filtered or unexported fields
}

func (*NotifyEventRequest) Descriptor deprecated 

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

Deprecated: Use NotifyEventRequest.ProtoReflect.Descriptor instead.

func (*NotifyEventRequest) GetCode 

func (x *NotifyEventRequest) GetCode() int32

func (*NotifyEventRequest) GetCreatedTs 

func (x *NotifyEventRequest) GetCreatedTs() *timestamp.Timestamp

func (*NotifyEventRequest) GetData 

func (x *NotifyEventRequest) GetData() *EventData

func (*NotifyEventRequest) GetDuplicates 

func (x *NotifyEventRequest) GetDuplicates() int32

func (*NotifyEventRequest) GetLevel 

func (x *NotifyEventRequest) GetLevel() EventLevel

func (*NotifyEventRequest) GetSource 

func (x *NotifyEventRequest) GetSource() *EventSource

func (*NotifyEventRequest) ProtoMessage 

func (*NotifyEventRequest) ProtoMessage()

func (*NotifyEventRequest) ProtoReflect 

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

func (*NotifyEventRequest) Reset 

func (x *NotifyEventRequest) Reset()

func (*NotifyEventRequest) String 

func (x *NotifyEventRequest) String() string

type NotifyEventResponse 

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

func (*NotifyEventResponse) Descriptor deprecated 

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

Deprecated: Use NotifyEventResponse.ProtoReflect.Descriptor instead.

func (*NotifyEventResponse) GetEventID 

func (x *NotifyEventResponse) GetEventID() string

func (*NotifyEventResponse) ProtoMessage 

func (*NotifyEventResponse) ProtoMessage()

func (*NotifyEventResponse) ProtoReflect 

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

func (*NotifyEventResponse) Reset 

func (x *NotifyEventResponse) Reset()

func (*NotifyEventResponse) String 

func (x *NotifyEventResponse) String() string

type NotifyServer 

type NotifyServer interface {
	NotifyEvent(context.Context, *NotifyEventRequest) (*NotifyEventResponse, error)
}

NotifyServer is the server API for Notify service.

type ProcessInfo 

type ProcessInfo struct {
	ReceivedTs *timestamp.Timestamp `protobuf:"bytes,1,opt,name=received_ts,json=receivedTs,proto3" json:"received_ts,omitempty"`
	Processor  *EventSource         `protobuf:"bytes,2,opt,name=processor,proto3" json:"processor,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessInfo) Descriptor deprecated 

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

Deprecated: Use ProcessInfo.ProtoReflect.Descriptor instead.

func (*ProcessInfo) GetProcessor 

func (x *ProcessInfo) GetProcessor() *EventSource

func (*ProcessInfo) GetReceivedTs 

func (x *ProcessInfo) GetReceivedTs() *timestamp.Timestamp

func (*ProcessInfo) ProtoMessage 

func (*ProcessInfo) ProtoMessage()

func (*ProcessInfo) ProtoReflect 

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

func (*ProcessInfo) Reset 

func (x *ProcessInfo) Reset()

func (*ProcessInfo) String 

func (x *ProcessInfo) String() string

type SaveEventRequest 

type SaveEventRequest struct {
	Id          string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type        EventType            `protobuf:"varint,2,opt,name=type,proto3,enum=luids.event.v1.EventType" json:"type,omitempty"`
	Code        int32                `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`
	Level       EventLevel           `protobuf:"varint,4,opt,name=level,proto3,enum=luids.event.v1.EventLevel" json:"level,omitempty"`
	CreatedTs   *timestamp.Timestamp `protobuf:"bytes,5,opt,name=created_ts,json=createdTs,proto3" json:"created_ts,omitempty"`
	ReceivedTs  *timestamp.Timestamp `protobuf:"bytes,6,opt,name=received_ts,json=receivedTs,proto3" json:"received_ts,omitempty"`
	Source      *EventSource         `protobuf:"bytes,7,opt,name=source,proto3" json:"source,omitempty"`
	Processors  []*ProcessInfo       `protobuf:"bytes,8,rep,name=processors,proto3" json:"processors,omitempty"`
	Data        *EventData           `protobuf:"bytes,9,opt,name=data,proto3" json:"data,omitempty"`
	Duplicates  int32                `protobuf:"varint,10,opt,name=duplicates,proto3" json:"duplicates,omitempty"`
	Codename    string               `protobuf:"bytes,11,opt,name=codename,proto3" json:"codename,omitempty"`
	Description string               `protobuf:"bytes,12,opt,name=description,proto3" json:"description,omitempty"`
	Tags        []string             `protobuf:"bytes,13,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveEventRequest) Descriptor deprecated 

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

Deprecated: Use SaveEventRequest.ProtoReflect.Descriptor instead.

func (*SaveEventRequest) GetCode 

func (x *SaveEventRequest) GetCode() int32

func (*SaveEventRequest) GetCodename 

func (x *SaveEventRequest) GetCodename() string

func (*SaveEventRequest) GetCreatedTs 

func (x *SaveEventRequest) GetCreatedTs() *timestamp.Timestamp

func (*SaveEventRequest) GetData 

func (x *SaveEventRequest) GetData() *EventData

func (*SaveEventRequest) GetDescription 

func (x *SaveEventRequest) GetDescription() string

func (*SaveEventRequest) GetDuplicates 

func (x *SaveEventRequest) GetDuplicates() int32

func (*SaveEventRequest) GetId 

func (x *SaveEventRequest) GetId() string

func (*SaveEventRequest) GetLevel 

func (x *SaveEventRequest) GetLevel() EventLevel

func (*SaveEventRequest) GetProcessors 

func (x *SaveEventRequest) GetProcessors() []*ProcessInfo

func (*SaveEventRequest) GetReceivedTs 

func (x *SaveEventRequest) GetReceivedTs() *timestamp.Timestamp

func (*SaveEventRequest) GetSource 

func (x *SaveEventRequest) GetSource() *EventSource

func (*SaveEventRequest) GetTags 

func (x *SaveEventRequest) GetTags() []string

func (*SaveEventRequest) GetType 

func (x *SaveEventRequest) GetType() EventType

func (*SaveEventRequest) ProtoMessage 

func (*SaveEventRequest) ProtoMessage()

func (*SaveEventRequest) ProtoReflect 

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

func (*SaveEventRequest) Reset 

func (x *SaveEventRequest) Reset()

func (*SaveEventRequest) String 

func (x *SaveEventRequest) String() string

type SaveEventResponse 

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

func (*SaveEventResponse) Descriptor deprecated 

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

Deprecated: Use SaveEventResponse.ProtoReflect.Descriptor instead.

func (*SaveEventResponse) GetStorageID 

func (x *SaveEventResponse) GetStorageID() string

func (*SaveEventResponse) ProtoMessage 

func (*SaveEventResponse) ProtoMessage()

func (*SaveEventResponse) ProtoReflect 

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

func (*SaveEventResponse) Reset 

func (x *SaveEventResponse) Reset()

func (*SaveEventResponse) String 

func (x *SaveEventResponse) String() string

type UnimplementedArchiveServer 

type UnimplementedArchiveServer struct {
}

UnimplementedArchiveServer can be embedded to have forward compatible implementations.

func (*UnimplementedArchiveServer) SaveEvent 

func (*UnimplementedArchiveServer) SaveEvent(context.Context, *SaveEventRequest) (*SaveEventResponse, error)

type UnimplementedForwardServer 

type UnimplementedForwardServer struct {
}

UnimplementedForwardServer can be embedded to have forward compatible implementations.

func (*UnimplementedForwardServer) ForwardEvent 

func (*UnimplementedForwardServer) ForwardEvent(context.Context, *ForwardEventRequest) (*empty.Empty, error)

type UnimplementedNotifyServer 

type UnimplementedNotifyServer struct {
}

UnimplementedNotifyServer can be embedded to have forward compatible implementations.

func (*UnimplementedNotifyServer) NotifyEvent 

func (*UnimplementedNotifyServer) NotifyEvent(context.Context, *NotifyEventRequest) (*NotifyEventResponse, error)

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.