pipeline_event

package
v1.0.12 Latest Latest
Warning

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

Go to latest
Published: Sep 15, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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 deprecated

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL