dataflow

package
v1.10.0 Latest Latest
Warning

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

Go to latest
Published: Feb 14, 2024 License: Apache-2.0 Imports: 7 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDataFlowEndpoints added in v1.0.0

func NewDataFlowEndpoints() []*api.Endpoint

func RegisterDataFlowHandler

func RegisterDataFlowHandler(s server.Server, hdlr DataFlowHandler, opts ...server.HandlerOption) error

Types

type Connector

type Connector struct {
	StorType             string   `protobuf:"bytes,1,opt,name=storType,proto3" json:"storType,omitempty"`
	BucketName           string   `protobuf:"bytes,2,opt,name=bucketName,proto3" json:"bucketName,omitempty"`
	ConnConfig           []*KV    `protobuf:"bytes,3,rep,name=connConfig,proto3" json:"connConfig,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Connector) Descriptor

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

func (*Connector) GetBucketName

func (m *Connector) GetBucketName() string

func (*Connector) GetConnConfig

func (m *Connector) GetConnConfig() []*KV

func (*Connector) GetStorType

func (m *Connector) GetStorType() string

func (*Connector) ProtoMessage

func (*Connector) ProtoMessage()

func (*Connector) Reset

func (m *Connector) Reset()

func (*Connector) String

func (m *Connector) String() string

func (*Connector) XXX_DiscardUnknown

func (m *Connector) XXX_DiscardUnknown()

func (*Connector) XXX_Marshal

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

func (*Connector) XXX_Merge

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

func (*Connector) XXX_Size

func (m *Connector) XXX_Size() int

func (*Connector) XXX_Unmarshal

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

type CreatePlanRequest

type CreatePlanRequest struct {
	Plan                 *Plan    `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreatePlanRequest) Descriptor

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

func (*CreatePlanRequest) GetPlan

func (m *CreatePlanRequest) GetPlan() *Plan

func (*CreatePlanRequest) ProtoMessage

func (*CreatePlanRequest) ProtoMessage()

func (*CreatePlanRequest) Reset

func (m *CreatePlanRequest) Reset()

func (*CreatePlanRequest) String

func (m *CreatePlanRequest) String() string

func (*CreatePlanRequest) XXX_DiscardUnknown

func (m *CreatePlanRequest) XXX_DiscardUnknown()

func (*CreatePlanRequest) XXX_Marshal

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

func (*CreatePlanRequest) XXX_Merge

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

func (*CreatePlanRequest) XXX_Size

func (m *CreatePlanRequest) XXX_Size() int

func (*CreatePlanRequest) XXX_Unmarshal

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

type CreatePlanResponse

type CreatePlanResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Plan                 *Plan    `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreatePlanResponse) Descriptor

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

func (*CreatePlanResponse) GetErr

func (m *CreatePlanResponse) GetErr() string

func (*CreatePlanResponse) GetPlan

func (m *CreatePlanResponse) GetPlan() *Plan

func (*CreatePlanResponse) ProtoMessage

func (*CreatePlanResponse) ProtoMessage()

func (*CreatePlanResponse) Reset

func (m *CreatePlanResponse) Reset()

func (*CreatePlanResponse) String

func (m *CreatePlanResponse) String() string

func (*CreatePlanResponse) XXX_DiscardUnknown

func (m *CreatePlanResponse) XXX_DiscardUnknown()

func (*CreatePlanResponse) XXX_Marshal

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

func (*CreatePlanResponse) XXX_Merge

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

func (*CreatePlanResponse) XXX_Size

func (m *CreatePlanResponse) XXX_Size() int

func (*CreatePlanResponse) XXX_Unmarshal

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

type CreatePolicyRequest

type CreatePolicyRequest struct {
	Policy               *Policy  `protobuf:"bytes,1,opt,name=policy,proto3" json:"policy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreatePolicyRequest) Descriptor

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

func (*CreatePolicyRequest) GetPolicy

func (m *CreatePolicyRequest) GetPolicy() *Policy

func (*CreatePolicyRequest) ProtoMessage

func (*CreatePolicyRequest) ProtoMessage()

func (*CreatePolicyRequest) Reset

func (m *CreatePolicyRequest) Reset()

func (*CreatePolicyRequest) String

func (m *CreatePolicyRequest) String() string

func (*CreatePolicyRequest) XXX_DiscardUnknown

func (m *CreatePolicyRequest) XXX_DiscardUnknown()

func (*CreatePolicyRequest) XXX_Marshal

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

func (*CreatePolicyRequest) XXX_Merge

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

func (*CreatePolicyRequest) XXX_Size

func (m *CreatePolicyRequest) XXX_Size() int

func (*CreatePolicyRequest) XXX_Unmarshal

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

type CreatePolicyResponse

type CreatePolicyResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Policy               *Policy  `protobuf:"bytes,2,opt,name=policy,proto3" json:"policy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreatePolicyResponse) Descriptor

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

func (*CreatePolicyResponse) GetErr

func (m *CreatePolicyResponse) GetErr() string

func (*CreatePolicyResponse) GetPolicy

func (m *CreatePolicyResponse) GetPolicy() *Policy

func (*CreatePolicyResponse) ProtoMessage

func (*CreatePolicyResponse) ProtoMessage()

func (*CreatePolicyResponse) Reset

func (m *CreatePolicyResponse) Reset()

func (*CreatePolicyResponse) String

func (m *CreatePolicyResponse) String() string

func (*CreatePolicyResponse) XXX_DiscardUnknown

func (m *CreatePolicyResponse) XXX_DiscardUnknown()

func (*CreatePolicyResponse) XXX_Marshal

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

func (*CreatePolicyResponse) XXX_Merge

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

func (*CreatePolicyResponse) XXX_Size

func (m *CreatePolicyResponse) XXX_Size() int

func (*CreatePolicyResponse) XXX_Unmarshal

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

type DataFlowService

func NewDataFlowService

func NewDataFlowService(name string, c client.Client) DataFlowService

type DeletePlanRequest

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

func (*DeletePlanRequest) Descriptor

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

func (*DeletePlanRequest) GetId

func (m *DeletePlanRequest) GetId() string

func (*DeletePlanRequest) ProtoMessage

func (*DeletePlanRequest) ProtoMessage()

func (*DeletePlanRequest) Reset

func (m *DeletePlanRequest) Reset()

func (*DeletePlanRequest) String

func (m *DeletePlanRequest) String() string

func (*DeletePlanRequest) XXX_DiscardUnknown

func (m *DeletePlanRequest) XXX_DiscardUnknown()

func (*DeletePlanRequest) XXX_Marshal

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

func (*DeletePlanRequest) XXX_Merge

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

func (*DeletePlanRequest) XXX_Size

func (m *DeletePlanRequest) XXX_Size() int

func (*DeletePlanRequest) XXX_Unmarshal

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

type DeletePlanResponse

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

func (*DeletePlanResponse) Descriptor

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

func (*DeletePlanResponse) GetErr

func (m *DeletePlanResponse) GetErr() string

func (*DeletePlanResponse) ProtoMessage

func (*DeletePlanResponse) ProtoMessage()

func (*DeletePlanResponse) Reset

func (m *DeletePlanResponse) Reset()

func (*DeletePlanResponse) String

func (m *DeletePlanResponse) String() string

func (*DeletePlanResponse) XXX_DiscardUnknown

func (m *DeletePlanResponse) XXX_DiscardUnknown()

func (*DeletePlanResponse) XXX_Marshal

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

func (*DeletePlanResponse) XXX_Merge

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

func (*DeletePlanResponse) XXX_Size

func (m *DeletePlanResponse) XXX_Size() int

func (*DeletePlanResponse) XXX_Unmarshal

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

type DeletePolicyRequest

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

func (*DeletePolicyRequest) Descriptor

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

func (*DeletePolicyRequest) GetId

func (m *DeletePolicyRequest) GetId() string

func (*DeletePolicyRequest) ProtoMessage

func (*DeletePolicyRequest) ProtoMessage()

func (*DeletePolicyRequest) Reset

func (m *DeletePolicyRequest) Reset()

func (*DeletePolicyRequest) String

func (m *DeletePolicyRequest) String() string

func (*DeletePolicyRequest) XXX_DiscardUnknown

func (m *DeletePolicyRequest) XXX_DiscardUnknown()

func (*DeletePolicyRequest) XXX_Marshal

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

func (*DeletePolicyRequest) XXX_Merge

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

func (*DeletePolicyRequest) XXX_Size

func (m *DeletePolicyRequest) XXX_Size() int

func (*DeletePolicyRequest) XXX_Unmarshal

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

type DeletePolicyResponse

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

func (*DeletePolicyResponse) Descriptor

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

func (*DeletePolicyResponse) GetErr

func (m *DeletePolicyResponse) GetErr() string

func (*DeletePolicyResponse) ProtoMessage

func (*DeletePolicyResponse) ProtoMessage()

func (*DeletePolicyResponse) Reset

func (m *DeletePolicyResponse) Reset()

func (*DeletePolicyResponse) String

func (m *DeletePolicyResponse) String() string

func (*DeletePolicyResponse) XXX_DiscardUnknown

func (m *DeletePolicyResponse) XXX_DiscardUnknown()

func (*DeletePolicyResponse) XXX_Marshal

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

func (*DeletePolicyResponse) XXX_Merge

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

func (*DeletePolicyResponse) XXX_Size

func (m *DeletePolicyResponse) XXX_Size() int

func (*DeletePolicyResponse) XXX_Unmarshal

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

type Filter

type Filter struct {
	Prefix               string   `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Tag                  []*KV    `protobuf:"bytes,2,rep,name=tag,proto3" json:"tag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Filter) Descriptor

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

func (*Filter) GetPrefix

func (m *Filter) GetPrefix() string

func (*Filter) GetTag

func (m *Filter) GetTag() []*KV

func (*Filter) ProtoMessage

func (*Filter) ProtoMessage()

func (*Filter) Reset

func (m *Filter) Reset()

func (*Filter) String

func (m *Filter) String() string

func (*Filter) XXX_DiscardUnknown

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal

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

func (*Filter) XXX_Merge

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

func (*Filter) XXX_Size

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal

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

type GetJobRequest

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

func (*GetJobRequest) Descriptor

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

func (*GetJobRequest) GetId

func (m *GetJobRequest) GetId() string

func (*GetJobRequest) ProtoMessage

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) Reset

func (m *GetJobRequest) Reset()

func (*GetJobRequest) String

func (m *GetJobRequest) String() string

func (*GetJobRequest) XXX_DiscardUnknown

func (m *GetJobRequest) XXX_DiscardUnknown()

func (*GetJobRequest) XXX_Marshal

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

func (*GetJobRequest) XXX_Merge

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

func (*GetJobRequest) XXX_Size

func (m *GetJobRequest) XXX_Size() int

func (*GetJobRequest) XXX_Unmarshal

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

type GetJobResponse

type GetJobResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Job                  *Job     `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetJobResponse) Descriptor

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

