Versions in this module Expand all Collapse all v1 v1.6.1 Oct 23, 2022 Changes in this version + var Events_ServiceDesc = grpc.ServiceDesc + var File_github_com_containerd_containerd_api_services_events_v1_events_proto protoreflect.FileDescriptor + func RegisterEventsServer(s grpc.ServiceRegistrar, srv EventsServer) + type Envelope struct + Event *anypb.Any + Namespace string + Timestamp *timestamppb.Timestamp + Topic string + func (*Envelope) Descriptor() ([]byte, []int) + func (*Envelope) ProtoMessage() + func (x *Envelope) GetEvent() *anypb.Any + func (x *Envelope) GetNamespace() string + func (x *Envelope) GetTimestamp() *timestamppb.Timestamp + func (x *Envelope) GetTopic() string + func (x *Envelope) ProtoReflect() protoreflect.Message + func (x *Envelope) Reset() + func (x *Envelope) String() string + type EventsClient interface + Forward func(ctx context.Context, in *ForwardRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Events_SubscribeClient, error) + func NewEventsClient(cc grpc.ClientConnInterface) EventsClient + type EventsServer interface + Forward func(context.Context, *ForwardRequest) (*emptypb.Empty, error) + Publish func(context.Context, *PublishRequest) (*emptypb.Empty, error) + Subscribe func(*SubscribeRequest, Events_SubscribeServer) error + type Events_SubscribeClient interface + Recv func() (*Envelope, error) + type Events_SubscribeServer interface + Send func(*Envelope) error + type ForwardRequest struct + Envelope *Envelope + func (*ForwardRequest) Descriptor() ([]byte, []int) + func (*ForwardRequest) ProtoMessage() + func (x *ForwardRequest) GetEnvelope() *Envelope + func (x *ForwardRequest) ProtoReflect() protoreflect.Message + func (x *ForwardRequest) Reset() + func (x *ForwardRequest) String() string + type PublishRequest struct + Event *anypb.Any + Topic string + func (*PublishRequest) Descriptor() ([]byte, []int) + func (*PublishRequest) ProtoMessage() + func (x *PublishRequest) GetEvent() *anypb.Any + func (x *PublishRequest) GetTopic() string + func (x *PublishRequest) ProtoReflect() protoreflect.Message + func (x *PublishRequest) Reset() + func (x *PublishRequest) String() string + type SubscribeRequest struct + Filters []string + func (*SubscribeRequest) Descriptor() ([]byte, []int) + func (*SubscribeRequest) ProtoMessage() + func (x *SubscribeRequest) GetFilters() []string + func (x *SubscribeRequest) ProtoReflect() protoreflect.Message + func (x *SubscribeRequest) Reset() + func (x *SubscribeRequest) String() string + type UnimplementedEventsServer struct + func (UnimplementedEventsServer) Forward(context.Context, *ForwardRequest) (*emptypb.Empty, error) + func (UnimplementedEventsServer) Publish(context.Context, *PublishRequest) (*emptypb.Empty, error) + func (UnimplementedEventsServer) Subscribe(*SubscribeRequest, Events_SubscribeServer) error + type UnsafeEventsServer interface Other modules containing this package github.com/goodbaikin/containerd
Go to main page