event

Documentation

Index

• Variables
• func FromEventBridgeEvent[T protoreflect.ProtoMessage](event *EventBridgeEvent, into T) error
• type EventBridgeEvent
  • func ToEventBridgeEvent[T protoreflect.ProtoMessage](body T, header *Header) (*EventBridgeEvent, error)
  • func (*EventBridgeEvent) Descriptor() ([]byte, []int)
  • func (x *EventBridgeEvent) GetAccount() string
  • func (x *EventBridgeEvent) GetDetail() *Transport
  • func (x *EventBridgeEvent) GetDetailType() string
  • func (x *EventBridgeEvent) GetId() string
  • func (x *EventBridgeEvent) GetRegion() string
  • func (x *EventBridgeEvent) GetResources() []string
  • func (x *EventBridgeEvent) GetSource() string
  • func (x *EventBridgeEvent) GetTime() string
  • func (x *EventBridgeEvent) GetVersion() string
  • func (*EventBridgeEvent) ProtoMessage()
  • func (x *EventBridgeEvent) ProtoReflect() protoreflect.Message
  • func (e *EventBridgeEvent) Publish(ctx context.Context, awsconfig aws.Config, busName string) error
  • func (x *EventBridgeEvent) Reset()
  • func (x *EventBridgeEvent) String() string
  • func (e *EventBridgeEvent) ToBytes() ([]byte, error)
  • func (e *EventBridgeEvent) ToString() (*string, error)
• type Header
  • func (*Header) Descriptor() ([]byte, []int)
  • func (x *Header) GetDestination() []string
  • func (x *Header) GetFeatures() []string
  • func (x *Header) GetSource() string
  • func (x *Header) GetSubstrate() string
  • func (*Header) ProtoMessage()
  • func (x *Header) ProtoReflect() protoreflect.Message
  • func (x *Header) Reset()
  • func (x *Header) String() string
• type Transport
  • func (*Transport) Descriptor() ([]byte, []int)
  • func (x *Transport) GetBody() *anypb.Any
  • func (x *Transport) GetHeader() *Header
  • func (*Transport) ProtoMessage()
  • func (x *Transport) ProtoReflect() protoreflect.Message
  • func (x *Transport) Reset()
  • func (x *Transport) String() string

Variables

var File_proto_substrate_proto protoreflect.FileDescriptor

Functions

func FromEventBridgeEvent

func FromEventBridgeEvent[T protoreflect.ProtoMessage](event *EventBridgeEvent, into T) error

Types

type EventBridgeEvent

type EventBridgeEvent struct {
	Version    string     `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`                        // Version
	Id         string     `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                  // ID
	Source     string     `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`                          // Source
	Account    string     `protobuf:"bytes,4,opt,name=account,proto3" json:"account,omitempty"`                        // Account
	Time       string     `protobuf:"bytes,5,opt,name=time,proto3" json:"time,omitempty"`                              // Time
	Region     string     `protobuf:"bytes,6,opt,name=region,proto3" json:"region,omitempty"`                          // Region
	Resources  []string   `protobuf:"bytes,7,rep,name=resources,proto3" json:"resources,omitempty"`                    // Resources
	DetailType string     `protobuf:"bytes,8,opt,name=detailType,json=detail-type,proto3" json:"detailType,omitempty"` // Detail type
	Detail     *Transport `protobuf:"bytes,9,opt,name=detail,proto3" json:"detail,omitempty"`                          // Detail
	// contains filtered or unexported fields
}

func ToEventBridgeEvent

func ToEventBridgeEvent[T protoreflect.ProtoMessage](body T, header *Header) (*EventBridgeEvent, error)

func (*EventBridgeEvent) Descriptor

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

Deprecated: Use EventBridgeEvent.ProtoReflect.Descriptor instead.

func (*EventBridgeEvent) GetAccount

func (x *EventBridgeEvent) GetAccount() string

func (*EventBridgeEvent) GetDetail

func (x *EventBridgeEvent) GetDetail() *Transport

func (*EventBridgeEvent) GetDetailType

func (x *EventBridgeEvent) GetDetailType() string

func (*EventBridgeEvent) GetId

func (x *EventBridgeEvent) GetId() string

func (*EventBridgeEvent) GetRegion

func (x *EventBridgeEvent) GetRegion() string

func (*EventBridgeEvent) GetResources

func (x *EventBridgeEvent) GetResources() []string

func (*EventBridgeEvent) GetSource

func (x *EventBridgeEvent) GetSource() string

func (*EventBridgeEvent) GetTime

func (x *EventBridgeEvent) GetTime() string

func (*EventBridgeEvent) GetVersion

func (x *EventBridgeEvent) GetVersion() string

func (*EventBridgeEvent) ProtoMessage

func (*EventBridgeEvent) ProtoMessage()

func (*EventBridgeEvent) ProtoReflect

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

func (*EventBridgeEvent) Publish

func (e *EventBridgeEvent) Publish(ctx context.Context, awsconfig aws.Config, busName string) error

func (*EventBridgeEvent) Reset

func (x *EventBridgeEvent) Reset()

func (*EventBridgeEvent) String

func (x *EventBridgeEvent) String() string

func (*EventBridgeEvent) ToBytes

func (e *EventBridgeEvent) ToBytes() ([]byte, error)

func (*EventBridgeEvent) ToString

func (e *EventBridgeEvent) ToString() (*string, error)

type Header

type Header struct {
	Substrate   string   `protobuf:"bytes,1,opt,name=substrate,proto3" json:"substrate,omitempty"`     // Substrate name
	Features    []string `protobuf:"bytes,2,rep,name=features,proto3" json:"features,omitempty"`       // Substrate feature flags
	Source      string   `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`           // Substrate source
	Destination []string `protobuf:"bytes,4,rep,name=destination,proto3" json:"destination,omitempty"` // Substrate destination
	// contains filtered or unexported fields
}

func (*Header) Descriptor

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetDestination

func (x *Header) GetDestination() []string

func (*Header) GetFeatures

func (x *Header) GetFeatures() []string

func (*Header) GetSource

func (x *Header) GetSource() string

func (*Header) GetSubstrate

func (x *Header) GetSubstrate() string

func (*Header) ProtoMessage

func (*Header) ProtoMessage()

func (*Header) ProtoReflect

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

func (*Header) Reset

func (x *Header) Reset()

func (*Header) String

func (x *Header) String() string

type Transport

type Transport struct {
	Header *Header    `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // Header
	Body   *anypb.Any `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`     // Body
	// contains filtered or unexported fields
}

func (*Transport) Descriptor

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

Deprecated: Use Transport.ProtoReflect.Descriptor instead.

func (*Transport) GetBody

func (x *Transport) GetBody() *anypb.Any

func (*Transport) GetHeader

func (x *Transport) GetHeader() *Header

func (*Transport) ProtoMessage

func (*Transport) ProtoMessage()

func (*Transport) ProtoReflect

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

func (*Transport) Reset

func (x *Transport) Reset()

func (*Transport) String

func (x *Transport) String() string