pb

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2021 License: Apache-2.0 Imports: 30 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_cron_proto protoreflect.FileDescriptor

Functions

func CronServiceClientType 

func CronServiceClientType() reflect.Type

CronServiceClientType .

func CronServiceHandlerType 

func CronServiceHandlerType() reflect.Type

CronServiceHandlerType .

func CronServiceServerType 

func CronServiceServerType() reflect.Type

CronServiceServerType .

func RegisterCronServiceHandler 

func RegisterCronServiceHandler(r http.Router, srv CronServiceHandler, opts ...http.HandleOption)

RegisterCronServiceHandler register CronServiceHandler to http.Router.

func RegisterCronServiceImp 

func RegisterCronServiceImp(regester transport.Register, srv CronServiceServer, opts ...transport.ServiceOption)

RegisterCronServiceImp cron.proto

func RegisterCronServiceServer 

func RegisterCronServiceServer(s grpc1.ServiceRegistrar, srv CronServiceServer, opts ...grpc1.HandleOption)

func ServiceNames 

func ServiceNames(svr ...string) []string

ServiceNames return all service names

func Types 

func Types() []reflect.Type

Types

type Cron 

type Cron struct {
	ID              uint64                 `protobuf:"varint,1,opt,name=ID,json=id,proto3" json:"ID,omitempty"`
	TimeCreated     *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timeCreated,proto3" json:"timeCreated,omitempty"`
	TimeUpdated     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timeUpdated,proto3" json:"timeUpdated,omitempty"`
	CronExpr        string                 `protobuf:"bytes,4,opt,name=cronExpr,proto3" json:"cronExpr,omitempty"`
	CronStartTime   *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=cronStartTime,proto3" json:"cronStartTime,omitempty"`
	PipelineYmlName string                 `protobuf:"bytes,6,opt,name=pipelineYmlName,proto3" json:"pipelineYmlName,omitempty"`
	Enable          bool                   `protobuf:"varint,7,opt,name=enable,proto3" json:"enable,omitempty"`
	// contains filtered or unexported fields
}

func (*Cron) Descriptor deprecated 

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

Deprecated: Use Cron.ProtoReflect.Descriptor instead.

func (*Cron) GetCronExpr 

func (x *Cron) GetCronExpr() string

func (*Cron) GetCronStartTime 

func (x *Cron) GetCronStartTime() *timestamppb.Timestamp

func (*Cron) GetEnable 

func (x *Cron) GetEnable() bool

func (*Cron) GetID 

func (x *Cron) GetID() uint64

func (*Cron) GetPipelineYmlName 

func (x *Cron) GetPipelineYmlName() string

func (*Cron) GetTimeCreated 

func (x *Cron) GetTimeCreated() *timestamppb.Timestamp

func (*Cron) GetTimeUpdated 

func (x *Cron) GetTimeUpdated() *timestamppb.Timestamp

func (*Cron) MarshalJSON 

func (m *Cron) MarshalJSON() ([]byte, error)

Cron implement json.Marshaler.

func (*Cron) ProtoMessage 

func (*Cron) ProtoMessage()

func (*Cron) ProtoReflect 

func (x *Cron) ProtoReflect() protoreflect.Message

func (*Cron) Reset 

func (x *Cron) Reset()

func (*Cron) String 

func (x *Cron) String() string

func (*Cron) UnmarshalJSON 

func (m *Cron) UnmarshalJSON(b []byte) error

Cron implement json.Marshaler.

func (*Cron) UnmarshalURLValues 

func (m *Cron) UnmarshalURLValues(prefix string, values url.Values) error

Cron implement urlenc.URLValuesUnmarshaler.

func (*Cron) Validate 

func (this *Cron) Validate() error

type CronCreateRequest 

type CronCreateRequest struct {
	PipelineCreateRequest *CronCreateRequestV1 `protobuf:"bytes,1,opt,name=pipelineCreateRequest,proto3" json:"pipelineCreateRequest,omitempty"`
	// contains filtered or unexported fields
}

func (*CronCreateRequest) Descriptor deprecated 

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

Deprecated: Use CronCreateRequest.ProtoReflect.Descriptor instead.

func (*CronCreateRequest) GetPipelineCreateRequest 

func (x *CronCreateRequest) GetPipelineCreateRequest() *CronCreateRequestV1

