events

package
v1.0.0-alpha4 Latest Latest
Warning

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

Go to latest
Published: Aug 10, 2017 License: Apache-2.0, CC-BY-SA-4.0 Imports: 17 Imported by: 0

Documentation

Overview

Package events is a generated protocol buffer package.

It is generated from these files:

github.com/containerd/containerd/api/services/events/v1/container.proto
github.com/containerd/containerd/api/services/events/v1/content.proto
github.com/containerd/containerd/api/services/events/v1/events.proto
github.com/containerd/containerd/api/services/events/v1/image.proto
github.com/containerd/containerd/api/services/events/v1/namespace.proto
github.com/containerd/containerd/api/services/events/v1/snapshot.proto
github.com/containerd/containerd/api/services/events/v1/task.proto

It has these top-level messages:

ContainerCreate
ContainerUpdate
ContainerDelete
ContentDelete
PublishRequest
ForwardRequest
SubscribeRequest
Envelope
ImageCreate
ImageUpdate
ImageDelete
NamespaceCreate
NamespaceUpdate
NamespaceDelete
SnapshotPrepare
SnapshotCommit
SnapshotRemove
TaskCreate
TaskStart
TaskDelete
TaskIO
TaskExit
TaskOOM
TaskExecAdded
TaskExecStarted
TaskPaused
TaskResumed
TaskCheckpointed

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthContainer = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowContainer   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthContent = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowContent   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthEvents = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthImage = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowImage   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthNamespace = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNamespace   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthSnapshot = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSnapshot   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthTask = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTask   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterEventsServer

func RegisterEventsServer(s *grpc.Server, srv EventsServer)

Types

type ContainerCreate

type ContainerCreate struct {
	ID      string                   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Image   string                   `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Runtime *ContainerCreate_Runtime `protobuf:"bytes,3,opt,name=runtime" json:"runtime,omitempty"`
}

func (*ContainerCreate) Descriptor

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

func (*ContainerCreate) Field

func (m *ContainerCreate) 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 (*ContainerCreate) Marshal

func (m *ContainerCreate) Marshal() (dAtA []byte, err error)

func (*ContainerCreate) MarshalTo

func (m *ContainerCreate) MarshalTo(dAtA []byte) (int, error)

func (*ContainerCreate) ProtoMessage

func (*ContainerCreate) ProtoMessage()

func (*ContainerCreate) Reset

func (m *ContainerCreate) Reset()

func (*ContainerCreate) Size

func (m *ContainerCreate) Size() (n int)

func (*ContainerCreate) String

func (this *ContainerCreate) String() string

func (*ContainerCreate) Unmarshal

func (m *ContainerCreate) Unmarshal(dAtA []byte) error

type ContainerCreate_Runtime

type ContainerCreate_Runtime struct {
	Name    string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Options *google_protobuf1.Any `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"`
}

func (*ContainerCreate_Runtime) Descriptor

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

func (*ContainerCreate_Runtime) Field

func (m *ContainerCreate_Runtime) 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 (*ContainerCreate_Runtime) Marshal

func (m *ContainerCreate_Runtime) Marshal() (dAtA []byte, err error)

func (*ContainerCreate_Runtime) MarshalTo

func (m *ContainerCreate_Runtime) MarshalTo(dAtA []byte) (int, error)

func (*ContainerCreate_Runtime) ProtoMessage

func (*ContainerCreate_Runtime) ProtoMessage()

func (*ContainerCreate_Runtime) Reset

func (m *ContainerCreate_Runtime) Reset()

func (*ContainerCreate_Runtime) Size

func (m *ContainerCreate_Runtime) Size() (n int)

func (*ContainerCreate_Runtime) String

func (this *ContainerCreate_Runtime) String() string

func (*ContainerCreate_Runtime) Unmarshal

func (m *ContainerCreate_Runtime) Unmarshal(dAtA []byte) error

type ContainerDelete