func (*GetJobResponse) GetErr

func (m *GetJobResponse) GetErr() string

func (*GetJobResponse) GetJob

func (m *GetJobResponse) GetJob() *Job

func (*GetJobResponse) ProtoMessage

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) Reset

func (m *GetJobResponse) Reset()

func (*GetJobResponse) String

func (m *GetJobResponse) String() string

func (*GetJobResponse) XXX_DiscardUnknown

func (m *GetJobResponse) XXX_DiscardUnknown()

func (*GetJobResponse) XXX_Marshal

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

func (*GetJobResponse) XXX_Merge

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

func (*GetJobResponse) XXX_Size

func (m *GetJobResponse) XXX_Size() int

func (*GetJobResponse) XXX_Unmarshal

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

type GetPlanRequest

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

func (*GetPlanRequest) Descriptor

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

func (*GetPlanRequest) GetId

func (m *GetPlanRequest) GetId() string

func (*GetPlanRequest) ProtoMessage

func (*GetPlanRequest) ProtoMessage()

func (*GetPlanRequest) Reset

func (m *GetPlanRequest) Reset()

func (*GetPlanRequest) String

func (m *GetPlanRequest) String() string

func (*GetPlanRequest) XXX_DiscardUnknown

func (m *GetPlanRequest) XXX_DiscardUnknown()

func (*GetPlanRequest) XXX_Marshal

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

func (*GetPlanRequest) XXX_Merge

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

func (*GetPlanRequest) XXX_Size

func (m *GetPlanRequest) XXX_Size() int

func (*GetPlanRequest) XXX_Unmarshal

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

type GetPlanResponse

type GetPlanResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Plan                 *Plan    `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPlanResponse) Descriptor

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

func (*GetPlanResponse) GetErr

func (m *GetPlanResponse) GetErr() string

func (*GetPlanResponse) GetPlan

func (m *GetPlanResponse) GetPlan() *Plan

func (*GetPlanResponse) ProtoMessage

func (*GetPlanResponse) ProtoMessage()

func (*GetPlanResponse) Reset

func (m *GetPlanResponse) Reset()

func (*GetPlanResponse) String

func (m *GetPlanResponse) String() string

func (*GetPlanResponse) XXX_DiscardUnknown

func (m *GetPlanResponse) XXX_DiscardUnknown()

func (*GetPlanResponse) XXX_Marshal

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

func (*GetPlanResponse) XXX_Merge

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

func (*GetPlanResponse) XXX_Size

func (m *GetPlanResponse) XXX_Size() int

func (*GetPlanResponse) XXX_Unmarshal

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

type GetPolicyRequest

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

func (*GetPolicyRequest) Descriptor

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

func (*GetPolicyRequest) GetId

func (m *GetPolicyRequest) GetId() string

func (*GetPolicyRequest) ProtoMessage

func (*GetPolicyRequest) ProtoMessage()

func (*GetPolicyRequest) Reset

func (m *GetPolicyRequest) Reset()

func (*GetPolicyRequest) String

func (m *GetPolicyRequest) String() string

func (*GetPolicyRequest) XXX_DiscardUnknown

func (m *GetPolicyRequest) XXX_DiscardUnknown()

func (*GetPolicyRequest) XXX_Marshal

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

func (*GetPolicyRequest) XXX_Merge

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

func (*GetPolicyRequest) XXX_Size

func (m *GetPolicyRequest) XXX_Size() int

func (*GetPolicyRequest) XXX_Unmarshal

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

type GetPolicyResponse

type GetPolicyResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Policy               *Policy  `protobuf:"bytes,2,opt,name=policy,proto3" json:"policy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPolicyResponse) Descriptor

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