func (*CronCreateRequest) MarshalJSON 

func (m *CronCreateRequest) MarshalJSON() ([]byte, error)

CronCreateRequest implement json.Marshaler.

func (*CronCreateRequest) ProtoMessage 

func (*CronCreateRequest) ProtoMessage()

func (*CronCreateRequest) ProtoReflect 

func (x *CronCreateRequest) ProtoReflect() protoreflect.Message

func (*CronCreateRequest) Reset 

func (x *CronCreateRequest) Reset()

func (*CronCreateRequest) String 

func (x *CronCreateRequest) String() string

func (*CronCreateRequest) UnmarshalJSON 

func (m *CronCreateRequest) UnmarshalJSON(b []byte) error

CronCreateRequest implement json.Marshaler.

func (*CronCreateRequest) UnmarshalURLValues 

func (m *CronCreateRequest) UnmarshalURLValues(prefix string, values url.Values) error

CronCreateRequest implement urlenc.URLValuesUnmarshaler.

func (*CronCreateRequest) Validate 

func (this *CronCreateRequest) Validate() error

type CronCreateRequestV1 

type CronCreateRequestV1 struct {
	PipelineYml            string                 `protobuf:"bytes,1,opt,name=pipelineYml,proto3" json:"pipelineYml,omitempty"`
	ClusterName            string                 `protobuf:"bytes,2,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	PipelineYmlName        string                 `protobuf:"bytes,3,opt,name=pipelineYmlName,proto3" json:"pipelineYmlName,omitempty"`
	PipelineSource         string                 `protobuf:"bytes,4,opt,name=pipelineSource,proto3" json:"pipelineSource,omitempty"`
	Labels                 map[string]string      `` /* 153-byte string literal not displayed */
	NormalLabels           map[string]string      `` /* 165-byte string literal not displayed */
	Envs                   map[string]string      `` /* 149-byte string literal not displayed */
	ConfigManageNamespaces []string               `protobuf:"bytes,8,rep,name=configManageNamespaces,proto3" json:"configManageNamespaces,omitempty"`
	AutoStartCron          bool                   `protobuf:"varint,9,opt,name=autoStartCron,proto3" json:"autoStartCron,omitempty"`
	CronStartFrom          *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=cronStartFrom,proto3" json:"cronStartFrom,omitempty"`
	// contains filtered or unexported fields
}

func (*CronCreateRequestV1) Descriptor deprecated 

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

Deprecated: Use CronCreateRequestV1.ProtoReflect.Descriptor instead.

func (*CronCreateRequestV1) GetAutoStartCron 

func (x *CronCreateRequestV1) GetAutoStartCron() bool

func (*CronCreateRequestV1) GetClusterName 

func (x *CronCreateRequestV1) GetClusterName() string

func (*CronCreateRequestV1) GetConfigManageNamespaces 

func (x *CronCreateRequestV1) GetConfigManageNamespaces() []string

func (*CronCreateRequestV1) GetCronStartFrom 

func (x *CronCreateRequestV1) GetCronStartFrom() *timestamppb.Timestamp

func (*CronCreateRequestV1) GetEnvs 

func (x *CronCreateRequestV1) GetEnvs() map[string]string

func (*CronCreateRequestV1) GetLabels 

func (x *CronCreateRequestV1) GetLabels() map[string]string

func (*CronCreateRequestV1) GetNormalLabels 

func (x *CronCreateRequestV1) GetNormalLabels() map[string]string

func (*CronCreateRequestV1) GetPipelineSource 

func (x *CronCreateRequestV1) GetPipelineSource() string

func (*CronCreateRequestV1) GetPipelineYml 

func (x *CronCreateRequestV1) GetPipelineYml() string

func (*CronCreateRequestV1) GetPipelineYmlName 

func (x *CronCreateRequestV1) GetPipelineYmlName() string

func (*CronCreateRequestV1) MarshalJSON 

func (m *CronCreateRequestV1) MarshalJSON() ([]byte, error)

CronCreateRequestV1 implement json.Marshaler.

func (*CronCreateRequestV1) ProtoMessage 

func (*CronCreateRequestV1) ProtoMessage()

func (*CronCreateRequestV1) ProtoReflect 

func (x *CronCreateRequestV1) ProtoReflect() protoreflect.Message