type ContainerDelete struct {
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*ContainerDelete) Descriptor

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

func (*ContainerDelete) Field

func (m *ContainerDelete) 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 (*ContainerDelete) Marshal

func (m *ContainerDelete) Marshal() (dAtA []byte, err error)

func (*ContainerDelete) MarshalTo

func (m *ContainerDelete) MarshalTo(dAtA []byte) (int, error)

func (*ContainerDelete) ProtoMessage

func (*ContainerDelete) ProtoMessage()

func (*ContainerDelete) Reset

func (m *ContainerDelete) Reset()

func (*ContainerDelete) Size

func (m *ContainerDelete) Size() (n int)

func (*ContainerDelete) String

func (this *ContainerDelete) String() string

func (*ContainerDelete) Unmarshal

func (m *ContainerDelete) Unmarshal(dAtA []byte) error

type ContainerUpdate

type ContainerUpdate struct {
	ID     string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Image  string            `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Labels map[string]string `` /* 146-byte string literal not displayed */
	RootFS string            `protobuf:"bytes,4,opt,name=rootfs,proto3" json:"rootfs,omitempty"`
}

func (*ContainerUpdate) Descriptor

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

func (*ContainerUpdate) Field

func (m *ContainerUpdate) 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 (*ContainerUpdate) Marshal

func (m *ContainerUpdate) Marshal() (dAtA []byte, err error)

func (*ContainerUpdate) MarshalTo

func (m *ContainerUpdate) MarshalTo(dAtA []byte) (int, error)

func (*ContainerUpdate) ProtoMessage

func (*ContainerUpdate) ProtoMessage()

func (*ContainerUpdate) Reset

func (m *ContainerUpdate) Reset()

func (*ContainerUpdate) Size

func (m *ContainerUpdate) Size() (n int)

func (*ContainerUpdate) String

func (this *ContainerUpdate) String() string

func (*ContainerUpdate) Unmarshal

func (m *ContainerUpdate) Unmarshal(dAtA []byte) error

type ContentDelete

type ContentDelete struct {
	Digest github_com_opencontainers_go_digest.Digest `protobuf:"bytes,1,opt,name=digest,proto3,customtype=github.com/opencontainers/go-digest.Digest" json:"digest"`
}

func (*ContentDelete) Descriptor

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

func (*ContentDelete) Field

func (m *ContentDelete) 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 (*ContentDelete) Marshal

func (m *ContentDelete) Marshal() (dAtA []byte, err error)

func (*ContentDelete) MarshalTo

func (m *ContentDelete) MarshalTo(dAtA []byte) (int, error)

func (*ContentDelete) ProtoMessage

func (*ContentDelete) ProtoMessage()

func (*ContentDelete) Reset

func (m *ContentDelete) Reset()

func (*ContentDelete) Size

func (m *ContentDelete) Size() (n int)

func (*ContentDelete) String

func (this *ContentDelete) String() string

func (*ContentDelete) Unmarshal

func (m *ContentDelete) Unmarshal(dAtA []byte) error

type Envelope

type Envelope struct {
	Timestamp time.Time             `protobuf:"bytes,1,opt,name=timestamp,stdtime" json:"timestamp"`
	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     *google_protobuf1.Any `protobuf:"bytes,4,opt,name=event" json:"event,omitempty"`
}

func (*Envelope) Descriptor

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

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) Marshal

func (m *Envelope) Marshal() (dAtA []byte, err error)

func (*Envelope) MarshalTo

func (m *Envelope) MarshalTo(dAtA []byte) (int, error)

func (*Envelope) ProtoMessage

func (*Envelope) ProtoMessage()

func (*Envelope) Reset

func (m *Envelope) Reset()

func (*Envelope) Size

func (m *Envelope) Size() (n int)

func (*Envelope) String

func (this *Envelope) String() string

func (*Envelope) Unmarshal

func (m *Envelope) Unmarshal(dAtA []byte) error

type EventsClient

type EventsClient interface {
	// Publish an event to a topic.
	//
	// The event will be packed into a timestamp envelope with the namespace
	// introspected from the context. The envelope will then be dispatched.
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*google_protobuf2.Empty, error)
	// Forward sends an event that has already been packaged into an envelope
	// with a timestamp and namespace.
	//
	// This is useful if earlier timestamping is required or when fowarding on
	// behalf of another component, namespace or publisher.
	Forward(ctx context.Context, in *ForwardRequest, opts ...grpc.CallOption) (*google_protobuf2.Empty, error)
	// Subscribe to a stream of events, possibly returning only that match any
	// of the provided filters.
	//
	// Unlike many other methods in containerd, subscribers will get messages
	// from all namespaces unless otherwise specified. If this is not desired,
	// a filter can be provided in the format 'namespace==<namespace>' to
	// restrict the received events.
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Events_SubscribeClient, error)
}

func NewEventsClient

func NewEventsClient(cc *grpc.ClientConn) EventsClient

type EventsServer

type EventsServer interface {
	// Publish an event to a topic.
	//
	// The event will be packed into a timestamp envelope with the namespace
	// introspected from the context. The envelope will then be dispatched.
	Publish(context.Context, *PublishRequest) (*google_protobuf2.Empty, error)
	// Forward sends an event that has already been packaged into an envelope
	// with a timestamp and namespace.
	//
	// This is useful if earlier timestamping is required or when fowarding on
	// behalf of another component, namespace or publisher.
	Forward(context.Context, *ForwardRequest) (*google_protobuf2.Empty, error)
	// Subscribe to a stream of events, possibly returning only that match any
	// of the provided filters.
	//
	// Unlike many other methods in containerd, subscribers will get messages
	// from all namespaces unless otherwise specified. If this is not desired,
	// a filter can be provided in the format 'namespace==<namespace>' to
	// restrict the received events.
	Subscribe(*SubscribeRequest, Events_SubscribeServer) error
}

type Events_SubscribeClient

type Events_SubscribeClient interface {
	Recv() (*Envelope, error)
	grpc.ClientStream
}

type Events_SubscribeServer

type Events_SubscribeServer interface {
	Send(*Envelope) error
	grpc.ServerStream
}

type ForwardRequest

type ForwardRequest struct {
	Envelope *Envelope `protobuf:"bytes,1,opt,name=envelope" json:"envelope,omitempty"`
}

func (*ForwardRequest) Descriptor

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

func (*ForwardRequest) Marshal

func (m *ForwardRequest) Marshal() (dAtA []byte, err error)

func (*ForwardRequest) MarshalTo

func (m *ForwardRequest) MarshalTo(dAtA []byte) (int, error)

func (*ForwardRequest) ProtoMessage

func (*ForwardRequest) ProtoMessage()

func (*ForwardRequest) Reset

func (m *ForwardRequest) Reset()

func (*ForwardRequest) Size

func (m *ForwardRequest) Size() (n int)

func (*ForwardRequest) String

func (this *ForwardRequest) String() string

func (*ForwardRequest) Unmarshal

func (m *ForwardRequest) Unmarshal(dAtA []byte) error

type ImageCreate

type ImageCreate struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 146-byte string literal not displayed */
}

func (*ImageCreate) Descriptor

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

func (*ImageCreate) Field

func (m *ImageCreate) 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 (*ImageCreate) Marshal

func (m *ImageCreate) Marshal() (dAtA []byte, err error)

func (*ImageCreate) MarshalTo

func (m *ImageCreate) MarshalTo(dAtA []byte) (int, error)

func (*ImageCreate) ProtoMessage

func (*ImageCreate) ProtoMessage()

func (*ImageCreate) Reset

func (m *ImageCreate) Reset()

func (*ImageCreate) Size

func (m *ImageCreate) Size() (n int)

func (*ImageCreate) String

func (this *ImageCreate) String() string

func (*ImageCreate) Unmarshal

func (m *ImageCreate) Unmarshal(dAtA []byte) error

type ImageDelete

type ImageDelete struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*ImageDelete) Descriptor

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

func (*ImageDelete) Field

func (m *ImageDelete) 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 (*ImageDelete) Marshal

func (m *ImageDelete) Marshal() (dAtA []byte, err error)

func (*ImageDelete) MarshalTo

func (m *ImageDelete) MarshalTo(dAtA []byte) (int, error)

func (*ImageDelete) ProtoMessage

func (*ImageDelete) ProtoMessage()

func (*ImageDelete) Reset

func (m *ImageDelete) Reset()

func (*ImageDelete) Size

func (m *ImageDelete) Size() (n int)

func (*ImageDelete) String

func (this *ImageDelete) String() string

func (*ImageDelete) Unmarshal

func (m *ImageDelete) Unmarshal(dAtA []byte) error

type ImageUpdate

type ImageUpdate struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 146-byte string literal not displayed */
}

func (*ImageUpdate) Descriptor

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

func (*ImageUpdate) Field

func (m *ImageUpdate) 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 (*ImageUpdate) Marshal

func (m *ImageUpdate) Marshal() (dAtA []byte, err error)

func (*ImageUpdate) MarshalTo

func (m *ImageUpdate) MarshalTo(dAtA []byte) (int, error)

func (*ImageUpdate) ProtoMessage

func (*ImageUpdate) ProtoMessage()

func (*ImageUpdate) Reset

func (m *ImageUpdate) Reset()

func (*ImageUpdate) Size

func (m *ImageUpdate) Size() (n int)

func (*ImageUpdate) String

func (this *ImageUpdate) String() string

func (*ImageUpdate) Unmarshal

func (m *ImageUpdate) Unmarshal(dAtA []byte) error

type NamespaceCreate

type NamespaceCreate struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 146-byte string literal not displayed */
}

func (*NamespaceCreate) Descriptor

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

func (*NamespaceCreate) Field

func (m *NamespaceCreate) 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 (*NamespaceCreate) Marshal

func (m *NamespaceCreate) Marshal() (dAtA []byte, err error)

func (*NamespaceCreate) MarshalTo

func (m *NamespaceCreate) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceCreate) ProtoMessage

func (*NamespaceCreate) ProtoMessage()

func (*NamespaceCreate) Reset

func (m *NamespaceCreate) Reset()

func (*NamespaceCreate) Size

func (m *NamespaceCreate) Size() (n int)

func (*NamespaceCreate) String

func (this *NamespaceCreate) String() string

func (*NamespaceCreate) Unmarshal

func (m *NamespaceCreate) Unmarshal(dAtA []byte) error

type NamespaceDelete

type NamespaceDelete struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*NamespaceDelete) Descriptor

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

func (*NamespaceDelete) Field

func (m *NamespaceDelete) 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 (*NamespaceDelete) Marshal

func (m *NamespaceDelete) Marshal() (dAtA []byte, err error)

func (*NamespaceDelete) MarshalTo

func (m *NamespaceDelete) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceDelete) ProtoMessage

func (*NamespaceDelete) ProtoMessage()

func (*NamespaceDelete) Reset

func (m *NamespaceDelete) Reset()

func (*NamespaceDelete) Size

func (m *NamespaceDelete) Size() (n int)

func (*NamespaceDelete) String

func (this *NamespaceDelete) String() string

func (*NamespaceDelete) Unmarshal

func (m *NamespaceDelete) Unmarshal(dAtA []byte) error

type NamespaceUpdate

type NamespaceUpdate struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 146-byte string literal not displayed */
}

func (*NamespaceUpdate) Descriptor

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

func (*NamespaceUpdate) Field

func (m *NamespaceUpdate) 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 (*NamespaceUpdate) Marshal

func (m *NamespaceUpdate) Marshal() (dAtA []byte, err error)

func (*NamespaceUpdate) MarshalTo

func (m *NamespaceUpdate) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceUpdate) ProtoMessage

func (*NamespaceUpdate) ProtoMessage()

func (*NamespaceUpdate) Reset

func (m *NamespaceUpdate) Reset()

func (*NamespaceUpdate) Size

func (m *NamespaceUpdate) Size() (n int)

func (*NamespaceUpdate) String

func (this *NamespaceUpdate) String() string

func (*NamespaceUpdate) Unmarshal

func (m *NamespaceUpdate) Unmarshal(dAtA []byte) error

type PublishRequest

type PublishRequest struct {
	Topic string                `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Event *google_protobuf1.Any `protobuf:"bytes,2,opt,name=event" json:"event,omitempty"`
}