func (*GetPolicyResponse) GetErr

func (m *GetPolicyResponse) GetErr() string

func (*GetPolicyResponse) GetPolicy

func (m *GetPolicyResponse) GetPolicy() *Policy

func (*GetPolicyResponse) ProtoMessage

func (*GetPolicyResponse) ProtoMessage()

func (*GetPolicyResponse) Reset

func (m *GetPolicyResponse) Reset()

func (*GetPolicyResponse) String

func (m *GetPolicyResponse) String() string

func (*GetPolicyResponse) XXX_DiscardUnknown

func (m *GetPolicyResponse) XXX_DiscardUnknown()

func (*GetPolicyResponse) XXX_Marshal

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

func (*GetPolicyResponse) XXX_Merge

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

func (*GetPolicyResponse) XXX_Size

func (m *GetPolicyResponse) XXX_Size() int

func (*GetPolicyResponse) XXX_Unmarshal

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

type Job

type Job struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TenantId             string   `protobuf:"bytes,2,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	UserId               string   `protobuf:"bytes,3,opt,name=userId,proto3" json:"userId,omitempty"`
	Type                 string   `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	PlanName             string   `protobuf:"bytes,5,opt,name=planName,proto3" json:"planName,omitempty"`
	PlanId               string   `protobuf:"bytes,6,opt,name=planId,proto3" json:"planId,omitempty"`
	Description          string   `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	SourceLocation       string   `protobuf:"bytes,8,opt,name=sourceLocation,proto3" json:"sourceLocation,omitempty"`
	DestLocation         string   `protobuf:"bytes,9,opt,name=destLocation,proto3" json:"destLocation,omitempty"`
	Status               string   `protobuf:"bytes,10,opt,name=status,proto3" json:"status,omitempty"`
	CreateTime           int64    `protobuf:"varint,11,opt,name=createTime,proto3" json:"createTime,omitempty"`
	StartTime            int64    `protobuf:"varint,12,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime              int64    `protobuf:"varint,13,opt,name=endTime,proto3" json:"endTime,omitempty"`
	RemainSource         bool     `protobuf:"varint,14,opt,name=remainSource,proto3" json:"remainSource,omitempty"`
	TotalCapacity        int64    `protobuf:"varint,15,opt,name=totalCapacity,proto3" json:"totalCapacity,omitempty"`
	PassedCapacity       int64    `protobuf:"varint,16,opt,name=passedCapacity,proto3" json:"passedCapacity,omitempty"`
	TotalCount           int64    `protobuf:"varint,17,opt,name=totalCount,proto3" json:"totalCount,omitempty"`
	PassedCount          int64    `protobuf:"varint,18,opt,name=passedCount,proto3" json:"passedCount,omitempty"`
	Progress             int64    `protobuf:"varint,19,opt,name=progress,proto3" json:"progress,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Job) Descriptor

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

func (*Job) GetCreateTime

func (m *Job) GetCreateTime() int64

func (*Job) GetDescription

func (m *Job) GetDescription() string

func (*Job) GetDestLocation

func (m *Job) GetDestLocation() string

func (*Job) GetEndTime

func (m *Job) GetEndTime() int64

func (*Job) GetId

func (m *Job) GetId() string

func (*Job) GetPassedCapacity

func (m *Job) GetPassedCapacity() int64

func (*Job) GetPassedCount

func (m *Job) GetPassedCount() int64

func (*Job) GetPlanId

func (m *Job) GetPlanId() string

func (*Job) GetPlanName

func (m *Job) GetPlanName() string

func (*Job) GetProgress

func (m *Job) GetProgress() int64

func (*Job) GetRemainSource

func (m *Job) GetRemainSource() bool

func (*Job) GetSourceLocation

func (m *Job) GetSourceLocation() string

func (*Job) GetStartTime

func (m *Job) GetStartTime() int64

func (*Job) GetStatus

func (m *Job) GetStatus() string

func (*Job) GetTenantId added in v0.6.3

func (m *Job) GetTenantId() string

func (*Job) GetTotalCapacity

func (m *Job) GetTotalCapacity() int64

func (*Job) GetTotalCount

func (m *Job) GetTotalCount() int64

func (*Job) GetType

func (m *Job) GetType() string

func (*Job) GetUserId added in v0.6.3

func (m *Job) GetUserId() string

func (*Job) ProtoMessage

func (*Job) ProtoMessage()

func (*Job) Reset

func (m *Job) Reset()

func (*Job) String

func (m *Job) String() string

func (*Job) XXX_DiscardUnknown

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal

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

func (*Job) XXX_Merge

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

func (*Job) XXX_Size

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal

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

type KV

type KV struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KV) Descriptor

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

func (*KV) GetKey

func (m *KV) GetKey() string

func (*KV) GetValue

func (m *KV) GetValue() string

func (*KV) ProtoMessage

func (*KV) ProtoMessage()

func (*KV) Reset

func (m *KV) Reset()

func (*KV) String

func (m *KV) String() string

func (*KV) XXX_DiscardUnknown

func (m *KV) XXX_DiscardUnknown()

func (*KV) XXX_Marshal

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

func (*KV) XXX_Merge

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

func (*KV) XXX_Size

func (m *KV) XXX_Size() int

func (*KV) XXX_Unmarshal

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

type ListJobRequest

type ListJobRequest struct {
	Limit                int32             `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset               int32             `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	SortKeys             []string          `protobuf:"bytes,3,rep,name=sortKeys,proto3" json:"sortKeys,omitempty"`
	SortDirs             []string          `protobuf:"bytes,4,rep,name=sortDirs,proto3" json:"sortDirs,omitempty"`
	Filter               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListJobRequest) Descriptor

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

func (*ListJobRequest) GetFilter

func (m *ListJobRequest) GetFilter() map[string]string

func (*ListJobRequest) GetLimit

func (m *ListJobRequest) GetLimit() int32

func (*ListJobRequest) GetOffset

func (m *ListJobRequest) GetOffset() int32

func (*ListJobRequest) GetSortDirs

func (m *ListJobRequest) GetSortDirs() []string

func (*ListJobRequest) GetSortKeys

func (m *ListJobRequest) GetSortKeys() []string

func (*ListJobRequest) ProtoMessage

func (*ListJobRequest) ProtoMessage()

func (*ListJobRequest) Reset

func (m *ListJobRequest) Reset()

func (*ListJobRequest) String

func (m *ListJobRequest) String() string

func (*ListJobRequest) XXX_DiscardUnknown

func (m *ListJobRequest) XXX_DiscardUnknown()

func (*ListJobRequest) XXX_Marshal

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

func (*ListJobRequest) XXX_Merge

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

func (*ListJobRequest) XXX_Size

func (m *ListJobRequest) XXX_Size() int

func (*ListJobRequest) XXX_Unmarshal

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

type ListJobResponse

type ListJobResponse struct {
	Jobs                 []*Job   `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	Next                 int32    `protobuf:"varint,2,opt,name=next,proto3" json:"next,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListJobResponse) Descriptor

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

func (*ListJobResponse) GetJobs

func (m *ListJobResponse) GetJobs() []*Job

func (*ListJobResponse) GetNext

func (m *ListJobResponse) GetNext() int32

func (*ListJobResponse) ProtoMessage

func (*ListJobResponse) ProtoMessage()

func (*ListJobResponse) Reset

func (m *ListJobResponse) Reset()

func (*ListJobResponse) String

func (m *ListJobResponse) String() string

func (*ListJobResponse) XXX_DiscardUnknown

func (m *ListJobResponse) XXX_DiscardUnknown()

func (*ListJobResponse) XXX_Marshal

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

func (*ListJobResponse) XXX_Merge

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

func (*ListJobResponse) XXX_Size

func (m *ListJobResponse) XXX_Size() int

func (*ListJobResponse) XXX_Unmarshal

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

type ListPlanRequest

type ListPlanRequest struct {
	Limit                int32             `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset               int32             `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	SortKeys             []string          `protobuf:"bytes,3,rep,name=sortKeys,proto3" json:"sortKeys,omitempty"`
	SortDirs             []string          `protobuf:"bytes,4,rep,name=sortDirs,proto3" json:"sortDirs,omitempty"`
	Filter               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListPlanRequest) Descriptor

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

func (*ListPlanRequest) GetFilter

func (m *ListPlanRequest) GetFilter() map[string]string

func (*ListPlanRequest) GetLimit

func (m *ListPlanRequest) GetLimit() int32

func (*ListPlanRequest) GetOffset

func (m *ListPlanRequest) GetOffset() int32

func (*ListPlanRequest) GetSortDirs

func (m *ListPlanRequest) GetSortDirs() []string

func (*ListPlanRequest) GetSortKeys

func (m *ListPlanRequest) GetSortKeys() []string

func (*ListPlanRequest) ProtoMessage

func (*ListPlanRequest) ProtoMessage()

func (*ListPlanRequest) Reset

func (m *ListPlanRequest) Reset()

func (*ListPlanRequest) String

func (m *ListPlanRequest) String() string

func (*ListPlanRequest) XXX_DiscardUnknown

func (m *ListPlanRequest) XXX_DiscardUnknown()

func (*ListPlanRequest) XXX_Marshal

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

func (*ListPlanRequest) XXX_Merge

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

func (*ListPlanRequest) XXX_Size

func (m *ListPlanRequest) XXX_Size() int

func (*ListPlanRequest) XXX_Unmarshal

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

type ListPlanResponse

type ListPlanResponse struct {
	Plans                []*Plan  `protobuf:"bytes,1,rep,name=plans,proto3" json:"plans,omitempty"`
	Next                 int32    `protobuf:"varint,2,opt,name=next,proto3" json:"next,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListPlanResponse) Descriptor

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