func (*CronCreateRequestV1) Reset 

func (x *CronCreateRequestV1) Reset()

func (*CronCreateRequestV1) String 

func (x *CronCreateRequestV1) String() string

func (*CronCreateRequestV1) UnmarshalJSON 

func (m *CronCreateRequestV1) UnmarshalJSON(b []byte) error

CronCreateRequestV1 implement json.Marshaler.

func (*CronCreateRequestV1) UnmarshalURLValues 

func (m *CronCreateRequestV1) UnmarshalURLValues(prefix string, values url.Values) error

CronCreateRequestV1 implement urlenc.URLValuesUnmarshaler.

func (*CronCreateRequestV1) Validate 

func (this *CronCreateRequestV1) Validate() error

type CronCreateResponse 

type CronCreateResponse struct {
	Data uint64 `protobuf:"varint,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CronCreateResponse) Descriptor deprecated 

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

Deprecated: Use CronCreateResponse.ProtoReflect.Descriptor instead.

func (*CronCreateResponse) GetData 

func (x *CronCreateResponse) GetData() uint64

func (*CronCreateResponse) MarshalJSON 

func (m *CronCreateResponse) MarshalJSON() ([]byte, error)

CronCreateResponse implement json.Marshaler.

func (*CronCreateResponse) ProtoMessage 

func (*CronCreateResponse) ProtoMessage()

func (*CronCreateResponse) ProtoReflect 

func (x *CronCreateResponse) ProtoReflect() protoreflect.Message

func (*CronCreateResponse) Reset 

func (x *CronCreateResponse) Reset()

func (*CronCreateResponse) String 

func (x *CronCreateResponse) String() string

func (*CronCreateResponse) UnmarshalJSON 

func (m *CronCreateResponse) UnmarshalJSON(b []byte) error

CronCreateResponse implement json.Marshaler.

func (*CronCreateResponse) UnmarshalURLValues 

func (m *CronCreateResponse) UnmarshalURLValues(prefix string, values url.Values) error

CronCreateResponse implement urlenc.URLValuesUnmarshaler.

func (*CronCreateResponse) Validate 

func (this *CronCreateResponse) Validate() error

type CronDeleteRequest 

type CronDeleteRequest struct {
	CronID uint64 `protobuf:"varint,1,opt,name=cronID,proto3" json:"cronID,omitempty"`
	// contains filtered or unexported fields
}

func (*CronDeleteRequest) Descriptor deprecated 

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

Deprecated: Use CronDeleteRequest.ProtoReflect.Descriptor instead.

func (*CronDeleteRequest) GetCronID 

func (x *CronDeleteRequest) GetCronID() uint64

func (*CronDeleteRequest) MarshalJSON 

func (m *CronDeleteRequest) MarshalJSON() ([]byte, error)

CronDeleteRequest implement json.Marshaler.

func (*CronDeleteRequest) ProtoMessage 

func (*CronDeleteRequest) ProtoMessage()

func (*CronDeleteRequest) ProtoReflect 

func (x *CronDeleteRequest) ProtoReflect() protoreflect.Message

func (*CronDeleteRequest) Reset 

func (x *CronDeleteRequest) Reset()

func (*CronDeleteRequest) String 

func (x *CronDeleteRequest) String() string

func (*CronDeleteRequest) UnmarshalJSON 

func (m *CronDeleteRequest) UnmarshalJSON(b []byte) error

CronDeleteRequest implement json.Marshaler.

func (*CronDeleteRequest) UnmarshalURLValues 

func (m *CronDeleteRequest) UnmarshalURLValues(prefix string, values url.Values) error

CronDeleteRequest implement urlenc.URLValuesUnmarshaler.

func (*CronDeleteRequest) Validate 

func (this *CronDeleteRequest) Validate() error

type CronDeleteResponse 

type CronDeleteResponse struct {
	// contains filtered or unexported fields
}

func (*CronDeleteResponse) Descriptor deprecated 

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

Deprecated: Use CronDeleteResponse.ProtoReflect.Descriptor instead.

func (*CronDeleteResponse) MarshalJSON 

func (m *CronDeleteResponse) MarshalJSON() ([]byte, error)

CronDeleteResponse implement json.Marshaler.

func (*CronDeleteResponse) ProtoMessage 

func (*CronDeleteResponse) ProtoMessage()

func (*CronDeleteResponse) ProtoReflect 

func (x *CronDeleteResponse) ProtoReflect() protoreflect.Message

func (*CronDeleteResponse) Reset 

func (x *CronDeleteResponse) Reset()

func (*CronDeleteResponse) String 

func (x *CronDeleteResponse) String() string

func (*CronDeleteResponse) UnmarshalJSON 

func (m *CronDeleteResponse) UnmarshalJSON(b []byte) error

CronDeleteResponse implement json.Marshaler.

func (*CronDeleteResponse) UnmarshalURLValues 

func (m *CronDeleteResponse) UnmarshalURLValues(prefix string, values url.Values) error

CronDeleteResponse implement urlenc.URLValuesUnmarshaler.

func (*CronDeleteResponse) Validate 

func (this *CronDeleteResponse) Validate() error

type CronGetRequest 

type CronGetRequest struct {
	CronID uint64 `protobuf:"varint,1,opt,name=cronID,proto3" json:"cronID,omitempty"`
	// contains filtered or unexported fields
}

func (*CronGetRequest) Descriptor deprecated 

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

Deprecated: Use CronGetRequest.ProtoReflect.Descriptor instead.

func (*CronGetRequest) GetCronID 

func (x *CronGetRequest) GetCronID() uint64

func (*CronGetRequest) MarshalJSON 

func (m *CronGetRequest) MarshalJSON() ([]byte, error)

CronGetRequest implement json.Marshaler.

func (*CronGetRequest) ProtoMessage 

func (*CronGetRequest) ProtoMessage()

func (*CronGetRequest) ProtoReflect 

func (x *CronGetRequest) ProtoReflect() protoreflect.Message

func (*CronGetRequest) Reset 

func (x *CronGetRequest) Reset()

func (*CronGetRequest) String 

func (x *CronGetRequest) String() string

func (*CronGetRequest) UnmarshalJSON 

func (m *CronGetRequest) UnmarshalJSON(b []byte) error

CronGetRequest implement json.Marshaler.

func (*CronGetRequest) UnmarshalURLValues 

func (m *CronGetRequest) UnmarshalURLValues(prefix string, values url.Values) error

CronGetRequest implement urlenc.URLValuesUnmarshaler.

func (*CronGetRequest) Validate 

func (this *CronGetRequest) Validate() error

type CronGetResponse 

type CronGetResponse struct {
	Data *Cron `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CronGetResponse) Descriptor deprecated 

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

