events

package
v1.0.0-alpha1 Latest Latest
Warning

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

 Go to latest Published: Jul 19, 2017 License: Apache-2.0, CC-BY-SA-4.0 Imports: 15 Imported by: 352

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
StreamEventsRequest
PostEventRequest
Envelope
ImageCreate
ImageUpdate
ImageDelete
NamespaceCreate
NamespaceUpdate
NamespaceDelete
SnapshotPrepare
SnapshotCommit
SnapshotRemove
TaskCreate
TaskStart
TaskDelete
TaskIO
TaskExit
TaskOOM
TaskExecAdded
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) 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) 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) 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) 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) 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"`
	Topic     string                `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Event     *google_protobuf1.Any `protobuf:"bytes,3,opt,name=event" json:"event,omitempty"`
}

func (*Envelope) Descriptor 

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

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 {
	Stream(ctx context.Context, in *StreamEventsRequest, opts ...grpc.CallOption) (Events_StreamClient, error)
	Post(ctx context.Context, in *PostEventRequest, opts ...grpc.CallOption) (*google_protobuf2.Empty, error)
}

func NewEventsClient 

func NewEventsClient(cc *grpc.ClientConn) EventsClient

type EventsServer 

type EventsServer interface {
	Stream(*StreamEventsRequest, Events_StreamServer) error
	Post(context.Context, *PostEventRequest) (*google_protobuf2.Empty, error)
}

type Events_StreamClient 

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

type Events_StreamServer 

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

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

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

func (*PostEventRequest) Descriptor 

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

func (*PostEventRequest) Marshal 

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

func (*PostEventRequest) MarshalTo 

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

func (*PostEventRequest) ProtoMessage 

func (*PostEventRequest) ProtoMessage()

func (*PostEventRequest) Reset 

func (m *PostEventRequest) Reset()

func (*PostEventRequest) Size 

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

func (*PostEventRequest) String 

func (this *PostEventRequest) String() string

func (*PostEventRequest) Unmarshal 

func (m *PostEventRequest) 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) 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) 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) 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 StreamEventsRequest 

type StreamEventsRequest struct {
}

func (*StreamEventsRequest) Descriptor 

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

func (*StreamEventsRequest) Marshal 

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

func (*StreamEventsRequest) MarshalTo 

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

func (*StreamEventsRequest) ProtoMessage 

func (*StreamEventsRequest) ProtoMessage()

func (*StreamEventsRequest) Reset 

func (m *StreamEventsRequest) Reset()

func (*StreamEventsRequest) Size 

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

func (*StreamEventsRequest) String 

func (this *StreamEventsRequest) String() string

func (*StreamEventsRequest) Unmarshal 

func (m *StreamEventsRequest) 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) 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) 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) 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"`
	Pid         uint32 `protobuf:"varint,3,opt,name=pid,proto3" json:"pid,omitempty"`
}

func (*TaskExecAdded) Descriptor 

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

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