dataflow

package
v1.8.2 Latest Latest
Warning

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

 Go to latest Published: Jul 11, 2023 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 DataFlowHandler 

type DataFlowHandler interface {
	GetPolicy(context.Context, *GetPolicyRequest, *GetPolicyResponse) error
	ListPolicy(context.Context, *ListPolicyRequest, *ListPolicyResponse) error
	CreatePolicy(context.Context, *CreatePolicyRequest, *CreatePolicyResponse) error
	UpdatePolicy(context.Context, *UpdatePolicyRequest, *UpdatePolicyResponse) error
	DeletePolicy(context.Context, *DeletePolicyRequest, *DeletePolicyResponse) error
	GetPlan(context.Context, *GetPlanRequest, *GetPlanResponse) error
	ListPlan(context.Context, *ListPlanRequest, *ListPlanResponse) error
	CreatePlan(context.Context, *CreatePlanRequest, *CreatePlanResponse) error
	UpdatePlan(context.Context, *UpdatePlanRequest, *UpdatePlanResponse) error
	DeletePlan(context.Context, *DeletePlanRequest, *DeletePlanResponse) error
	GetJob(context.Context, *GetJobRequest, *GetJobResponse) error
	ListJob(context.Context, *ListJobRequest, *ListJobResponse) error
	RunPlan(context.Context, *RunPlanRequest, *RunPlanResponse) error
}

type DataFlowService 

type DataFlowService interface {
	GetPolicy(ctx context.Context, in *GetPolicyRequest, opts ...client.CallOption) (*GetPolicyResponse, error)
	ListPolicy(ctx context.Context, in *ListPolicyRequest, opts ...client.CallOption) (*ListPolicyResponse, error)
	CreatePolicy(ctx context.Context, in *CreatePolicyRequest, opts ...client.CallOption) (*CreatePolicyResponse, error)
	UpdatePolicy(ctx context.Context, in *UpdatePolicyRequest, opts ...client.CallOption) (*UpdatePolicyResponse, error)
	DeletePolicy(ctx context.Context, in *DeletePolicyRequest, opts ...client.CallOption) (*DeletePolicyResponse, error)
	GetPlan(ctx context.Context, in *GetPlanRequest, opts ...client.CallOption) (*GetPlanResponse, error)
	ListPlan(ctx context.Context, in *ListPlanRequest, opts ...client.CallOption) (*ListPlanResponse, error)
	CreatePlan(ctx context.Context, in *CreatePlanRequest, opts ...client.CallOption) (*CreatePlanResponse, error)
	UpdatePlan(ctx context.Context, in *UpdatePlanRequest, opts ...client.CallOption) (*UpdatePlanResponse, error)
	DeletePlan(ctx context.Context, in *DeletePlanRequest, opts ...client.CallOption) (*DeletePlanResponse, error)
	GetJob(ctx context.Context, in *GetJobRequest, opts ...client.CallOption) (*GetJobResponse, error)
	ListJob(ctx context.Context, in *ListJobRequest, opts ...client.CallOption) (*ListJobResponse, error)
	RunPlan(ctx context.Context, in *RunPlanRequest, opts ...client.CallOption) (*RunPlanResponse, error)
}

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

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.