Deprecated: Use CronGetResponse.ProtoReflect.Descriptor instead.

func (*CronGetResponse) GetData 

func (x *CronGetResponse) GetData() *Cron

func (*CronGetResponse) MarshalJSON 

func (m *CronGetResponse) MarshalJSON() ([]byte, error)

CronGetResponse implement json.Marshaler.

func (*CronGetResponse) ProtoMessage 

func (*CronGetResponse) ProtoMessage()

func (*CronGetResponse) ProtoReflect 

func (x *CronGetResponse) ProtoReflect() protoreflect.Message

func (*CronGetResponse) Reset 

func (x *CronGetResponse) Reset()

func (*CronGetResponse) String 

func (x *CronGetResponse) String() string

func (*CronGetResponse) UnmarshalJSON 

func (m *CronGetResponse) UnmarshalJSON(b []byte) error

CronGetResponse implement json.Marshaler.

func (*CronGetResponse) UnmarshalURLValues 

func (m *CronGetResponse) UnmarshalURLValues(prefix string, values url.Values) error

CronGetResponse implement urlenc.URLValuesUnmarshaler.

func (*CronGetResponse) Validate 

func (this *CronGetResponse) Validate() error

type CronPagingRequest 

type CronPagingRequest struct {
	AllSources bool     `protobuf:"varint,1,opt,name=allSources,proto3" json:"allSources,omitempty"`
	Sources    []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"`   // ?source=cdp-dev&source=cdp-test
	YmlNames   []string `protobuf:"bytes,3,rep,name=ymlNames,proto3" json:"ymlNames,omitempty"` // ?ymlName=11&ymlName=22
	PageSize   int64    `protobuf:"varint,4,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	PageNo     int64    `protobuf:"varint,5,opt,name=pageNo,proto3" json:"pageNo,omitempty"`
	// contains filtered or unexported fields
}

func (*CronPagingRequest) Descriptor deprecated 

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

Deprecated: Use CronPagingRequest.ProtoReflect.Descriptor instead.

func (*CronPagingRequest) GetAllSources 

func (x *CronPagingRequest) GetAllSources() bool

func (*CronPagingRequest) GetPageNo 

func (x *CronPagingRequest) GetPageNo() int64

func (*CronPagingRequest) GetPageSize 

func (x *CronPagingRequest) GetPageSize() int64

func (*CronPagingRequest) GetSources 

func (x *CronPagingRequest) GetSources() []string

func (*CronPagingRequest) GetYmlNames 

func (x *CronPagingRequest) GetYmlNames() []string

func (*CronPagingRequest) MarshalJSON 

func (m *CronPagingRequest) MarshalJSON() ([]byte, error)

CronPagingRequest implement json.Marshaler.

func (*CronPagingRequest) ProtoMessage 

func (*CronPagingRequest) ProtoMessage()

func (*CronPagingRequest) ProtoReflect 

func (x *CronPagingRequest) ProtoReflect() protoreflect.Message

func (*CronPagingRequest) Reset 

func (x *CronPagingRequest) Reset()

func (*CronPagingRequest) String 

func (x *CronPagingRequest) String() string

func (*CronPagingRequest) UnmarshalJSON 

func (m *CronPagingRequest) UnmarshalJSON(b []byte) error

CronPagingRequest implement json.Marshaler.

func (*CronPagingRequest) UnmarshalURLValues 

func (m *CronPagingRequest) UnmarshalURLValues(prefix string, values url.Values) error

CronPagingRequest implement urlenc.URLValuesUnmarshaler.

func (*CronPagingRequest) Validate 

func (this *CronPagingRequest) Validate() error

type CronPagingResponse 

type CronPagingResponse struct {
	Total int64   `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Data  []*Cron `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CronPagingResponse) Descriptor deprecated 

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

Deprecated: Use CronPagingResponse.ProtoReflect.Descriptor instead.

func (*CronPagingResponse) GetData 

func (x *CronPagingResponse) GetData() []*Cron

func (*CronPagingResponse) GetTotal 

func (x *CronPagingResponse) GetTotal() int64

func (*CronPagingResponse) MarshalJSON 

func (m *CronPagingResponse) MarshalJSON() ([]byte, error)

CronPagingResponse implement json.Marshaler.

func (*CronPagingResponse) ProtoMessage 

func (*CronPagingResponse) ProtoMessage()

func (*CronPagingResponse) ProtoReflect 

func (x *CronPagingResponse) ProtoReflect() protoreflect.Message

func (*CronPagingResponse) Reset 

func (x *CronPagingResponse) Reset()

func (*CronPagingResponse) String 

func (x *CronPagingResponse) String() string

func (*CronPagingResponse) UnmarshalJSON 

func (m *CronPagingResponse) UnmarshalJSON(b []byte) error

CronPagingResponse implement json.Marshaler.

func (*CronPagingResponse) UnmarshalURLValues 

func (m *CronPagingResponse) UnmarshalURLValues(prefix string, values url.Values) error

CronPagingResponse implement urlenc.URLValuesUnmarshaler.

func (*CronPagingResponse) Validate 

func (this *CronPagingResponse) Validate() error

type CronServiceClient 

type CronServiceClient interface {
	CronCreate(ctx context.Context, in *CronCreateRequest, opts ...grpc.CallOption) (*CronCreateResponse, error)
	CronPaging(ctx context.Context, in *CronPagingRequest, opts ...grpc.CallOption) (*CronPagingResponse, error)
	CronStart(ctx context.Context, in *CronStartRequest, opts ...grpc.CallOption) (*CronStartResponse, error)
	CronStop(ctx context.Context, in *CronStopRequest, opts ...grpc.CallOption) (*CronStopResponse, error)
	CronDelete(ctx context.Context, in *CronDeleteRequest, opts ...grpc.CallOption) (*CronDeleteResponse, error)
	CronGet(ctx context.Context, in *CronGetRequest, opts ...grpc.CallOption) (*CronGetResponse, error)
	CronUpdate(ctx context.Context, in *CronUpdateRequest, opts ...grpc.CallOption) (*CronUpdateResponse, error)
}

CronServiceClient is the client API for CronService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCronServiceClient 

func NewCronServiceClient(cc grpc1.ClientConnInterface) CronServiceClient

type CronServiceHandler 

type CronServiceHandler interface {
	// POST /api/pipeline-crons
	CronCreate(context.Context, *CronCreateRequest) (*CronCreateResponse, error)
	// GET /api/pipeline-crons
	CronPaging(context.Context, *CronPagingRequest) (*CronPagingResponse, error)
	// PUT /api/pipeline-crons/{cronID}/actions/start
	CronStart(context.Context, *CronStartRequest) (*CronStartResponse, error)
	// PUT /api/pipeline-crons/{cronID}/actions/stop
	CronStop(context.Context, *CronStopRequest) (*CronStopResponse, error)
	// DELETE /api/pipeline-crons/{cronID}
	CronDelete(context.Context, *CronDeleteRequest) (*CronDeleteResponse, error)
	// GET /api/pipeline-crons/{cronID}
	CronGet(context.Context, *CronGetRequest) (*CronGetResponse, error)
	// PUT /api/pipeline-crons/{cronID}
	CronUpdate(context.Context, *CronUpdateRequest) (*CronUpdateResponse, error)
}

CronServiceHandler is the server API for CronService service.

type CronServiceServer 

type CronServiceServer interface {
	CronCreate(context.Context, *CronCreateRequest) (*CronCreateResponse, error)
	CronPaging(context.Context, *CronPagingRequest) (*CronPagingResponse, error)
	CronStart(context.Context, *CronStartRequest) (*CronStartResponse, error)
	CronStop(context.Context, *CronStopRequest) (*CronStopResponse, error)
	CronDelete(context.Context, *CronDeleteRequest) (*CronDeleteResponse, error)
	CronGet(context.Context, *CronGetRequest) (*CronGetResponse, error)
	CronUpdate(context.Context, *CronUpdateRequest) (*CronUpdateResponse, error)
}

CronServiceServer is the server API for CronService service. All implementations should embed UnimplementedCronServiceServer for forward compatibility

type CronStartRequest 

type CronStartRequest struct {
	CronID uint64 `protobuf:"varint,1,opt,name=cronID,proto3" json:"cronID,omitempty"`
	// contains filtered or unexported fields
}

func (*CronStartRequest) Descriptor deprecated 

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

Deprecated: Use CronStartRequest.ProtoReflect.Descriptor instead.

func (*CronStartRequest) GetCronID 

func (x *CronStartRequest) GetCronID() uint64

func (*CronStartRequest) MarshalJSON 

func (m *CronStartRequest) MarshalJSON() ([]byte, error)

CronStartRequest implement json.Marshaler.

func (*CronStartRequest) ProtoMessage 

func (*CronStartRequest) ProtoMessage()

func (*CronStartRequest) ProtoReflect 

func (x *CronStartRequest) ProtoReflect() protoreflect.Message

func (*CronStartRequest) Reset 

func (x *CronStartRequest) Reset()

func (*CronStartRequest) String 

func (x *CronStartRequest) String() string

func (*CronStartRequest) UnmarshalJSON 

func (m *CronStartRequest) UnmarshalJSON(b []byte) error

CronStartRequest implement json.Marshaler.

func (*CronStartRequest) UnmarshalURLValues 

func (m *CronStartRequest) UnmarshalURLValues(prefix string, values url.Values) error

CronStartRequest implement urlenc.URLValuesUnmarshaler.

func (*CronStartRequest) Validate 

func (this *CronStartRequest) Validate() error

type CronStartResponse 

type CronStartResponse struct {
	Data *Cron `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CronStartResponse) Descriptor deprecated 

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