func (*PublishRequest) Descriptor

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

func (*PublishRequest) Marshal

func (m *PublishRequest) Marshal() (dAtA []byte, err error)

func (*PublishRequest) MarshalTo

func (m *PublishRequest) MarshalTo(dAtA []byte) (int, error)

func (*PublishRequest) ProtoMessage

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset

func (m *PublishRequest) Reset()

func (*PublishRequest) Size

func (m *PublishRequest) Size() (n int)

func (*PublishRequest) String

func (this *PublishRequest) String() string

func (*PublishRequest) Unmarshal

func (m *PublishRequest) Unmarshal(dAtA []byte) error

type SnapshotCommit

type SnapshotCommit struct {
	Key  string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

func (*SnapshotCommit) Descriptor

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

func (*SnapshotCommit) Field

func (m *SnapshotCommit) 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 (*SnapshotCommit) Marshal

func (m *SnapshotCommit) Marshal() (dAtA []byte, err error)

func (*SnapshotCommit) MarshalTo

func (m *SnapshotCommit) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotCommit) ProtoMessage

func (*SnapshotCommit) ProtoMessage()

func (*SnapshotCommit) Reset

func (m *SnapshotCommit) Reset()

func (*SnapshotCommit) Size

func (m *SnapshotCommit) Size() (n int)

