events

package
v1.0.0-alpha6 Latest Latest
Warning

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

 Go to latest Published: Aug 23, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.