Deprecated: Use CronStartResponse.ProtoReflect.Descriptor instead.

func (*CronStartResponse) GetData 

func (x *CronStartResponse) GetData() *Cron

func (*CronStartResponse) MarshalJSON 

func (m *CronStartResponse) MarshalJSON() ([]byte, error)

CronStartResponse implement json.Marshaler.

func (*CronStartResponse) ProtoMessage 

func (*CronStartResponse) ProtoMessage()

func (*CronStartResponse) ProtoReflect 

func (x *CronStartResponse) ProtoReflect() protoreflect.Message

func (*CronStartResponse) Reset 

func (x *CronStartResponse) Reset()

func (*CronStartResponse) String 

func (x *CronStartResponse) String() string

func (*CronStartResponse) UnmarshalJSON 

func (m *CronStartResponse) UnmarshalJSON(b []byte) error

CronStartResponse implement json.Marshaler.

func (*CronStartResponse) UnmarshalURLValues 

func (m *CronStartResponse) UnmarshalURLValues(prefix string, values url.Values) error

CronStartResponse implement urlenc.URLValuesUnmarshaler.

func (*CronStartResponse) Validate 

func (this *CronStartResponse) Validate() error

type CronStopRequest 

type CronStopRequest struct {
	CronID uint64 `protobuf:"varint,1,opt,name=cronID,proto3" json:"cronID,omitempty"`
	// contains filtered or unexported fields
}

