Versions in this module Expand all Collapse all v0 v0.3.2 Nov 9, 2018 Changes in this version + func RegisterDataFlowHandler(s server.Server, hdlr DataFlowHandler, opts ...server.HandlerOption) error + type Connector struct + BucketName string + ConnConfig []*KV + StorType string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Connector) Descriptor() ([]byte, []int) + func (*Connector) ProtoMessage() + func (dst *Connector) XXX_Merge(src proto.Message) + func (m *Connector) GetBucketName() string + func (m *Connector) GetConnConfig() []*KV + func (m *Connector) GetStorType() string + func (m *Connector) Reset() + func (m *Connector) String() string + func (m *Connector) XXX_DiscardUnknown() + func (m *Connector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Connector) XXX_Size() int + func (m *Connector) XXX_Unmarshal(b []byte) error + type CreatePlanRequest struct + Context string + Plan *Plan + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreatePlanRequest) Descriptor() ([]byte, []int) + func (*CreatePlanRequest) ProtoMessage() + func (dst *CreatePlanRequest) XXX_Merge(src proto.Message) + func (m *CreatePlanRequest) GetContext() string + func (m *CreatePlanRequest) GetPlan() *Plan + func (m *CreatePlanRequest) Reset() + func (m *CreatePlanRequest) String() string + func (m *CreatePlanRequest) XXX_DiscardUnknown() + func (m *CreatePlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreatePlanRequest) XXX_Size() int + func (m *CreatePlanRequest) XXX_Unmarshal(b []byte) error + type CreatePlanResponse struct + Err string + Plan *Plan + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreatePlanResponse) Descriptor() ([]byte, []int) + func (*CreatePlanResponse) ProtoMessage() + func (dst *CreatePlanResponse) XXX_Merge(src proto.Message) + func (m *CreatePlanResponse) GetErr() string + func (m *CreatePlanResponse) GetPlan() *Plan + func (m *CreatePlanResponse) Reset() + func (m *CreatePlanResponse) String() string + func (m *CreatePlanResponse) XXX_DiscardUnknown() + func (m *CreatePlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreatePlanResponse) XXX_Size() int + func (m *CreatePlanResponse) XXX_Unmarshal(b []byte) error + type CreatePolicyRequest struct + Context string + Policy *Policy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreatePolicyRequest) Descriptor() ([]byte, []int) + func (*CreatePolicyRequest) ProtoMessage() + func (dst *CreatePolicyRequest) XXX_Merge(src proto.Message) + func (m *CreatePolicyRequest) GetContext() string + func (m *CreatePolicyRequest) GetPolicy() *Policy + func (m *CreatePolicyRequest) Reset() + func (m *CreatePolicyRequest) String() string + func (m *CreatePolicyRequest) XXX_DiscardUnknown() + func (m *CreatePolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreatePolicyRequest) XXX_Size() int + func (m *CreatePolicyRequest) XXX_Unmarshal(b []byte) error + type CreatePolicyResponse struct + Err string + Policy *Policy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreatePolicyResponse) Descriptor() ([]byte, []int) + func (*CreatePolicyResponse) ProtoMessage() + func (dst *CreatePolicyResponse) XXX_Merge(src proto.Message) + func (m *CreatePolicyResponse) GetErr() string + func (m *CreatePolicyResponse) GetPolicy() *Policy + func (m *CreatePolicyResponse) Reset() + func (m *CreatePolicyResponse) String() string + func (m *CreatePolicyResponse) XXX_DiscardUnknown() + func (m *CreatePolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreatePolicyResponse) XXX_Size() int + func (m *CreatePolicyResponse) XXX_Unmarshal(b []byte) error + type DataFlowHandler interface + CreatePlan func(context.Context, *CreatePlanRequest, *CreatePlanResponse) error + CreatePolicy func(context.Context, *CreatePolicyRequest, *CreatePolicyResponse) error + DeletePlan func(context.Context, *DeletePlanRequest, *DeletePlanResponse) error + DeletePolicy func(context.Context, *DeletePolicyRequest, *DeletePolicyResponse) error + GetJob func(context.Context, *GetJobRequest, *GetJobResponse) error + GetPlan func(context.Context, *GetPlanRequest, *GetPlanResponse) error + GetPolicy func(context.Context, *GetPolicyRequest, *GetPolicyResponse) error + ListJob func(context.Context, *ListJobRequest, *ListJobResponse) error + ListPlan func(context.Context, *ListPlanRequest, *ListPlanResponse) error + ListPolicy func(context.Context, *ListPolicyRequest, *ListPolicyResponse) error + RunPlan func(context.Context, *RunPlanRequest, *RunPlanResponse) error + UpdatePlan func(context.Context, *UpdatePlanRequest, *UpdatePlanResponse) error + UpdatePolicy func(context.Context, *UpdatePolicyRequest, *UpdatePolicyResponse) error + type DataFlowService interface + CreatePlan func(ctx context.Context, in *CreatePlanRequest, opts ...client.CallOption) (*CreatePlanResponse, error) + CreatePolicy func(ctx context.Context, in *CreatePolicyRequest, opts ...client.CallOption) (*CreatePolicyResponse, error) + DeletePlan func(ctx context.Context, in *DeletePlanRequest, opts ...client.CallOption) (*DeletePlanResponse, error) + DeletePolicy func(ctx context.Context, in *DeletePolicyRequest, opts ...client.CallOption) (*DeletePolicyResponse, error) + GetJob func(ctx context.Context, in *GetJobRequest, opts ...client.CallOption) (*GetJobResponse, error) + GetPlan func(ctx context.Context, in *GetPlanRequest, opts ...client.CallOption) (*GetPlanResponse, error) + GetPolicy func(ctx context.Context, in *GetPolicyRequest, opts ...client.CallOption) (*GetPolicyResponse, error) + ListJob func(ctx context.Context, in *ListJobRequest, opts ...client.CallOption) (*ListJobResponse, error) + ListPlan func(ctx context.Context, in *ListPlanRequest, opts ...client.CallOption) (*ListPlanResponse, error) + ListPolicy func(ctx context.Context, in *ListPolicyRequest, opts ...client.CallOption) (*ListPolicyResponse, error) + RunPlan func(ctx context.Context, in *RunPlanRequest, opts ...client.CallOption) (*RunPlanResponse, error) + UpdatePlan func(ctx context.Context, in *UpdatePlanRequest, opts ...client.CallOption) (*UpdatePlanResponse, error) + UpdatePolicy func(ctx context.Context, in *UpdatePolicyRequest, opts ...client.CallOption) (*UpdatePolicyResponse, error) + func NewDataFlowService(name string, c client.Client) DataFlowService + type DeletePlanRequest struct + Context string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeletePlanRequest) Descriptor() ([]byte, []int) + func (*DeletePlanRequest) ProtoMessage() + func (dst *DeletePlanRequest) XXX_Merge(src proto.Message) + func (m *DeletePlanRequest) GetContext() string + func (m *DeletePlanRequest) GetId() string + func (m *DeletePlanRequest) Reset() + func (m *DeletePlanRequest) String() string + func (m *DeletePlanRequest) XXX_DiscardUnknown() + func (m *DeletePlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeletePlanRequest) XXX_Size() int + func (m *DeletePlanRequest) XXX_Unmarshal(b []byte) error + type DeletePlanResponse struct + Err string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeletePlanResponse) Descriptor() ([]byte, []int) + func (*DeletePlanResponse) ProtoMessage() + func (dst *DeletePlanResponse) XXX_Merge(src proto.Message) + func (m *DeletePlanResponse) GetErr() string + func (m *DeletePlanResponse) Reset() + func (m *DeletePlanResponse) String() string + func (m *DeletePlanResponse) XXX_DiscardUnknown() + func (m *DeletePlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeletePlanResponse) XXX_Size() int + func (m *DeletePlanResponse) XXX_Unmarshal(b []byte) error + type DeletePolicyRequest struct + Context string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeletePolicyRequest) Descriptor() ([]byte, []int) + func (*DeletePolicyRequest) ProtoMessage() + func (dst *DeletePolicyRequest) XXX_Merge(src proto.Message) + func (m *DeletePolicyRequest) GetContext() string + func (m *DeletePolicyRequest) GetId() string + func (m *DeletePolicyRequest) Reset() + func (m *DeletePolicyRequest) String() string + func (m *DeletePolicyRequest) XXX_DiscardUnknown() + func (m *DeletePolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeletePolicyRequest) XXX_Size() int + func (m *DeletePolicyRequest) XXX_Unmarshal(b []byte) error + type DeletePolicyResponse struct + Err string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeletePolicyResponse) Descriptor() ([]byte, []int) + func (*DeletePolicyResponse) ProtoMessage() + func (dst *DeletePolicyResponse) XXX_Merge(src proto.Message) + func (m *DeletePolicyResponse) GetErr() string + func (m *DeletePolicyResponse) Reset() + func (m *DeletePolicyResponse) String() string + func (m *DeletePolicyResponse) XXX_DiscardUnknown() + func (m *DeletePolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeletePolicyResponse) XXX_Size() int + func (m *DeletePolicyResponse) XXX_Unmarshal(b []byte) error + type Filter struct + Prefix string + Tag []*KV + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Filter) Descriptor() ([]byte, []int) + func (*Filter) ProtoMessage() + func (dst *Filter) XXX_Merge(src proto.Message) + func (m *Filter) GetPrefix() string + func (m *Filter) GetTag() []*KV + func (m *Filter) Reset() + func (m *Filter) String() string + func (m *Filter) XXX_DiscardUnknown() + func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Filter) XXX_Size() int + func (m *Filter) XXX_Unmarshal(b []byte) error + type GetJobRequest struct + Context string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetJobRequest) Descriptor() ([]byte, []int) + func (*GetJobRequest) ProtoMessage() + func (dst *GetJobRequest) XXX_Merge(src proto.Message) + func (m *GetJobRequest) GetContext() string + func (m *GetJobRequest) GetId() string + func (m *GetJobRequest) Reset() + func (m *GetJobRequest) String() string + func (m *GetJobRequest) XXX_DiscardUnknown() + func (m *GetJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetJobRequest) XXX_Size() int + func (m *GetJobRequest) XXX_Unmarshal(b []byte) error + type GetJobResponse struct + Err string + Job *Job + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetJobResponse) Descriptor() ([]byte, []int) + func (*GetJobResponse) ProtoMessage() + func (dst *GetJobResponse) XXX_Merge(src proto.Message) + func (m *GetJobResponse) GetErr() string + func (m *GetJobResponse) GetJob() *Job + func (m *GetJobResponse) Reset() + func (m *GetJobResponse) String() string + func (m *GetJobResponse) XXX_DiscardUnknown() + func (m *GetJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetJobResponse) XXX_Size() int + func (m *GetJobResponse) XXX_Unmarshal(b []byte) error + type GetPlanRequest struct + Context string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetPlanRequest) Descriptor() ([]byte, []int) + func (*GetPlanRequest) ProtoMessage() + func (dst *GetPlanRequest) XXX_Merge(src proto.Message) + func (m *GetPlanRequest) GetContext() string + func (m *GetPlanRequest) GetId() string + func (m *GetPlanRequest) Reset() + func (m *GetPlanRequest) String() string + func (m *GetPlanRequest) XXX_DiscardUnknown() + func (m *GetPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetPlanRequest) XXX_Size() int + func (m *GetPlanRequest) XXX_Unmarshal(b []byte) error + type GetPlanResponse struct + Err string + Plan *Plan + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetPlanResponse) Descriptor() ([]byte, []int) + func (*GetPlanResponse) ProtoMessage() + func (dst *GetPlanResponse) XXX_Merge(src proto.Message) + func (m *GetPlanResponse) GetErr() string + func (m *GetPlanResponse) GetPlan() *Plan + func (m *GetPlanResponse) Reset() + func (m *GetPlanResponse) String() string + func (m *GetPlanResponse) XXX_DiscardUnknown() + func (m *GetPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetPlanResponse) XXX_Size() int + func (m *GetPlanResponse) XXX_Unmarshal(b []byte) error + type GetPolicyRequest struct + Context string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetPolicyRequest) Descriptor() ([]byte, []int) + func (*GetPolicyRequest) ProtoMessage() + func (dst *GetPolicyRequest) XXX_Merge(src proto.Message) + func (m *GetPolicyRequest) GetContext() string + func (m *GetPolicyRequest) GetId() string + func (m *GetPolicyRequest) Reset() + func (m *GetPolicyRequest) String() string + func (m *GetPolicyRequest) XXX_DiscardUnknown() + func (m *GetPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetPolicyRequest) XXX_Size() int + func (m *GetPolicyRequest) XXX_Unmarshal(b []byte) error + type GetPolicyResponse struct + Err string + Policy *Policy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetPolicyResponse) Descriptor() ([]byte, []int) + func (*GetPolicyResponse) ProtoMessage() + func (dst *GetPolicyResponse) XXX_Merge(src proto.Message) + func (m *GetPolicyResponse) GetErr() string + func (m *GetPolicyResponse) GetPolicy() *Policy + func (m *GetPolicyResponse) Reset() + func (m *GetPolicyResponse) String() string + func (m *GetPolicyResponse) XXX_DiscardUnknown() + func (m *GetPolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetPolicyResponse) XXX_Size() int + func (m *GetPolicyResponse) XXX_Unmarshal(b []byte) error + type Job struct + CreateTime int64 + Description string + DestLocation string + EndTime int64 + Id string + PassedCapacity int64 + PassedCount int64 + PlanId string + PlanName string + Progress int64 + RemainSource bool + SourceLocation string + StartTime int64 + Status string + TotalCapacity int64 + TotalCount int64 + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (dst *Job) XXX_Merge(src proto.Message) + func (m *Job) GetCreateTime() int64 + func (m *Job) GetDescription() string + func (m *Job) GetDestLocation() string + func (m *Job) GetEndTime() int64 + func (m *Job) GetId() string + func (m *Job) GetPassedCapacity() int64 + func (m *Job) GetPassedCount() int64 + func (m *Job) GetPlanId() string + func (m *Job) GetPlanName() string + func (m *Job) GetProgress() int64 + func (m *Job) GetRemainSource() bool + func (m *Job) GetSourceLocation() string + func (m *Job) GetStartTime() int64 + func (m *Job) GetStatus() string + func (m *Job) GetTotalCapacity() int64 + func (m *Job) GetTotalCount() int64 + func (m *Job) GetType() string + func (m *Job) Reset() + func (m *Job) String() string + func (m *Job) XXX_DiscardUnknown() + func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Job) XXX_Size() int + func (m *Job) XXX_Unmarshal(b []byte) error + type KV struct + Key string + Value string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KV) Descriptor() ([]byte, []int) + func (*KV) ProtoMessage() + func (dst *KV) XXX_Merge(src proto.Message) + func (m *KV) GetKey() string + func (m *KV) GetValue() string + func (m *KV) Reset() + func (m *KV) String() string + func (m *KV) XXX_DiscardUnknown() + func (m *KV) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KV) XXX_Size() int + func (m *KV) XXX_Unmarshal(b []byte) error + type ListJobRequest struct + Context string + Filter map[string]string + Limit int32 + Offset int32 + SortDirs []string + SortKeys []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListJobRequest) Descriptor() ([]byte, []int) + func (*ListJobRequest) ProtoMessage() + func (dst *ListJobRequest) XXX_Merge(src proto.Message) + func (m *ListJobRequest) GetContext() string + func (m *ListJobRequest) GetFilter() map[string]string + func (m *ListJobRequest) GetLimit() int32 + func (m *ListJobRequest) GetOffset() int32 + func (m *ListJobRequest) GetSortDirs() []string + func (m *ListJobRequest) GetSortKeys() []string + func (m *ListJobRequest) Reset() + func (m *ListJobRequest) String() string + func (m *ListJobRequest) XXX_DiscardUnknown() + func (m *ListJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListJobRequest) XXX_Size() int + func (m *ListJobRequest) XXX_Unmarshal(b []byte) error + type ListJobResponse struct + Jobs []*Job + Next int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListJobResponse) Descriptor() ([]byte, []int) + func (*ListJobResponse) ProtoMessage() + func (dst *ListJobResponse) XXX_Merge(src proto.Message) + func (m *ListJobResponse) GetJobs() []*Job + func (m *ListJobResponse) GetNext() int32 + func (m *ListJobResponse) Reset() + func (m *ListJobResponse) String() string + func (m *ListJobResponse) XXX_DiscardUnknown() + func (m *ListJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListJobResponse) XXX_Size() int + func (m *ListJobResponse) XXX_Unmarshal(b []byte) error + type ListPlanRequest struct + Context string + Filter map[string]string + Limit int32 + Offset int32 + SortDirs []string + SortKeys []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListPlanRequest) Descriptor() ([]byte, []int) + func (*ListPlanRequest) ProtoMessage() + func (dst *ListPlanRequest) XXX_Merge(src proto.Message) + func (m *ListPlanRequest) GetContext() string + func (m *ListPlanRequest) GetFilter() map[string]string + func (m *ListPlanRequest) GetLimit() int32 + func (m *ListPlanRequest) GetOffset() int32 + func (m *ListPlanRequest) GetSortDirs() []string + func (m *ListPlanRequest) GetSortKeys() []string + func (m *ListPlanRequest) Reset() + func (m *ListPlanRequest) String() string + func (m *ListPlanRequest) XXX_DiscardUnknown() + func (m *ListPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPlanRequest) XXX_Size() int + func (m *ListPlanRequest) XXX_Unmarshal(b []byte) error + type ListPlanResponse struct + Next int32 + Plans []*Plan + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListPlanResponse) Descriptor() ([]byte, []int) + func (*ListPlanResponse) ProtoMessage() + func (dst *ListPlanResponse) XXX_Merge(src proto.Message) + func (m *ListPlanResponse) GetNext() int32 + func (m *ListPlanResponse) GetPlans() []*Plan + func (m *ListPlanResponse) Reset() + func (m *ListPlanResponse) String() string + func (m *ListPlanResponse) XXX_DiscardUnknown() + func (m *ListPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPlanResponse) XXX_Size() int + func (m *ListPlanResponse) XXX_Unmarshal(b []byte) error + type ListPolicyRequest struct + Context string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListPolicyRequest) Descriptor() ([]byte, []int) + func (*ListPolicyRequest) ProtoMessage() + func (dst *ListPolicyRequest) XXX_Merge(src proto.Message) + func (m *ListPolicyRequest) GetContext() string + func (m *ListPolicyRequest) Reset() + func (m *ListPolicyRequest) String() string + func (m *ListPolicyRequest) XXX_DiscardUnknown() + func (m *ListPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPolicyRequest) XXX_Size() int + func (m *ListPolicyRequest) XXX_Unmarshal(b []byte) error + type ListPolicyResponse struct + Err string + Policies []*Policy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListPolicyResponse) Descriptor() ([]byte, []int) + func (*ListPolicyResponse) ProtoMessage() + func (dst *ListPolicyResponse) XXX_Merge(src proto.Message) + func (m *ListPolicyResponse) GetErr() string + func (m *ListPolicyResponse) GetPolicies() []*Policy + func (m *ListPolicyResponse) Reset() + func (m *ListPolicyResponse) String() string + func (m *ListPolicyResponse) XXX_DiscardUnknown() + func (m *ListPolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPolicyResponse) XXX_Size() int + func (m *ListPolicyResponse) XXX_Unmarshal(b []byte) error + type Plan struct + Description string + DestConn *Connector + Filter *Filter + Id string + Name string + PolicyEnabled bool + PolicyId string + PolicyName string + RemainSource bool + SourceConn *Connector + TenantId string + Type string + UserId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Plan) Descriptor() ([]byte, []int) + func (*Plan) ProtoMessage() + func (dst *Plan) XXX_Merge(src proto.Message) + func (m *Plan) GetDescription() string + func (m *Plan) GetDestConn() *Connector + func (m *Plan) GetFilter() *Filter + func (m *Plan) GetId() string + func (m *Plan) GetName() string + func (m *Plan) GetPolicyEnabled() bool + func (m *Plan) GetPolicyId() string + func (m *Plan) GetPolicyName() string + func (m *Plan) GetRemainSource() bool + func (m *Plan) GetSourceConn() *Connector + func (m *Plan) GetTenantId() string + func (m *Plan) GetType() string + func (m *Plan) GetUserId() string + func (m *Plan) Reset() + func (m *Plan) String() string + func (m *Plan) XXX_DiscardUnknown() + func (m *Plan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Plan) XXX_Size() int + func (m *Plan) XXX_Unmarshal(b []byte) error + type Policy struct + Description string + Id string + Name string + Schedule *Schedule + Tenant string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Policy) Descriptor() ([]byte, []int) + func (*Policy) ProtoMessage() + func (dst *Policy) XXX_Merge(src proto.Message) + func (m *Policy) GetDescription() string + func (m *Policy) GetId() string + func (m *Policy) GetName() string + func (m *Policy) GetSchedule() *Schedule + func (m *Policy) GetTenant() string + func (m *Policy) Reset() + func (m *Policy) String() string + func (m *Policy) XXX_DiscardUnknown() + func (m *Policy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Policy) XXX_Size() int + func (m *Policy) XXX_Unmarshal(b []byte) error + type RunPlanRequest struct + Context string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RunPlanRequest) Descriptor() ([]byte, []int) + func (*RunPlanRequest) ProtoMessage() + func (dst *RunPlanRequest) XXX_Merge(src proto.Message) + func (m *RunPlanRequest) GetContext() string + func (m *RunPlanRequest) GetId() string + func (m *RunPlanRequest) Reset() + func (m *RunPlanRequest) String() string + func (m *RunPlanRequest) XXX_DiscardUnknown() + func (m *RunPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RunPlanRequest) XXX_Size() int + func (m *RunPlanRequest) XXX_Unmarshal(b []byte) error + type RunPlanResponse struct + Err string + JobId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RunPlanResponse) Descriptor() ([]byte, []int) + func (*RunPlanResponse) ProtoMessage() + func (dst *RunPlanResponse) XXX_Merge(src proto.Message) + func (m *RunPlanResponse) GetErr() string + func (m *RunPlanResponse) GetJobId() string + func (m *RunPlanResponse) Reset() + func (m *RunPlanResponse) String() string + func (m *RunPlanResponse) XXX_DiscardUnknown() + func (m *RunPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RunPlanResponse) XXX_Size() int + func (m *RunPlanResponse) XXX_Unmarshal(b []byte) error + type Schedule struct + TiggerProperties string + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Schedule) Descriptor() ([]byte, []int) + func (*Schedule) ProtoMessage() + func (dst *Schedule) XXX_Merge(src proto.Message) + func (m *Schedule) GetTiggerProperties() string + func (m *Schedule) GetType() string + func (m *Schedule) Reset() + func (m *Schedule) String() string + func (m *Schedule) XXX_DiscardUnknown() + func (m *Schedule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Schedule) XXX_Size() int + func (m *Schedule) XXX_Unmarshal(b []byte) error + type UpdatePlanRequest struct + Body string + Context string + PlanId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdatePlanRequest) Descriptor() ([]byte, []int) + func (*UpdatePlanRequest) ProtoMessage() + func (dst *UpdatePlanRequest) XXX_Merge(src proto.Message) + func (m *UpdatePlanRequest) GetBody() string + func (m *UpdatePlanRequest) GetContext() string + func (m *UpdatePlanRequest) GetPlanId() string + func (m *UpdatePlanRequest) Reset() + func (m *UpdatePlanRequest) String() string + func (m *UpdatePlanRequest) XXX_DiscardUnknown() + func (m *UpdatePlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdatePlanRequest) XXX_Size() int + func (m *UpdatePlanRequest) XXX_Unmarshal(b []byte) error + type UpdatePlanResponse struct + Err string + Plan *Plan + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdatePlanResponse) Descriptor() ([]byte, []int) + func (*UpdatePlanResponse) ProtoMessage() + func (dst *UpdatePlanResponse) XXX_Merge(src proto.Message) + func (m *UpdatePlanResponse) GetErr() string + func (m *UpdatePlanResponse) GetPlan() *Plan + func (m *UpdatePlanResponse) Reset() + func (m *UpdatePlanResponse) String() string + func (m *UpdatePlanResponse) XXX_DiscardUnknown() + func (m *UpdatePlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdatePlanResponse) XXX_Size() int + func (m *UpdatePlanResponse) XXX_Unmarshal(b []byte) error + type UpdatePolicyRequest struct + Body string + Context string + PolicyId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdatePolicyRequest) Descriptor() ([]byte, []int) + func (*UpdatePolicyRequest) ProtoMessage() + func (dst *UpdatePolicyRequest) XXX_Merge(src proto.Message) + func (m *UpdatePolicyRequest) GetBody() string + func (m *UpdatePolicyRequest) GetContext() string + func (m *UpdatePolicyRequest) GetPolicyId() string + func (m *UpdatePolicyRequest) Reset() + func (m *UpdatePolicyRequest) String() string + func (m *UpdatePolicyRequest) XXX_DiscardUnknown() + func (m *UpdatePolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdatePolicyRequest) XXX_Size() int + func (m *UpdatePolicyRequest) XXX_Unmarshal(b []byte) error + type UpdatePolicyResponse struct + Err string + Policy *Policy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdatePolicyResponse) Descriptor() ([]byte, []int) + func (*UpdatePolicyResponse) ProtoMessage() + func (dst *UpdatePolicyResponse) XXX_Merge(src proto.Message) + func (m *UpdatePolicyResponse) GetErr() string + func (m *UpdatePolicyResponse) GetPolicy() *Policy + func (m *UpdatePolicyResponse) Reset() + func (m *UpdatePolicyResponse) String() string + func (m *UpdatePolicyResponse) XXX_DiscardUnknown() + func (m *UpdatePolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdatePolicyResponse) XXX_Size() int + func (m *UpdatePolicyResponse) XXX_Unmarshal(b []byte) error
Go to main page