func (*SnapshotCommit) String

func (this *SnapshotCommit) String() string

func (*SnapshotCommit) Unmarshal

func (m *SnapshotCommit) Unmarshal(dAtA []byte) error

type SnapshotPrepare

type SnapshotPrepare struct {
	Key    string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Parent string `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
}

func (*SnapshotPrepare) Descriptor

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

func (*SnapshotPrepare) Field

func (m *SnapshotPrepare) 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 (*SnapshotPrepare) Marshal

func (m *SnapshotPrepare) Marshal() (dAtA []byte, err error)

func (*SnapshotPrepare) MarshalTo

func (m *SnapshotPrepare) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotPrepare) ProtoMessage

func (*SnapshotPrepare) ProtoMessage()

func (*SnapshotPrepare) Reset

func (m *SnapshotPrepare) Reset()

func (*SnapshotPrepare) Size

func (m *SnapshotPrepare) Size() (n int)

func (*SnapshotPrepare) String

func (this *SnapshotPrepare) String() string

func (*SnapshotPrepare) Unmarshal

func (m *SnapshotPrepare) Unmarshal(dAtA []byte) error

type SnapshotRemove

type SnapshotRemove struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

func (*SnapshotRemove) Descriptor

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

func (*SnapshotRemove) Field

func (m *SnapshotRemove) 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 (*SnapshotRemove) Marshal

func (m *SnapshotRemove) Marshal() (dAtA []byte, err error)

func (*SnapshotRemove) MarshalTo

func (m *SnapshotRemove) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotRemove) ProtoMessage

func (*SnapshotRemove) ProtoMessage()

func (*SnapshotRemove) Reset

func (m *SnapshotRemove) Reset()

func (*SnapshotRemove) Size

func (m *SnapshotRemove) Size() (n int)

func (*SnapshotRemove) String

func (this *SnapshotRemove) String() string

func (*SnapshotRemove) Unmarshal

func (m *SnapshotRemove) Unmarshal(dAtA []byte) error

type SubscribeRequest

type SubscribeRequest struct {
	Filters []string `protobuf:"bytes,1,rep,name=filters" json:"filters,omitempty"`
}

func (*SubscribeRequest) Descriptor

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

func (*SubscribeRequest) Marshal

func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)

func (*SubscribeRequest) MarshalTo

func (m *SubscribeRequest) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeRequest) ProtoMessage

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) Size

func (m *SubscribeRequest) Size() (n int)

func (*SubscribeRequest) String

func (this *SubscribeRequest) String() string

func (*SubscribeRequest) Unmarshal

func (m *SubscribeRequest) Unmarshal(dAtA []byte) error

type TaskCheckpointed

type TaskCheckpointed struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Checkpoint  string `protobuf:"bytes,2,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
}