func (*CronStopRequest) Descriptor deprecated 

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

Deprecated: Use CronStopRequest.ProtoReflect.Descriptor instead.

func (*CronStopRequest) GetCronID 

func (x *CronStopRequest) GetCronID() uint64

func (*CronStopRequest) MarshalJSON 

func (m *CronStopRequest) MarshalJSON() ([]byte, error)

CronStopRequest implement json.Marshaler.

func (*CronStopRequest) ProtoMessage 

func (*CronStopRequest) ProtoMessage()

func (*CronStopRequest) ProtoReflect 

func (x *CronStopRequest) ProtoReflect() protoreflect.Message

func (*CronStopRequest) Reset 

func (x *CronStopRequest) Reset()

func (*CronStopRequest) String 

func (x *CronStopRequest) String() string

func (*CronStopRequest) UnmarshalJSON 

func (m *CronStopRequest) UnmarshalJSON(b []byte) error

CronStopRequest implement json.Marshaler.

func (*CronStopRequest) UnmarshalURLValues 

func (m *CronStopRequest) UnmarshalURLValues(prefix string, values url.Values) error

CronStopRequest implement urlenc.URLValuesUnmarshaler.

func (*CronStopRequest) Validate 

func (this *CronStopRequest) Validate() error

type CronStopResponse 

