events

Documentation

Overview

Package events defines the ttrpc event service.

Code generated by protoc-gen-go-fieldpath. DO NOT EDIT. source: github.com/containerd/containerd/api/services/ttrpc/events/v1/events.proto

Code generated by protoc-gen-go-ttrpc. DO NOT EDIT. source: github.com/containerd/containerd/api/services/ttrpc/events/v1/events.proto

Index

• Variables
• func RegisterEventsService(srv *ttrpc.Server, svc EventsService)
• type Envelope
  • func (*Envelope) Descriptor() ([]byte, []int)
  • func (m *Envelope) Field(fieldpath []string) (string, bool)
  • func (x *Envelope) GetEvent() *anypb.Any
  • func (x *Envelope) GetNamespace() string
  • func (x *Envelope) GetTimestamp() *timestamppb.Timestamp
  • func (x *Envelope) GetTopic() string
  • func (*Envelope) ProtoMessage()
  • func (x *Envelope) ProtoReflect() protoreflect.Message
  • func (x *Envelope) Reset()
  • func (x *Envelope) String() string
• type EventsService
  • func NewEventsClient(client *ttrpc.Client) EventsService
• type ForwardRequest
  • func (*ForwardRequest) Descriptor() ([]byte, []int)
  • func (m *ForwardRequest) Field(fieldpath []string) (string, bool)
  • func (x *ForwardRequest) GetEnvelope() *Envelope
  • func (*ForwardRequest) ProtoMessage()
  • func (x *ForwardRequest) ProtoReflect() protoreflect.Message
  • func (x *ForwardRequest) Reset()
  • func (x *ForwardRequest) String() string

Variables

var File_github_com_containerd_containerd_api_services_ttrpc_events_v1_events_proto protoreflect.FileDescriptor

Functions

func RegisterEventsService

func RegisterEventsService(srv *ttrpc.Server, svc EventsService)

Types

type Envelope

type Envelope struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Namespace string                 `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Topic     string                 `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Event     *anypb.Any             `protobuf:"bytes,4,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*Envelope) Descriptor

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

Deprecated: Use Envelope.ProtoReflect.Descriptor instead.

func (*Envelope) Field

func (m *Envelope) Field(fieldpath []string) (string, bool)

Field returns the value for the given fieldpath as a string, if defined. If the value is not defined, the second value will be false.

func (*Envelope) GetEvent

func (x *Envelope) GetEvent() *anypb.Any

func (*Envelope) GetNamespace

func (x *Envelope) GetNamespace() string

func (*Envelope) GetTimestamp

func (x *Envelope) GetTimestamp() *timestamppb.Timestamp

func (*Envelope) GetTopic

func (x *Envelope) GetTopic() string

func (*Envelope) ProtoMessage

func (*Envelope) ProtoMessage()

func (*Envelope) ProtoReflect

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

func (*Envelope) Reset

func (x *Envelope) Reset()

func (*Envelope) String

func (x *Envelope) String() string

type EventsService

type EventsService interface {
	Forward(context.Context, *ForwardRequest) (*emptypb.Empty, error)
}

func NewEventsClient

func NewEventsClient(client *ttrpc.Client) EventsService

type ForwardRequest

type ForwardRequest struct {
	Envelope *Envelope `protobuf:"bytes,1,opt,name=envelope,proto3" json:"envelope,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardRequest) Descriptor

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

Deprecated: Use ForwardRequest.ProtoReflect.Descriptor instead.

func (*ForwardRequest) Field

func (m *ForwardRequest) Field(fieldpath []string) (string, bool)

Field returns the value for the given fieldpath as a string, if defined. If the value is not defined, the second value will be false.

func (*ForwardRequest) GetEnvelope

func (x *ForwardRequest) GetEnvelope() *Envelope

func (*ForwardRequest) ProtoMessage

func (*ForwardRequest) ProtoMessage()

func (*ForwardRequest) ProtoReflect

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

func (*ForwardRequest) Reset

func (x *ForwardRequest) Reset()

func (*ForwardRequest) String

func (x *ForwardRequest) String() string