func (*TaskCheckpointed) Descriptor

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

func (*TaskCheckpointed) Field

func (m *TaskCheckpointed) 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 (*TaskCheckpointed) Marshal

func (m *TaskCheckpointed) Marshal() (dAtA []byte, err error)

func (*TaskCheckpointed) MarshalTo

func (m *TaskCheckpointed) MarshalTo(dAtA []byte) (int, error)

func (*TaskCheckpointed) ProtoMessage

func (*TaskCheckpointed) ProtoMessage()

func (*TaskCheckpointed) Reset

func (m *TaskCheckpointed) Reset()

func (*TaskCheckpointed) Size

func (m *TaskCheckpointed) Size() (n int)

func (*TaskCheckpointed) String

func (this *TaskCheckpointed) String() string

func (*TaskCheckpointed) Unmarshal

func (m *TaskCheckpointed) Unmarshal(dAtA []byte) error

type TaskCreate

type TaskCreate struct {
	ContainerID string                    `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Bundle      string                    `protobuf:"bytes,2,opt,name=bundle,proto3" json:"bundle,omitempty"`
	Rootfs      []*containerd_types.Mount `protobuf:"bytes,3,rep,name=rootfs" json:"rootfs,omitempty"`
	IO          *TaskIO                   `protobuf:"bytes,4,opt,name=io" json:"io,omitempty"`
	Checkpoint  string                    `protobuf:"bytes,5,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	Pid         uint32                    `protobuf:"varint,6,opt,name=pid,proto3" json:"pid,omitempty"`
}

