package events

import "github.com/containerd/containerd/api/services/ttrpc/events/v1"

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

Source Files ¶

doc.go events.pb.go events_fieldpath.pb.go events_ttrpc.pb.go