plugin

Documentation

Index

• Constants
• Variables
• type Meta
  • func NewPopulatedMeta(r randyPlugin, easy bool) *Meta
  • func (this *Meta) Compare(that interface{}) int
  • func (*Meta) Descriptor() ([]byte, []int)
  • func (this *Meta) Equal(that interface{}) bool
  • func (m *Meta) GetVersion() string
  • func (this *Meta) GoString() string
  • func (m *Meta) Marshal() (dAtA []byte, err error)
  • func (m *Meta) MarshalTo(dAtA []byte) (int, error)
  • func (m *Meta) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Meta) ProtoMessage()
  • func (m *Meta) Reset()
  • func (m *Meta) Size() (n int)
  • func (this *Meta) String() string
  • func (m *Meta) Unmarshal(dAtA []byte) error
  • func (m *Meta) XXX_DiscardUnknown()
  • func (m *Meta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Meta) XXX_Merge(src proto.Message)
  • func (*Meta) XXX_MessageName() string
  • func (m *Meta) XXX_Size() int
  • func (m *Meta) XXX_Unmarshal(b []byte) error
• type MockTask
  • func (m *MockTask) Apply(ctx context.Context) (*ResultChange, error)
  • func (m *MockTask) Evaluate(ctx context.Context) (*ResultChange, error)
• type ResultChange
• type Task
• type TaskFunc
• type TaskItem
  • func (ti *TaskItem) String() string
• type TaskMeta
  • func NewPopulatedTaskMeta(r randyPlugin, easy bool) *TaskMeta
  • func (this *TaskMeta) Compare(that interface{}) int
  • func (*TaskMeta) Descriptor() ([]byte, []int)
  • func (this *TaskMeta) Equal(that interface{}) bool
  • func (m *TaskMeta) GetDependencies() []string
  • func (m *TaskMeta) GetEnforce() bool
  • func (m *TaskMeta) GetName() string
  • func (m *TaskMeta) GetPluginMeta() *Meta
  • func (m *TaskMeta) GetURL() string
  • func (m *TaskMeta) GetVersion() string
  • func (this *TaskMeta) GoString() string
  • func (m *TaskMeta) Marshal() (dAtA []byte, err error)
  • func (m *TaskMeta) MarshalTo(dAtA []byte) (int, error)
  • func (m *TaskMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*TaskMeta) ProtoMessage()
  • func (m *TaskMeta) Reset()
  • func (m *TaskMeta) Size() (n int)
  • func (this *TaskMeta) String() string
  • func (m *TaskMeta) Unmarshal(dAtA []byte) error
  • func (m *TaskMeta) XXX_DiscardUnknown()
  • func (m *TaskMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *TaskMeta) XXX_Merge(src proto.Message)
  • func (*TaskMeta) XXX_MessageName() string
  • func (m *TaskMeta) XXX_Size() int
  • func (m *TaskMeta) XXX_Unmarshal(b []byte) error

Constants

const (
	TaskPackageIsVersion1 = true
)

Variables

var (
	ErrInvalidLengthPlugin        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPlugin          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPlugin = fmt.Errorf("proto: unexpected end of group")
)

Types

type Meta