func (*TaskCreate) Descriptor

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

func (*TaskCreate) Field

func (m *TaskCreate) 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 (*TaskCreate) Marshal

func (m *TaskCreate) Marshal() (dAtA []byte, err error)

func (*TaskCreate) MarshalTo

func (m *TaskCreate) MarshalTo(dAtA []byte) (int, error)

func (*TaskCreate) ProtoMessage

func (*TaskCreate) ProtoMessage()

func (*TaskCreate) Reset

func (m *TaskCreate) Reset()

func (*TaskCreate) Size

func (m *TaskCreate) Size() (n int)

func (*TaskCreate) String

func (this *TaskCreate) String() string

func (*TaskCreate) Unmarshal

func (m *TaskCreate) Unmarshal(dAtA []byte) error

type TaskDelete

type TaskDelete struct {
	ContainerID string    `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Pid         uint32    `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	ExitStatus  uint32    `protobuf:"varint,3,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ExitedAt    time.Time `protobuf:"bytes,4,opt,name=exited_at,json=exitedAt,stdtime" json:"exited_at"`
}

func (*TaskDelete) Descriptor

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

func (*TaskDelete) Field

func (m *TaskDelete) 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 (*TaskDelete) Marshal

func (m *TaskDelete) Marshal() (dAtA []byte, err error)

func (*TaskDelete) MarshalTo

func (m *TaskDelete) MarshalTo(dAtA []byte) (int, error)

func (*TaskDelete) ProtoMessage

func (*TaskDelete) ProtoMessage()

func (*TaskDelete) Reset

func (m *TaskDelete) Reset()

func (*TaskDelete) Size

func (m *TaskDelete) Size() (n int)

func (*TaskDelete) String

func (this *TaskDelete) String() string

func (*TaskDelete) Unmarshal

func (m *TaskDelete) Unmarshal(dAtA []byte) error

type TaskExecAdded

type TaskExecAdded struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ExecID      string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
}

func (*TaskExecAdded) Descriptor

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

func (*TaskExecAdded) Field

func (m *TaskExecAdded) 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 (*TaskExecAdded) Marshal

func (m *TaskExecAdded) Marshal() (dAtA []byte, err error)

func (*TaskExecAdded) MarshalTo

func (m *TaskExecAdded) MarshalTo(dAtA []byte) (int, error)

func (*TaskExecAdded) ProtoMessage

func (*TaskExecAdded) ProtoMessage()

func (*TaskExecAdded) Reset

func (m *TaskExecAdded) Reset()

func (*TaskExecAdded) Size

func (m *TaskExecAdded) Size() (n int)

func (*TaskExecAdded) String

func (this *TaskExecAdded) String() string

func (*TaskExecAdded) Unmarshal

func (m *TaskExecAdded) Unmarshal(dAtA []byte) error

type TaskExecStarted

type TaskExecStarted struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ExecID      string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Pid         uint32 `protobuf:"varint,3,opt,name=pid,proto3" json:"pid,omitempty"`
}

func (*TaskExecStarted) Descriptor

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

func (*TaskExecStarted) Field

func (m *TaskExecStarted) 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 (*TaskExecStarted) Marshal

func (m *TaskExecStarted) Marshal() (dAtA []byte, err error)

func (*TaskExecStarted) MarshalTo

func (m *TaskExecStarted) MarshalTo(dAtA []byte) (int, error)

func (*TaskExecStarted) ProtoMessage

func (*TaskExecStarted) ProtoMessage()

func (*TaskExecStarted) Reset

func (m *TaskExecStarted) Reset()

func (*TaskExecStarted) Size

func (m *TaskExecStarted) Size() (n int)

func (*TaskExecStarted) String

func (this *TaskExecStarted) String() string

func (*TaskExecStarted) Unmarshal

func (m *TaskExecStarted) Unmarshal(dAtA []byte) error

type TaskExit

type TaskExit struct {
	ContainerID string    `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ID          string    `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Pid         uint32    `protobuf:"varint,3,opt,name=pid,proto3" json:"pid,omitempty"`
	ExitStatus  uint32    `protobuf:"varint,4,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ExitedAt    time.Time `protobuf:"bytes,5,opt,name=exited_at,json=exitedAt,stdtime" json:"exited_at"`
}