func (*ListPlanResponse) GetNext

func (m *ListPlanResponse) GetNext() int32

func (*ListPlanResponse) GetPlans

func (m *ListPlanResponse) GetPlans() []*Plan

func (*ListPlanResponse) ProtoMessage

func (*ListPlanResponse) ProtoMessage()

func (*ListPlanResponse) Reset

func (m *ListPlanResponse) Reset()

func (*ListPlanResponse) String

func (m *ListPlanResponse) String() string

func (*ListPlanResponse) XXX_DiscardUnknown

func (m *ListPlanResponse) XXX_DiscardUnknown()

func (*ListPlanResponse) XXX_Marshal

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

func (*ListPlanResponse) XXX_Merge

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

func (*ListPlanResponse) XXX_Size

func (m *ListPlanResponse) XXX_Size() int

func (*ListPlanResponse) XXX_Unmarshal

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

type ListPolicyRequest

type ListPolicyRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListPolicyRequest) Descriptor

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

func (*ListPolicyRequest) ProtoMessage

func (*ListPolicyRequest) ProtoMessage()

func (*ListPolicyRequest) Reset

func (m *ListPolicyRequest) Reset()

func (*ListPolicyRequest) String

func (m *ListPolicyRequest) String() string

func (*ListPolicyRequest) XXX_DiscardUnknown

