pipeline_event

Documentation

Index

• Variables
• func Marshal(event *PipelineEvent) ([]byte, error)
• func Unmarshal(data []byte, event *PipelineEvent) error
• type PipelineEvent
  • func (*PipelineEvent) Descriptor() ([]byte, []int)
  • func (x *PipelineEvent) GetPayload() []byte
  • func (x *PipelineEvent) GetPipelineID() uint64
  • func (x *PipelineEvent) GetSequence() uint64
  • func (*PipelineEvent) ProtoMessage()
  • func (x *PipelineEvent) ProtoReflect() protoreflect.Message
  • func (x *PipelineEvent) Reset()
  • func (x *PipelineEvent) String() string

Variables

var File_types_pipeline_event_pipeline_event_proto protoreflect.FileDescriptor

Functions

func Marshal

func Marshal(event *PipelineEvent) ([]byte, error)

func Unmarshal

func Unmarshal(data []byte, event *PipelineEvent) error

Types

type PipelineEvent

type PipelineEvent struct {
	PipelineID uint64 `protobuf:"varint,1,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	Sequence   uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Payload    []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineEvent) Descriptor

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

Deprecated: Use PipelineEvent.ProtoReflect.Descriptor instead.

func (*PipelineEvent) GetPayload

func (x *PipelineEvent) GetPayload() []byte

func (*PipelineEvent) GetPipelineID

func (x *PipelineEvent) GetPipelineID() uint64

func (*PipelineEvent) GetSequence

func (x *PipelineEvent) GetSequence() uint64

func (*PipelineEvent) ProtoMessage

func (*PipelineEvent) ProtoMessage()

func (*PipelineEvent) ProtoReflect

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

func (*PipelineEvent) Reset

func (x *PipelineEvent) Reset()

func (*PipelineEvent) String

func (x *PipelineEvent) String() string