func (*TaskExit) Descriptor

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

func (*TaskExit) Field

func (m *TaskExit) 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 (*TaskExit) Marshal

func (m *TaskExit) Marshal() (dAtA []byte, err error)

func (*TaskExit) MarshalTo

func (m *TaskExit) MarshalTo(dAtA []byte) (int, error)

func (*TaskExit) ProtoMessage

func (*TaskExit) ProtoMessage()

func (*TaskExit) Reset

func (m *TaskExit) Reset()

func (*TaskExit) Size

func (m *TaskExit) Size() (n int)

func (*TaskExit) String

func (this *TaskExit) String() string

func (*TaskExit) Unmarshal

func (m *TaskExit) Unmarshal(dAtA []byte) error

type TaskIO

type TaskIO struct {
	Stdin    string `protobuf:"bytes,1,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Stdout   string `protobuf:"bytes,2,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr   string `protobuf:"bytes,3,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Terminal bool   `protobuf:"varint,4,opt,name=terminal,proto3" json:"terminal,omitempty"`
}

func (*TaskIO) Descriptor

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

func (*TaskIO) Field

func (m *TaskIO) 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 (*TaskIO) Marshal

func (m *TaskIO) Marshal() (dAtA []byte, err error)

func (*TaskIO) MarshalTo