type Meta struct {
	Version              string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedMeta

func NewPopulatedMeta(r randyPlugin, easy bool) *Meta

func (*Meta) Compare

func (this *Meta) Compare(that interface{}) int

func (*Meta) Descriptor

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

func (*Meta) Equal

func (this *Meta) Equal(that interface{}) bool

func (*Meta) GetVersion

func (m *Meta) GetVersion() string

func (*Meta) GoString

func (this *Meta) GoString() string

func (*Meta) Marshal

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

func (*Meta) MarshalTo

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

func (*Meta) MarshalToSizedBuffer

func (m *Meta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Meta) ProtoMessage

func (*Meta) ProtoMessage()

func (*Meta) Reset

func (m *Meta) Reset()

func (*Meta) Size

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

func (*Meta) String

func (this *Meta) String() string

func (*Meta) Unmarshal

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

func (*Meta) XXX_DiscardUnknown

func (m *Meta) XXX_DiscardUnknown()

func (*Meta) XXX_Marshal

func (m *Meta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Meta) XXX_Merge

func (m *Meta) XXX_Merge(src proto.Message)

func (*Meta) XXX_MessageName

func (*Meta) XXX_MessageName() string

func (*Meta) XXX_Size

func (m *Meta) XXX_Size() int

func (*Meta) XXX_Unmarshal

func (m *Meta) XXX_Unmarshal(b []byte) error

type MockTask

type MockTask struct {
	Meta *TaskMeta `json:"meta,omitempty"`
}

func (*MockTask) Apply

func (m *MockTask) Apply(ctx context.Context) (*ResultChange, error)

func (*MockTask) Evaluate

func (m *MockTask) Evaluate(ctx context.Context) (*ResultChange, error)

type ResultChange

type ResultChange struct{}

type Task

type Task interface {
	Evaluate(ctx context.Context) (*ResultChange, error)
	Apply(ctx context.Context) (*ResultChange, error)
}

type TaskFunc

type TaskFunc func(TaskMeta) Task

type TaskItem

type TaskItem struct {
	Id   string
	Task Task
	Meta *TaskMeta
}

func (*TaskItem) String

func (ti *TaskItem) String() string

type TaskMeta

type TaskMeta struct {
	URL                  string   `protobuf:"bytes,1,opt,name=URL,json=uRL,proto3" json:"URL,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version              string   `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	PluginMeta           *Meta    `protobuf:"bytes,6,opt,name=pluginMeta,proto3" json:"pluginMeta,omitempty"`
	Enforce              bool     `protobuf:"varint,4,opt,name=enforce,proto3" json:"enforce,omitempty"`
	Dependencies         []string `protobuf:"bytes,5,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedTaskMeta

func NewPopulatedTaskMeta(r randyPlugin, easy bool) *TaskMeta

func (*TaskMeta) Compare

func (this *TaskMeta) Compare(that interface{}) int

func (*TaskMeta) Descriptor

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

func (*TaskMeta) Equal

func (this *TaskMeta) Equal(that interface{}) bool

func (*TaskMeta) GetDependencies

func (m *TaskMeta) GetDependencies() []string

func (*TaskMeta) GetEnforce

func (m *TaskMeta) GetEnforce() bool

func (*TaskMeta) GetName

func (m *TaskMeta) GetName() string

func (*TaskMeta) GetPluginMeta

func (m *TaskMeta) GetPluginMeta() *Meta

func (*TaskMeta) GetURL

func (m *TaskMeta) GetURL() string

func (*TaskMeta) GetVersion

func (m *TaskMeta) GetVersion() string

func (*TaskMeta) GoString

func (this *TaskMeta) GoString() string

func (*TaskMeta) Marshal

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

func (*TaskMeta) MarshalTo

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

func (*TaskMeta) MarshalToSizedBuffer

func (m *TaskMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TaskMeta) ProtoMessage

func (*TaskMeta) ProtoMessage()

func (*TaskMeta) Reset

func (m *TaskMeta) Reset()

func (*TaskMeta) Size

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

func (*TaskMeta) String

func (this *TaskMeta) String() string

func (*TaskMeta) Unmarshal

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

func (*TaskMeta) XXX_DiscardUnknown

func (m *TaskMeta) XXX_DiscardUnknown()

func (*TaskMeta) XXX_Marshal

func (m *TaskMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskMeta) XXX_Merge

func (m *TaskMeta) XXX_Merge(src proto.Message)

func (*TaskMeta) XXX_MessageName

func (*TaskMeta) XXX_MessageName() string

func (*TaskMeta) XXX_Size

func (m *TaskMeta) XXX_Size() int

func (*TaskMeta) XXX_Unmarshal

func (m *TaskMeta) XXX_Unmarshal(b []byte) error