nflogpb

package
v0.29.0 Latest Latest
Warning

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

 Go to latest Published: Nov 3, 2025 License: Apache-2.0 Imports: 8 Imported by: 103

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthNflog        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNflog          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupNflog = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type Entry 

type Entry struct {
	// The key identifying the dispatching group.
	GroupKey []byte `protobuf:"bytes,1,opt,name=group_key,json=groupKey,proto3" json:"group_key,omitempty"`
	// The receiver that was notified.
	Receiver *Receiver `protobuf:"bytes,2,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// Hash over the state of the group at notification time.
	// Deprecated in favor of FiringAlerts field, but kept for compatibility.
	GroupHash []byte `protobuf:"bytes,3,opt,name=group_hash,json=groupHash,proto3" json:"group_hash,omitempty"`
	// Whether the notification was about a resolved alert.
	// Deprecated in favor of ResolvedAlerts field, but kept for compatibility.
	Resolved bool `protobuf:"varint,4,opt,name=resolved,proto3" json:"resolved,omitempty"`
	// Timestamp of the succeeding notification.
	Timestamp time.Time `protobuf:"bytes,5,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
	// FiringAlerts list of hashes of firing alerts at the last notification time.
	FiringAlerts []uint64 `protobuf:"varint,6,rep,packed,name=firing_alerts,json=firingAlerts,proto3" json:"firing_alerts,omitempty"`
	// ResolvedAlerts list of hashes of resolved alerts at the last notification time.
	ResolvedAlerts       []uint64 `protobuf:"varint,7,rep,packed,name=resolved_alerts,json=resolvedAlerts,proto3" json:"resolved_alerts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Entry holds information about a successful notification sent to a receiver.

func (*Entry) Descriptor 

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

func (*Entry) IsFiringSubset added in v0.6.0 

func (m *Entry) IsFiringSubset(subset map[uint64]struct{}) bool

IsFiringSubset returns whether the given subset is a subset of the alerts that were firing at the time of the last notification.

func (*Entry) IsResolvedSubset added in v0.6.0 

func (m *Entry) IsResolvedSubset(subset map[uint64]struct{}) bool

IsResolvedSubset returns whether the given subset is a subset of the alerts that were resolved at the time of the last notification.

func (*Entry) Marshal added in v0.6.0 

func (m *Entry) Marshal() (dAtA []byte, err error)

func (*Entry) MarshalTo added in v0.6.0 

func (m *Entry) MarshalTo(dAtA []byte) (int, error)

func (*Entry) MarshalToSizedBuffer added in v0.19.0 

func (m *Entry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) Reset 

func (m *Entry) Reset()

func (*Entry) Size added in v0.6.0 

func (m *Entry) Size() (n int)

func (*Entry) String 

func (m *Entry) String() string

func (*Entry) Unmarshal added in v0.6.0 

func (m *Entry) Unmarshal(dAtA []byte) error

func (*Entry) XXX_DiscardUnknown added in v0.17.0 

func (m *Entry) XXX_DiscardUnknown()

func (*Entry) XXX_Marshal added in v0.17.0 

func (m *Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Entry) XXX_Merge added in v0.17.0 

func (m *Entry) XXX_Merge(src proto.Message)

func (*Entry) XXX_Size added in v0.17.0 

func (m *Entry) XXX_Size() int

func (*Entry) XXX_Unmarshal added in v0.17.0 

func (m *Entry) XXX_Unmarshal(b []byte) error

type MeshEntry 

type MeshEntry struct {
	// The original raw notify log entry.
	Entry *Entry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	// A timestamp indicating when the mesh peer should evict
	// the log entry from its state.
	ExpiresAt            time.Time `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3,stdtime" json:"expires_at"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

MeshEntry is a wrapper message to communicate a notify log entry through a mesh network.

func (*MeshEntry) Descriptor 

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

func (*MeshEntry) Marshal added in v0.6.0 

func (m *MeshEntry) Marshal() (dAtA []byte, err error)

func (*MeshEntry) MarshalTo added in v0.6.0 

func (m *MeshEntry) MarshalTo(dAtA []byte) (int, error)

func (*MeshEntry) MarshalToSizedBuffer added in v0.19.0 

func (m *MeshEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MeshEntry) ProtoMessage 

func (*MeshEntry) ProtoMessage()

func (*MeshEntry) Reset 

func (m *MeshEntry) Reset()

func (*MeshEntry) Size added in v0.6.0 

func (m *MeshEntry) Size() (n int)

func (*MeshEntry) String 

func (m *MeshEntry) String() string

func (*MeshEntry) Unmarshal added in v0.6.0 

func (m *MeshEntry) Unmarshal(dAtA []byte) error

func (*MeshEntry) XXX_DiscardUnknown added in v0.17.0 

func (m *MeshEntry) XXX_DiscardUnknown()

func (*MeshEntry) XXX_Marshal added in v0.17.0 

func (m *MeshEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshEntry) XXX_Merge added in v0.17.0 

func (m *MeshEntry) XXX_Merge(src proto.Message)

func (*MeshEntry) XXX_Size added in v0.17.0 

func (m *MeshEntry) XXX_Size() int

func (*MeshEntry) XXX_Unmarshal added in v0.17.0 

func (m *MeshEntry) XXX_Unmarshal(b []byte) error

type Receiver 

type Receiver struct {
	// Configured name of the receiver group.
	GroupName string `protobuf:"bytes,1,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// Name of the integration of the receiver.
	Integration string `protobuf:"bytes,2,opt,name=integration,proto3" json:"integration,omitempty"`
	// Index of the receiver with respect to the integration.
	// Every integration in a group may have 0..N configurations.
	Idx                  uint32   `protobuf:"varint,3,opt,name=idx,proto3" json:"idx,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Receiver) Descriptor 

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

func (*Receiver) Marshal added in v0.6.0 

func (m *Receiver) Marshal() (dAtA []byte, err error)

func (*Receiver) MarshalTo added in v0.6.0 

func (m *Receiver) MarshalTo(dAtA []byte) (int, error)

func (*Receiver) MarshalToSizedBuffer added in v0.19.0 

func (m *Receiver) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Receiver) ProtoMessage 

func (*Receiver) ProtoMessage()

func (*Receiver) Reset 

func (m *Receiver) Reset()

func (*Receiver) Size added in v0.6.0 

func (m *Receiver) Size() (n int)

func (*Receiver) String 

func (m *Receiver) String() string

func (*Receiver) Unmarshal added in v0.6.0 

func (m *Receiver) Unmarshal(dAtA []byte) error

func (*Receiver) XXX_DiscardUnknown added in v0.17.0 

func (m *Receiver) XXX_DiscardUnknown()

func (*Receiver) XXX_Marshal added in v0.17.0 

func (m *Receiver) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Receiver) XXX_Merge added in v0.17.0 

func (m *Receiver) XXX_Merge(src proto.Message)

func (*Receiver) XXX_Size added in v0.17.0 

func (m *Receiver) XXX_Size() int

func (*Receiver) XXX_Unmarshal added in v0.17.0 

func (m *Receiver) XXX_Unmarshal(b []byte) 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.