func (m *TaskIO) MarshalTo(dAtA []byte) (int, error)

func (*TaskIO) ProtoMessage

func (*TaskIO) ProtoMessage()

func (*TaskIO) Reset

func (m *TaskIO) Reset()

func (*TaskIO) Size

func (m *TaskIO) Size() (n int)

func (*TaskIO) String

func (this *TaskIO) String() string

func (*TaskIO) Unmarshal

func (m *TaskIO) Unmarshal(dAtA []byte) error

type TaskOOM

type TaskOOM struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
}

func (*TaskOOM) Descriptor

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

func (*TaskOOM) Field

func (m *TaskOOM) 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 (*TaskOOM) Marshal

func (m *TaskOOM) Marshal() (dAtA []byte, err error)

func (*TaskOOM) MarshalTo

func (m *TaskOOM) MarshalTo(dAtA []byte) (int, error)

func (*TaskOOM) ProtoMessage

func (*TaskOOM) ProtoMessage()

func (*TaskOOM) Reset

func (m *TaskOOM) Reset()

func (*TaskOOM) Size

func (m *TaskOOM) Size() (n int)

func (*TaskOOM) String

func (this *TaskOOM) String() string

func (*TaskOOM) Unmarshal

func (m *TaskOOM) Unmarshal(dAtA []byte) error

type TaskPaused

type TaskPaused struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
}

func (*TaskPaused) Descriptor

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

func (*TaskPaused) Field

func (m *TaskPaused) 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 (*TaskPaused) Marshal

func (m *TaskPaused) Marshal() (dAtA []byte, err error)

func (*TaskPaused) MarshalTo

func (m *TaskPaused) MarshalTo(dAtA []byte) (int, error)

func (*TaskPaused) ProtoMessage

func (*TaskPaused) ProtoMessage()

func (*TaskPaused) Reset

func (m *TaskPaused) Reset()

func (*TaskPaused) Size

func (m *TaskPaused) Size() (n int)

func (*TaskPaused) String

func (this *TaskPaused) String() string

func (*TaskPaused) Unmarshal

func (m *TaskPaused) Unmarshal(dAtA []byte) error

type TaskResumed

type TaskResumed struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
}

func (*TaskResumed) Descriptor

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

func (*TaskResumed) Field

func (m *TaskResumed) 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 (*TaskResumed) Marshal

func (m *TaskResumed) Marshal() (dAtA []byte, err error)

func (*TaskResumed) MarshalTo

func (m *TaskResumed) MarshalTo(dAtA []byte) (int, error)

func (*TaskResumed) ProtoMessage

func (*TaskResumed) ProtoMessage()

func (*TaskResumed) Reset

func (m *TaskResumed) Reset()

func (*TaskResumed) Size

func (m *TaskResumed) Size() (n int)

func (*TaskResumed) String

func (this *TaskResumed) String() string

func (*TaskResumed) Unmarshal

func (m *TaskResumed) Unmarshal(dAtA []byte) error

type TaskStart

type TaskStart struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Pid         uint32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
}

func (*TaskStart) Descriptor

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

func (*TaskStart) Field

func (m *TaskStart) 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 (*TaskStart) Marshal

func (m *TaskStart) Marshal() (dAtA []byte, err error)

func (*TaskStart) MarshalTo

func (m *TaskStart) MarshalTo(dAtA []byte) (int, error)

func (*TaskStart) ProtoMessage

func (*TaskStart) ProtoMessage()

func (*TaskStart) Reset

func (m *TaskStart) Reset()

func (*TaskStart) Size

func (m *TaskStart) Size() (n int)

func (*TaskStart) String

func (this *TaskStart) String() string

func (*TaskStart) Unmarshal

func (m *TaskStart) Unmarshal(dAtA []byte) error

Jump to

Keyboard shortcuts

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