func (m *ListPolicyRequest) XXX_DiscardUnknown()

func (*ListPolicyRequest) XXX_Marshal

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

func (*ListPolicyRequest) XXX_Merge

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

func (*ListPolicyRequest) XXX_Size

func (m *ListPolicyRequest) XXX_Size() int

func (*ListPolicyRequest) XXX_Unmarshal

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

type ListPolicyResponse

type ListPolicyResponse struct {
	Err                  string    `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Policies             []*Policy `protobuf:"bytes,2,rep,name=policies,proto3" json:"policies,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListPolicyResponse) Descriptor

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

func (*ListPolicyResponse) GetErr

func (m *ListPolicyResponse) GetErr() string

func (*ListPolicyResponse) GetPolicies

func (m *ListPolicyResponse) GetPolicies() []*Policy

func (*ListPolicyResponse) ProtoMessage

func (*ListPolicyResponse) ProtoMessage()

func (*ListPolicyResponse) Reset

func (m *ListPolicyResponse) Reset()

func (*ListPolicyResponse) String

func (m *ListPolicyResponse) String() string

func (*ListPolicyResponse) XXX_DiscardUnknown

func (m *ListPolicyResponse) XXX_DiscardUnknown()

func (*ListPolicyResponse) XXX_Marshal

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

func (*ListPolicyResponse) XXX_Merge

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

func (*ListPolicyResponse) XXX_Size

func (m *ListPolicyResponse) XXX_Size() int

func (*ListPolicyResponse) XXX_Unmarshal

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

type Plan

type Plan struct {
	Id                   string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string     `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description          string     `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Type                 string     `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	PolicyId             string     `protobuf:"bytes,5,opt,name=policyId,proto3" json:"policyId,omitempty"`
	PolicyName           string     `protobuf:"bytes,6,opt,name=policyName,proto3" json:"policyName,omitempty"`
	SourceConn           *Connector `protobuf:"bytes,7,opt,name=sourceConn,proto3" json:"sourceConn,omitempty"`
	DestConn             *Connector `protobuf:"bytes,8,opt,name=destConn,proto3" json:"destConn,omitempty"`
	Filter               *Filter    `protobuf:"bytes,9,opt,name=filter,proto3" json:"filter,omitempty"`
	RemainSource         bool       `protobuf:"varint,10,opt,name=remainSource,proto3" json:"remainSource,omitempty"`
	TenantId             string     `protobuf:"bytes,11,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	UserId               string     `protobuf:"bytes,12,opt,name=userId,proto3" json:"userId,omitempty"`
	PolicyEnabled        bool       `protobuf:"varint,13,opt,name=policyEnabled,proto3" json:"policyEnabled,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Plan) Descriptor

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

func (*Plan) GetDescription

func (m *Plan) GetDescription() string

func (*Plan) GetDestConn

func (m *Plan) GetDestConn() *Connector

func (*Plan) GetFilter

func (m *Plan) GetFilter() *Filter

func (*Plan) GetId

func (m *Plan) GetId() string

func (*Plan) GetName

func (m *Plan) GetName() string

func (*Plan) GetPolicyEnabled

func (m *Plan) GetPolicyEnabled() bool

func (*Plan) GetPolicyId

func (m *Plan) GetPolicyId() string

func (*Plan) GetPolicyName

func (m *Plan) GetPolicyName() string

func (*Plan) GetRemainSource

func (m *Plan) GetRemainSource() bool

func (*Plan) GetSourceConn

func (m *Plan) GetSourceConn() *Connector

func (*Plan) GetTenantId

func (m *Plan) GetTenantId() string

func (*Plan) GetType

func (m *Plan) GetType() string

func (*Plan) GetUserId

func (m *Plan) GetUserId() string

func (*Plan) ProtoMessage

func (*Plan) ProtoMessage()

func (*Plan) Reset

func (m *Plan) Reset()

func (*Plan) String

func (m *Plan) String() string

func (*Plan) XXX_DiscardUnknown

func (m *Plan) XXX_DiscardUnknown()

func (*Plan) XXX_Marshal

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

func (*Plan) XXX_Merge

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

func (*Plan) XXX_Size

func (m *Plan) XXX_Size() int

func (*Plan) XXX_Unmarshal

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

type Policy

type Policy struct {
	Id                   string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TenantId             string    `protobuf:"bytes,2,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	UserId               string    `protobuf:"bytes,3,opt,name=userId,proto3" json:"userId,omitempty"`
	Name                 string    `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Tenant               string    `protobuf:"bytes,5,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Description          string    `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	Schedule             *Schedule `protobuf:"bytes,7,opt,name=schedule,proto3" json:"schedule,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Policy) Descriptor

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

func (*Policy) GetDescription

func (m *Policy) GetDescription() string

func (*Policy) GetId

func (m *Policy) GetId() string

func (*Policy) GetName

func (m *Policy) GetName() string

func (*Policy) GetSchedule

func (m *Policy) GetSchedule() *Schedule

func (*Policy) GetTenant

func (m *Policy) GetTenant() string

func (*Policy) GetTenantId added in v0.6.3

func (m *Policy) GetTenantId() string

func (*Policy) GetUserId added in v0.6.3

func (m *Policy) GetUserId() string

func (*Policy) ProtoMessage

func (*Policy) ProtoMessage()

func (*Policy) Reset

func (m *Policy) Reset()

func (*Policy) String

func (m *Policy) String() string

func (*Policy) XXX_DiscardUnknown

func (m *Policy) XXX_DiscardUnknown()

func (*Policy) XXX_Marshal

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

func (*Policy) XXX_Merge

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

func (*Policy) XXX_Size

func (m *Policy) XXX_Size() int

func (*Policy) XXX_Unmarshal

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

type RunPlanRequest

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

func (*RunPlanRequest) Descriptor

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

func (*RunPlanRequest) GetId

func (m *RunPlanRequest) GetId() string

func (*RunPlanRequest) ProtoMessage

func (*RunPlanRequest) ProtoMessage()

func (*RunPlanRequest) Reset

func (m *RunPlanRequest) Reset()

func (*RunPlanRequest) String

func (m *RunPlanRequest) String() string

func (*RunPlanRequest) XXX_DiscardUnknown

func (m *RunPlanRequest) XXX_DiscardUnknown()

func (*RunPlanRequest) XXX_Marshal

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

func (*RunPlanRequest) XXX_Merge

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

func (*RunPlanRequest) XXX_Size

func (m *RunPlanRequest) XXX_Size() int

func (*RunPlanRequest) XXX_Unmarshal

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

type RunPlanResponse

type RunPlanResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	JobId                string   `protobuf:"bytes,2,opt,name=jobId,proto3" json:"jobId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RunPlanResponse) Descriptor

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

func (*RunPlanResponse) GetErr

func (m *RunPlanResponse) GetErr() string

func (*RunPlanResponse) GetJobId

func (m *RunPlanResponse) GetJobId() string

func (*RunPlanResponse) ProtoMessage

func (*RunPlanResponse) ProtoMessage()

func (*RunPlanResponse) Reset

func (m *RunPlanResponse) Reset()

func (*RunPlanResponse) String

func (m *RunPlanResponse) String() string

func (*RunPlanResponse) XXX_DiscardUnknown

func (m *RunPlanResponse) XXX_DiscardUnknown()

func (*RunPlanResponse) XXX_Marshal

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

func (*RunPlanResponse) XXX_Merge

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

func (*RunPlanResponse) XXX_Size

func (m *RunPlanResponse) XXX_Size() int

func (*RunPlanResponse) XXX_Unmarshal

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

type Schedule

type Schedule struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	TiggerProperties     string   `protobuf:"bytes,2,opt,name=tiggerProperties,proto3" json:"tiggerProperties,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Schedule) Descriptor

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

func (*Schedule) GetTiggerProperties

func (m *Schedule) GetTiggerProperties() string

func (*Schedule) GetType

func (m *Schedule) GetType() string

func (*Schedule) ProtoMessage

func (*Schedule) ProtoMessage()

func (*Schedule) Reset

func (m *Schedule) Reset()

func (*Schedule) String

func (m *Schedule) String() string

func (*Schedule) XXX_DiscardUnknown

func (m *Schedule) XXX_DiscardUnknown()

func (*Schedule) XXX_Marshal

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

func (*Schedule) XXX_Merge

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

func (*Schedule) XXX_Size

func (m *Schedule) XXX_Size() int

func (*Schedule) XXX_Unmarshal

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

type UpdatePlanRequest

type UpdatePlanRequest struct {
	PlanId               string   `protobuf:"bytes,1,opt,name=planId,proto3" json:"planId,omitempty"`
	Body                 string   `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdatePlanRequest) Descriptor

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

func (*UpdatePlanRequest) GetBody

func (m *UpdatePlanRequest) GetBody() string

func (*UpdatePlanRequest) GetPlanId

func (m *UpdatePlanRequest) GetPlanId() string

func (*UpdatePlanRequest) ProtoMessage

func (*UpdatePlanRequest) ProtoMessage()

func (*UpdatePlanRequest) Reset

func (m *UpdatePlanRequest) Reset()

func (*UpdatePlanRequest) String

func (m *UpdatePlanRequest) String() string

func (*UpdatePlanRequest) XXX_DiscardUnknown

func (m *UpdatePlanRequest) XXX_DiscardUnknown()

func (*UpdatePlanRequest) XXX_Marshal

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

func (*UpdatePlanRequest) XXX_Merge

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

func (*UpdatePlanRequest) XXX_Size

func (m *UpdatePlanRequest) XXX_Size() int

func (*UpdatePlanRequest) XXX_Unmarshal

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

type UpdatePlanResponse

type UpdatePlanResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Plan                 *Plan    `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdatePlanResponse) Descriptor

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

func (*UpdatePlanResponse) GetErr

func (m *UpdatePlanResponse) GetErr() string

func (*UpdatePlanResponse) GetPlan

func (m *UpdatePlanResponse) GetPlan() *Plan

func (*UpdatePlanResponse) ProtoMessage

func (*UpdatePlanResponse) ProtoMessage()

func (*UpdatePlanResponse) Reset

func (m *UpdatePlanResponse) Reset()

func (*UpdatePlanResponse) String

func (m *UpdatePlanResponse) String() string

func (*UpdatePlanResponse) XXX_DiscardUnknown

func (m *UpdatePlanResponse) XXX_DiscardUnknown()

func (*UpdatePlanResponse) XXX_Marshal

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

func (*UpdatePlanResponse) XXX_Merge

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

func (*UpdatePlanResponse) XXX_Size

func (m *UpdatePlanResponse) XXX_Size() int

func (*UpdatePlanResponse) XXX_Unmarshal

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

type UpdatePolicyRequest

type UpdatePolicyRequest struct {
	PolicyId             string   `protobuf:"bytes,1,opt,name=policyId,proto3" json:"policyId,omitempty"`
	Body                 string   `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdatePolicyRequest) Descriptor

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

func (*UpdatePolicyRequest) GetBody

func (m *UpdatePolicyRequest) GetBody() string

func (*UpdatePolicyRequest) GetPolicyId

func (m *UpdatePolicyRequest) GetPolicyId() string

func (*UpdatePolicyRequest) ProtoMessage

func (*UpdatePolicyRequest) ProtoMessage()

func (*UpdatePolicyRequest) Reset

func (m *UpdatePolicyRequest) Reset()

func (*UpdatePolicyRequest) String

func (m *UpdatePolicyRequest) String() string

func (*UpdatePolicyRequest) XXX_DiscardUnknown

func (m *UpdatePolicyRequest) XXX_DiscardUnknown()

func (*UpdatePolicyRequest) XXX_Marshal

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

func (*UpdatePolicyRequest) XXX_Merge

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

func (*UpdatePolicyRequest) XXX_Size

func (m *UpdatePolicyRequest) XXX_Size() int

func (*UpdatePolicyRequest) XXX_Unmarshal

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

type UpdatePolicyResponse

type UpdatePolicyResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Policy               *Policy  `protobuf:"bytes,2,opt,name=policy,proto3" json:"policy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdatePolicyResponse) Descriptor

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

func (*UpdatePolicyResponse) GetErr

func (m *UpdatePolicyResponse) GetErr() string

func (*UpdatePolicyResponse) GetPolicy

func (m *UpdatePolicyResponse) GetPolicy() *Policy

func (*UpdatePolicyResponse) ProtoMessage

func (*UpdatePolicyResponse) ProtoMessage()

func (*UpdatePolicyResponse) Reset

func (m *UpdatePolicyResponse) Reset()

func (*UpdatePolicyResponse) String

func (m *UpdatePolicyResponse) String() string

func (*UpdatePolicyResponse) XXX_DiscardUnknown

func (m *UpdatePolicyResponse) XXX_DiscardUnknown()

func (*UpdatePolicyResponse) XXX_Marshal

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

func (*UpdatePolicyResponse) XXX_Merge

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

func (*UpdatePolicyResponse) XXX_Size

func (m *UpdatePolicyResponse) XXX_Size() int

func (*UpdatePolicyResponse) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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