type CronStopResponse struct {
	Data *Cron `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CronStopResponse) Descriptor deprecated 

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

Deprecated: Use CronStopResponse.ProtoReflect.Descriptor instead.

func (*CronStopResponse) GetData 

func (x *CronStopResponse) GetData() *Cron

func (*CronStopResponse) MarshalJSON 

func (m *CronStopResponse) MarshalJSON() ([]byte, error)

CronStopResponse implement json.Marshaler.

func (*CronStopResponse) ProtoMessage 

func (*CronStopResponse) ProtoMessage()

func (*CronStopResponse) ProtoReflect 

func (x *CronStopResponse) ProtoReflect() protoreflect.Message

func (*CronStopResponse) Reset 

func (x *CronStopResponse) Reset()

func (*CronStopResponse) String 

func (x *CronStopResponse) String() string

func (*CronStopResponse) UnmarshalJSON 

func (m *CronStopResponse) UnmarshalJSON(b []byte) error

CronStopResponse implement json.Marshaler.

func (*CronStopResponse) UnmarshalURLValues 

func (m *CronStopResponse) UnmarshalURLValues(prefix string, values url.Values) error

CronStopResponse implement urlenc.URLValuesUnmarshaler.

func (*CronStopResponse) Validate 

func (this *CronStopResponse) Validate() error

type CronUpdateRequest 

type CronUpdateRequest struct {
	CronID      uint64 `protobuf:"varint,1,opt,name=cronID,proto3" json:"cronID,omitempty"`
	Id          uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	PipelineYml string `protobuf:"bytes,3,opt,name=pipelineYml,proto3" json:"pipelineYml,omitempty"`
	CronExpr    string `protobuf:"bytes,4,opt,name=cronExpr,proto3" json:"cronExpr,omitempty"`
	// contains filtered or unexported fields
}

func (*CronUpdateRequest) Descriptor deprecated 

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

Deprecated: Use CronUpdateRequest.ProtoReflect.Descriptor instead.

func (*CronUpdateRequest) GetCronExpr 

func (x *CronUpdateRequest) GetCronExpr() string

func (*CronUpdateRequest) GetCronID 

func (x *CronUpdateRequest) GetCronID() uint64

func (*CronUpdateRequest) GetId 

func (x *CronUpdateRequest) GetId() uint64

func (*CronUpdateRequest) GetPipelineYml 

func (x *CronUpdateRequest) GetPipelineYml() string

func (*CronUpdateRequest) MarshalJSON 

func (m *CronUpdateRequest) MarshalJSON() ([]byte, error)

CronUpdateRequest implement json.Marshaler.

func (*CronUpdateRequest) ProtoMessage 

func (*CronUpdateRequest) ProtoMessage()

func (*CronUpdateRequest) ProtoReflect 

func (x *CronUpdateRequest) ProtoReflect() protoreflect.Message

func (*CronUpdateRequest) Reset 

func (x *CronUpdateRequest) Reset()

func (*CronUpdateRequest) String 

func (x *CronUpdateRequest) String() string

func (*CronUpdateRequest) UnmarshalJSON 

func (m *CronUpdateRequest) UnmarshalJSON(b []byte) error

CronUpdateRequest implement json.Marshaler.

func (*CronUpdateRequest) UnmarshalURLValues 

func (m *CronUpdateRequest) UnmarshalURLValues(prefix string, values url.Values) error

CronUpdateRequest implement urlenc.URLValuesUnmarshaler.

func (*CronUpdateRequest) Validate 

func (this *CronUpdateRequest) Validate() error

type CronUpdateResponse 

type CronUpdateResponse struct {
	// contains filtered or unexported fields
}

func (*CronUpdateResponse) Descriptor deprecated 

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

Deprecated: Use CronUpdateResponse.ProtoReflect.Descriptor instead.

func (*CronUpdateResponse) MarshalJSON 

func (m *CronUpdateResponse) MarshalJSON() ([]byte, error)

CronUpdateResponse implement json.Marshaler.

func (*CronUpdateResponse) ProtoMessage 

func (*CronUpdateResponse) ProtoMessage()

func (*CronUpdateResponse) ProtoReflect 

func (x *CronUpdateResponse) ProtoReflect() protoreflect.Message

func (*CronUpdateResponse) Reset 

func (x *CronUpdateResponse) Reset()

func (*CronUpdateResponse) String 

func (x *CronUpdateResponse) String() string

func (*CronUpdateResponse) UnmarshalJSON 

func (m *CronUpdateResponse) UnmarshalJSON(b []byte) error

CronUpdateResponse implement json.Marshaler.

func (*CronUpdateResponse) UnmarshalURLValues 

func (m *CronUpdateResponse) UnmarshalURLValues(prefix string, values url.Values) error

CronUpdateResponse implement urlenc.URLValuesUnmarshaler.

func (*CronUpdateResponse) Validate 

func (this *CronUpdateResponse) Validate() error

type UnimplementedCronServiceServer 

type UnimplementedCronServiceServer struct {
}

UnimplementedCronServiceServer should be embedded to have forward compatible implementations.

func (*UnimplementedCronServiceServer) CronCreate 

func (*UnimplementedCronServiceServer) CronCreate(context.Context, *CronCreateRequest) (*CronCreateResponse, error)

func (*UnimplementedCronServiceServer) CronDelete 

func (*UnimplementedCronServiceServer) CronDelete(context.Context, *CronDeleteRequest) (*CronDeleteResponse, error)

func (*UnimplementedCronServiceServer) CronGet 

func (*UnimplementedCronServiceServer) CronGet(context.Context, *CronGetRequest) (*CronGetResponse, error)

func (*UnimplementedCronServiceServer) CronPaging 

func (*UnimplementedCronServiceServer) CronPaging(context.Context, *CronPagingRequest) (*CronPagingResponse, error)

func (*UnimplementedCronServiceServer) CronStart 

func (*UnimplementedCronServiceServer) CronStart(context.Context, *CronStartRequest) (*CronStartResponse, error)

func (*UnimplementedCronServiceServer) CronStop 

func (*UnimplementedCronServiceServer) CronStop(context.Context, *CronStopRequest) (*CronStopResponse, error)

func (*UnimplementedCronServiceServer) CronUpdate 

func (*UnimplementedCronServiceServer) CronUpdate(context.Context, *CronUpdateRequest) (*CronUpdateResponse, 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.