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: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_queue_proto protoreflect.FileDescriptor

Functions

func QueueServiceClientType 

func QueueServiceClientType() reflect.Type

QueueServiceClientType .

func QueueServiceHandlerType 

func QueueServiceHandlerType() reflect.Type

QueueServiceHandlerType .

func QueueServiceServerType 

func QueueServiceServerType() reflect.Type

QueueServiceServerType .

func RegisterQueueServiceHandler 

func RegisterQueueServiceHandler(r http.Router, srv QueueServiceHandler, opts ...http.HandleOption)

RegisterQueueServiceHandler register QueueServiceHandler to http.Router.

func RegisterQueueServiceImp 

func RegisterQueueServiceImp(regester transport.Register, srv QueueServiceServer, opts ...transport.ServiceOption)

RegisterQueueServiceImp queue.proto

func RegisterQueueServiceServer 

func RegisterQueueServiceServer(s grpc1.ServiceRegistrar, srv QueueServiceServer, opts ...grpc1.HandleOption)

func ServiceNames 

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

ServiceNames return all service names

func Types 

func Types() []reflect.Type

Types

type Queue 

type Queue struct {
	ID               uint64                 `protobuf:"varint,1,opt,name=ID,json=id,proto3" json:"ID,omitempty"`
	Name             string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	PipelineSource   string                 `protobuf:"bytes,3,opt,name=pipelineSource,proto3" json:"pipelineSource,omitempty"`
	ClusterName      string                 `protobuf:"bytes,4,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	ScheduleStrategy string                 `protobuf:"bytes,5,opt,name=scheduleStrategy,proto3" json:"scheduleStrategy,omitempty"`
	Mode             string                 `protobuf:"bytes,6,opt,name=mode,proto3" json:"mode,omitempty"`
	Priority         int64                  `protobuf:"varint,7,opt,name=priority,proto3" json:"priority,omitempty"`
	Concurrency      int64                  `protobuf:"varint,8,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	MaxCPU           float64                `protobuf:"fixed64,9,opt,name=maxCPU,proto3" json:"maxCPU,omitempty"`
	MaxMemoryMB      float64                `protobuf:"fixed64,10,opt,name=maxMemoryMB,proto3" json:"maxMemoryMB,omitempty"`
	Labels           map[string]string      `` /* 154-byte string literal not displayed */
	TimeCreated      *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=timeCreated,proto3" json:"timeCreated,omitempty"`
	TimeUpdated      *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=timeUpdated,proto3" json:"timeUpdated,omitempty"`
	Usage            *QueueUsage            `protobuf:"bytes,14,opt,name=usage,proto3" json:"usage,omitempty"`
	// contains filtered or unexported fields
}

func (*Queue) Descriptor deprecated 

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

Deprecated: Use Queue.ProtoReflect.Descriptor instead.

func (*Queue) GetClusterName 

func (x *Queue) GetClusterName() string

func (*Queue) GetConcurrency 

func (x *Queue) GetConcurrency() int64

func (*Queue) GetID 

func (x *Queue) GetID() uint64

func (*Queue) GetLabels 

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

func (*Queue) GetMaxCPU 

func (x *Queue) GetMaxCPU() float64

func (*Queue) GetMaxMemoryMB 

func (x *Queue) GetMaxMemoryMB() float64

func (*Queue) GetMode 

func (x *Queue) GetMode() string

func (*Queue) GetName 

func (x *Queue) GetName() string

func (*Queue) GetPipelineSource 

func (x *Queue) GetPipelineSource() string

func (*Queue) GetPriority 

func (x *Queue) GetPriority() int64

func (*Queue) GetScheduleStrategy 

func (x *Queue) GetScheduleStrategy() string

func (*Queue) GetTimeCreated 

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

func (*Queue) GetTimeUpdated 

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

func (*Queue) GetUsage 

func (x *Queue) GetUsage() *QueueUsage

func (*Queue) MarshalJSON 

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

Queue implement json.Marshaler.

func (*Queue) ProtoMessage 

func (*Queue) ProtoMessage()

func (*Queue) ProtoReflect 

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

func (*Queue) Reset 

func (x *Queue) Reset()

func (*Queue) String 

func (x *Queue) String() string

func (*Queue) UnmarshalJSON 

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

Queue implement json.Marshaler.

func (*Queue) UnmarshalURLValues 

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

Queue implement urlenc.URLValuesUnmarshaler.

func (*Queue) Validate 

func (this *Queue) Validate() error

type QueueCreateRequest 

type QueueCreateRequest struct {

	// Name is the queue name.
	// +required
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// PipelineSource group queues by source.
	// +required
	PipelineSource string `protobuf:"bytes,2,opt,name=pipelineSource,proto3" json:"pipelineSource,omitempty"`
	// ClusterName represents which cluster this queue belongs to.
	// +required
	ClusterName string `protobuf:"bytes,3,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	// ScheduleStrategy defines schedule strategy.
	// If not present, will use default strategy.
	// +optional
	ScheduleStrategy string `protobuf:"bytes,4,opt,name=scheduleStrategy,proto3" json:"scheduleStrategy,omitempty"`
	// Mode defines queue mode.
	// If not present, will use default mode.
	// +optional
	Mode string `protobuf:"bytes,5,opt,name=mode,proto3" json:"mode,omitempty"`
	// Priority defines item default priority inside queues.
	// Higher number means higher priority.
	// If not present, will use default priority.
	// +optional
	Priority int64 `protobuf:"varint,6,opt,name=priority,proto3" json:"priority,omitempty"`
	// Concurrency defines how many item can running at the same time.
	// If not present, will use default concurrency.
	// +optional
	Concurrency int64 `protobuf:"varint,7,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	// MaxCPU is the cpu resource this queue holds.
	// +optional
	MaxCPU float64 `protobuf:"fixed64,8,opt,name=maxCPU,proto3" json:"maxCPU,omitempty"`
	// MaxMemoryMB is the memory resource this queue holds.
	// +optional
	MaxMemoryMB float64 `protobuf:"fixed64,9,opt,name=maxMemoryMB,proto3" json:"maxMemoryMB,omitempty"`
	// Labels contains the other infos for this queue.
	// Labels can be used to query and filter queues.
	// +optional
	Labels       map[string]string `` /* 154-byte string literal not displayed */
	IdentityInfo *pb.IdentityInfo  `protobuf:"bytes,11,opt,name=identityInfo,proto3" json:"identityInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueCreateRequest) Descriptor deprecated 

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

Deprecated: Use QueueCreateRequest.ProtoReflect.Descriptor instead.

func (*QueueCreateRequest) GetClusterName 

func (x *QueueCreateRequest) GetClusterName() string

func (*QueueCreateRequest) GetConcurrency 

func (x *QueueCreateRequest) GetConcurrency() int64

func (*QueueCreateRequest) GetIdentityInfo 

func (x *QueueCreateRequest) GetIdentityInfo() *pb.IdentityInfo

func (*QueueCreateRequest) GetLabels 

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

func (*QueueCreateRequest) GetMaxCPU 

func (x *QueueCreateRequest) GetMaxCPU() float64

func (*QueueCreateRequest) GetMaxMemoryMB 

func (x *QueueCreateRequest) GetMaxMemoryMB() float64

func (*QueueCreateRequest) GetMode 

func (x *QueueCreateRequest) GetMode() string

func (*QueueCreateRequest) GetName 

func (x *QueueCreateRequest) GetName() string

func (*QueueCreateRequest) GetPipelineSource 

func (x *QueueCreateRequest) GetPipelineSource() string

func (*QueueCreateRequest) GetPriority 

func (x *QueueCreateRequest) GetPriority() int64

func (*QueueCreateRequest) GetScheduleStrategy 

func (x *QueueCreateRequest) GetScheduleStrategy() string

func (*QueueCreateRequest) MarshalJSON 

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

QueueCreateRequest implement json.Marshaler.

func (*QueueCreateRequest) ProtoMessage 

func (*QueueCreateRequest) ProtoMessage()

func (*QueueCreateRequest) ProtoReflect 

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

func (*QueueCreateRequest) Reset 

func (x *QueueCreateRequest) Reset()

func (*QueueCreateRequest) String 

func (x *QueueCreateRequest) String() string

func (*QueueCreateRequest) UnmarshalJSON 

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

QueueCreateRequest implement json.Marshaler.

func (*QueueCreateRequest) UnmarshalURLValues 

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

QueueCreateRequest implement urlenc.URLValuesUnmarshaler.

func (*QueueCreateRequest) Validate 

func (this *QueueCreateRequest) Validate() error

type QueueCreateResponse 

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

func (*QueueCreateResponse) Descriptor deprecated 

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

Deprecated: Use QueueCreateResponse.ProtoReflect.Descriptor instead.

func (*QueueCreateResponse) GetData 

func (x *QueueCreateResponse) GetData() *Queue

func (*QueueCreateResponse) MarshalJSON 

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

QueueCreateResponse implement json.Marshaler.

func (*QueueCreateResponse) ProtoMessage 

func (*QueueCreateResponse) ProtoMessage()

func (*QueueCreateResponse) ProtoReflect 

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

func (*QueueCreateResponse) Reset 

func (x *QueueCreateResponse) Reset()

func (*QueueCreateResponse) String 

func (x *QueueCreateResponse) String() string

func (*QueueCreateResponse) UnmarshalJSON 

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

QueueCreateResponse implement json.Marshaler.

func (*QueueCreateResponse) UnmarshalURLValues 

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

QueueCreateResponse implement urlenc.URLValuesUnmarshaler.

func (*QueueCreateResponse) Validate 

func (this *QueueCreateResponse) Validate() error

type QueueDeleteRequest 

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

func (*QueueDeleteRequest) Descriptor deprecated 

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

Deprecated: Use QueueDeleteRequest.ProtoReflect.Descriptor instead.

func (*QueueDeleteRequest) GetQueueID 

func (x *QueueDeleteRequest) GetQueueID() uint64

func (*QueueDeleteRequest) MarshalJSON 

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

QueueDeleteRequest implement json.Marshaler.

func (*QueueDeleteRequest) ProtoMessage 

func (*QueueDeleteRequest) ProtoMessage()

func (*QueueDeleteRequest) ProtoReflect 

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

func (*QueueDeleteRequest) Reset 

func (x *QueueDeleteRequest) Reset()

func (*QueueDeleteRequest) String 

func (x *QueueDeleteRequest) String() string

func (*QueueDeleteRequest) UnmarshalJSON 

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

QueueDeleteRequest implement json.Marshaler.

func (*QueueDeleteRequest) UnmarshalURLValues 

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

QueueDeleteRequest implement urlenc.URLValuesUnmarshaler.

func (*QueueDeleteRequest) Validate 

func (this *QueueDeleteRequest) Validate() error

type QueueDeleteResponse 

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

func (*QueueDeleteResponse) Descriptor deprecated 

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

Deprecated: Use QueueDeleteResponse.ProtoReflect.Descriptor instead.

func (*QueueDeleteResponse) MarshalJSON 

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

QueueDeleteResponse implement json.Marshaler.

func (*QueueDeleteResponse) ProtoMessage 

func (*QueueDeleteResponse) ProtoMessage()

func (*QueueDeleteResponse) ProtoReflect 

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

func (*QueueDeleteResponse) Reset 

func (x *QueueDeleteResponse) Reset()

func (*QueueDeleteResponse) String 

func (x *QueueDeleteResponse) String() string

func (*QueueDeleteResponse) UnmarshalJSON 

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

QueueDeleteResponse implement json.Marshaler.

func (*QueueDeleteResponse) UnmarshalURLValues 

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

QueueDeleteResponse implement urlenc.URLValuesUnmarshaler.

func (*QueueDeleteResponse) Validate 

func (this *QueueDeleteResponse) Validate() error

type QueueGetRequest 

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

func (*QueueGetRequest) Descriptor deprecated 

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

Deprecated: Use QueueGetRequest.ProtoReflect.Descriptor instead.

func (*QueueGetRequest) GetQueueID 

func (x *QueueGetRequest) GetQueueID() uint64

func (*QueueGetRequest) MarshalJSON 

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

QueueGetRequest implement json.Marshaler.

func (*QueueGetRequest) ProtoMessage 

func (*QueueGetRequest) ProtoMessage()

func (*QueueGetRequest) ProtoReflect 

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

func (*QueueGetRequest) Reset 

func (x *QueueGetRequest) Reset()

func (*QueueGetRequest) String 

func (x *QueueGetRequest) String() string

func (*QueueGetRequest) UnmarshalJSON 

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

QueueGetRequest implement json.Marshaler.

func (*QueueGetRequest) UnmarshalURLValues 

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

QueueGetRequest implement urlenc.URLValuesUnmarshaler.

func (*QueueGetRequest) Validate 

func (this *QueueGetRequest) Validate() error

type QueueGetResponse 

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

func (*QueueGetResponse) Descriptor deprecated 

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

Deprecated: Use QueueGetResponse.ProtoReflect.Descriptor instead.

func (*QueueGetResponse) GetData 

func (x *QueueGetResponse) GetData() *Queue

func (*QueueGetResponse) MarshalJSON 

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

QueueGetResponse implement json.Marshaler.

func (*QueueGetResponse) ProtoMessage 

func (*QueueGetResponse) ProtoMessage()

func (*QueueGetResponse) ProtoReflect 

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

func (*QueueGetResponse) Reset 

func (x *QueueGetResponse) Reset()

func (*QueueGetResponse) String 

func (x *QueueGetResponse) String() string

func (*QueueGetResponse) UnmarshalJSON 

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

QueueGetResponse implement json.Marshaler.

func (*QueueGetResponse) UnmarshalURLValues 

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

QueueGetResponse implement urlenc.URLValuesUnmarshaler.

func (*QueueGetResponse) Validate 

func (this *QueueGetResponse) Validate() error

type QueuePagingRequest 

type QueuePagingRequest struct {
	Name             string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PipelineSources  []string `protobuf:"bytes,2,rep,name=pipelineSources,proto3" json:"pipelineSources,omitempty"`
	ClusterName      string   `protobuf:"bytes,3,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	ScheduleStrategy string   `protobuf:"bytes,4,opt,name=scheduleStrategy,proto3" json:"scheduleStrategy,omitempty"`
	Priority         int64    `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"`
	Concurrency      int64    `protobuf:"varint,6,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	// MUST match
	MustMatchLabels []string `protobuf:"bytes,7,rep,name=mustMatchLabels,proto3" json:"mustMatchLabels,omitempty"`
	// ANY match
	AnyMatchLabels []string `protobuf:"bytes,8,rep,name=anyMatchLabels,proto3" json:"anyMatchLabels,omitempty"`
	// AllowNoPipelineSources, default is false.
	// 默认查询必须带上 pipeline source，增加区分度
	AllowNoPipelineSources bool `protobuf:"varint,9,opt,name=allowNoPipelineSources,proto3" json:"allowNoPipelineSources,omitempty"`
	// OrderByTargetIDAsc 根据 target_id 升序，默认为 false，即降序
	OrderByTargetIDAsc bool  `protobuf:"varint,10,opt,name=orderByTargetIDAsc,proto3" json:"orderByTargetIDAsc,omitempty"`
	PageNo             int64 `protobuf:"varint,11,opt,name=pageNo,proto3" json:"pageNo,omitempty"`
	PageSize           int64 `protobuf:"varint,12,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	// contains filtered or unexported fields
}

func (*QueuePagingRequest) Descriptor deprecated 

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

Deprecated: Use QueuePagingRequest.ProtoReflect.Descriptor instead.

func (*QueuePagingRequest) GetAllowNoPipelineSources 

func (x *QueuePagingRequest) GetAllowNoPipelineSources() bool

func (*QueuePagingRequest) GetAnyMatchLabels 

func (x *QueuePagingRequest) GetAnyMatchLabels() []string

func (*QueuePagingRequest) GetClusterName 

func (x *QueuePagingRequest) GetClusterName() string

func (*QueuePagingRequest) GetConcurrency 

func (x *QueuePagingRequest) GetConcurrency() int64

func (*QueuePagingRequest) GetMustMatchLabels 

func (x *QueuePagingRequest) GetMustMatchLabels() []string

func (*QueuePagingRequest) GetName 

func (x *QueuePagingRequest) GetName() string

func (*QueuePagingRequest) GetOrderByTargetIDAsc 

func (x *QueuePagingRequest) GetOrderByTargetIDAsc() bool

func (*QueuePagingRequest) GetPageNo 

func (x *QueuePagingRequest) GetPageNo() int64

func (*QueuePagingRequest) GetPageSize 

func (x *QueuePagingRequest) GetPageSize() int64

func (*QueuePagingRequest) GetPipelineSources 

func (x *QueuePagingRequest) GetPipelineSources() []string

func (*QueuePagingRequest) GetPriority 

func (x *QueuePagingRequest) GetPriority() int64

func (*QueuePagingRequest) GetScheduleStrategy 

func (x *QueuePagingRequest) GetScheduleStrategy() string

func (*QueuePagingRequest) MarshalJSON 

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

QueuePagingRequest implement json.Marshaler.

func (*QueuePagingRequest) ProtoMessage 

func (*QueuePagingRequest) ProtoMessage()

func (*QueuePagingRequest) ProtoReflect 

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

func (*QueuePagingRequest) Reset 

func (x *QueuePagingRequest) Reset()

func (*QueuePagingRequest) String 

func (x *QueuePagingRequest) String() string

func (*QueuePagingRequest) UnmarshalJSON 

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

QueuePagingRequest implement json.Marshaler.

func (*QueuePagingRequest) UnmarshalURLValues 

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

QueuePagingRequest implement urlenc.URLValuesUnmarshaler.

func (*QueuePagingRequest) Validate 

func (this *QueuePagingRequest) Validate() error

type QueuePagingResponse 

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

func (*QueuePagingResponse) Descriptor deprecated 

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

Deprecated: Use QueuePagingResponse.ProtoReflect.Descriptor instead.

func (*QueuePagingResponse) GetQueues 

func (x *QueuePagingResponse) GetQueues() []*Queue

func (*QueuePagingResponse) GetTotal 

func (x *QueuePagingResponse) GetTotal() int64

func (*QueuePagingResponse) MarshalJSON 

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

QueuePagingResponse implement json.Marshaler.

func (*QueuePagingResponse) ProtoMessage 

func (*QueuePagingResponse) ProtoMessage()

func (*QueuePagingResponse) ProtoReflect 

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

func (*QueuePagingResponse) Reset 

func (x *QueuePagingResponse) Reset()

func (*QueuePagingResponse) String 

func (x *QueuePagingResponse) String() string

func (*QueuePagingResponse) UnmarshalJSON 

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

QueuePagingResponse implement json.Marshaler.

func (*QueuePagingResponse) UnmarshalURLValues 

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

QueuePagingResponse implement urlenc.URLValuesUnmarshaler.

func (*QueuePagingResponse) Validate 

func (this *QueuePagingResponse) Validate() error

type QueueServiceClient 

type QueueServiceClient interface {
	CreateQueue(ctx context.Context, in *QueueCreateRequest, opts ...grpc.CallOption) (*QueueCreateResponse, error)
	GetQueue(ctx context.Context, in *QueueGetRequest, opts ...grpc.CallOption) (*QueueGetResponse, error)
	PagingQueue(ctx context.Context, in *QueuePagingRequest, opts ...grpc.CallOption) (*QueuePagingResponse, error)
	UpdateQueue(ctx context.Context, in *QueueUpdateRequest, opts ...grpc.CallOption) (*QueueUpdateResponse, error)
	DeleteQueue(ctx context.Context, in *QueueDeleteRequest, opts ...grpc.CallOption) (*QueueDeleteResponse, error)
}

QueueServiceClient is the client API for QueueService 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 NewQueueServiceClient 

func NewQueueServiceClient(cc grpc1.ClientConnInterface) QueueServiceClient

type QueueServiceHandler 

type QueueServiceHandler interface {
	// POST /api/pipeline-queues
	CreateQueue(context.Context, *QueueCreateRequest) (*QueueCreateResponse, error)
	// GET /api/pipeline-queues/{queueID}
	GetQueue(context.Context, *QueueGetRequest) (*QueueGetResponse, error)
	// GET /api/pipeline-queues
	PagingQueue(context.Context, *QueuePagingRequest) (*QueuePagingResponse, error)
	// PUT /api/pipeline-queues/{queueID}
	UpdateQueue(context.Context, *QueueUpdateRequest) (*QueueUpdateResponse, error)
	// DELETE /api/pipeline-queues/{queueID}
	DeleteQueue(context.Context, *QueueDeleteRequest) (*QueueDeleteResponse, error)
}

QueueServiceHandler is the server API for QueueService service.

type QueueServiceServer 

type QueueServiceServer interface {
	CreateQueue(context.Context, *QueueCreateRequest) (*QueueCreateResponse, error)
	GetQueue(context.Context, *QueueGetRequest) (*QueueGetResponse, error)
	PagingQueue(context.Context, *QueuePagingRequest) (*QueuePagingResponse, error)
	UpdateQueue(context.Context, *QueueUpdateRequest) (*QueueUpdateResponse, error)
	DeleteQueue(context.Context, *QueueDeleteRequest) (*QueueDeleteResponse, error)
}

QueueServiceServer is the server API for QueueService service. All implementations should embed UnimplementedQueueServiceServer for forward compatibility

type QueueUpdateRequest 

type QueueUpdateRequest struct {
	QueueID          uint64            `protobuf:"varint,1,opt,name=queueID,proto3" json:"queueID,omitempty"`
	Name             string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	PipelineSource   string            `protobuf:"bytes,3,opt,name=pipelineSource,proto3" json:"pipelineSource,omitempty"`
	ClusterName      string            `protobuf:"bytes,4,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
	ScheduleStrategy string            `protobuf:"bytes,5,opt,name=scheduleStrategy,proto3" json:"scheduleStrategy,omitempty"`
	Mode             string            `protobuf:"bytes,6,opt,name=mode,proto3" json:"mode,omitempty"`
	Priority         int64             `protobuf:"varint,7,opt,name=priority,proto3" json:"priority,omitempty"`
	Concurrency      int64             `protobuf:"varint,8,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	MaxCPU           float64           `protobuf:"fixed64,9,opt,name=maxCPU,proto3" json:"maxCPU,omitempty"`
	MaxMemoryMB      float64           `protobuf:"fixed64,10,opt,name=maxMemoryMB,proto3" json:"maxMemoryMB,omitempty"`
	Labels           map[string]string `` /* 154-byte string literal not displayed */
	IdentityInfo     *pb.IdentityInfo  `protobuf:"bytes,12,opt,name=identityInfo,proto3" json:"identityInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueUpdateRequest) Descriptor deprecated 

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

Deprecated: Use QueueUpdateRequest.ProtoReflect.Descriptor instead.

func (*QueueUpdateRequest) GetClusterName 

func (x *QueueUpdateRequest) GetClusterName() string

func (*QueueUpdateRequest) GetConcurrency 

func (x *QueueUpdateRequest) GetConcurrency() int64

func (*QueueUpdateRequest) GetIdentityInfo 

func (x *QueueUpdateRequest) GetIdentityInfo() *pb.IdentityInfo

func (*QueueUpdateRequest) GetLabels 

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

func (*QueueUpdateRequest) GetMaxCPU 

func (x *QueueUpdateRequest) GetMaxCPU() float64

func (*QueueUpdateRequest) GetMaxMemoryMB 

func (x *QueueUpdateRequest) GetMaxMemoryMB() float64

func (*QueueUpdateRequest) GetMode 

func (x *QueueUpdateRequest) GetMode() string

func (*QueueUpdateRequest) GetName 

func (x *QueueUpdateRequest) GetName() string

func (*QueueUpdateRequest) GetPipelineSource 

func (x *QueueUpdateRequest) GetPipelineSource() string

func (*QueueUpdateRequest) GetPriority 

func (x *QueueUpdateRequest) GetPriority() int64

func (*QueueUpdateRequest) GetQueueID 

func (x *QueueUpdateRequest) GetQueueID() uint64

func (*QueueUpdateRequest) GetScheduleStrategy 

func (x *QueueUpdateRequest) GetScheduleStrategy() string

func (*QueueUpdateRequest) MarshalJSON 

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

QueueUpdateRequest implement json.Marshaler.

func (*QueueUpdateRequest) ProtoMessage 

func (*QueueUpdateRequest) ProtoMessage()

func (*QueueUpdateRequest) ProtoReflect 

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

func (*QueueUpdateRequest) Reset 

func (x *QueueUpdateRequest) Reset()

func (*QueueUpdateRequest) String 

func (x *QueueUpdateRequest) String() string

func (*QueueUpdateRequest) UnmarshalJSON 

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

QueueUpdateRequest implement json.Marshaler.

func (*QueueUpdateRequest) UnmarshalURLValues 

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

QueueUpdateRequest implement urlenc.URLValuesUnmarshaler.

func (*QueueUpdateRequest) Validate 

func (this *QueueUpdateRequest) Validate() error

type QueueUpdateResponse 

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

func (*QueueUpdateResponse) Descriptor deprecated 

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

Deprecated: Use QueueUpdateResponse.ProtoReflect.Descriptor instead.

func (*QueueUpdateResponse) GetData 

func (x *QueueUpdateResponse) GetData() *Queue

func (*QueueUpdateResponse) MarshalJSON 

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

QueueUpdateResponse implement json.Marshaler.

func (*QueueUpdateResponse) ProtoMessage 

func (*QueueUpdateResponse) ProtoMessage()

func (*QueueUpdateResponse) ProtoReflect 

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

func (*QueueUpdateResponse) Reset 

func (x *QueueUpdateResponse) Reset()

func (*QueueUpdateResponse) String 

func (x *QueueUpdateResponse) String() string

func (*QueueUpdateResponse) UnmarshalJSON 

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

QueueUpdateResponse implement json.Marshaler.

func (*QueueUpdateResponse) UnmarshalURLValues 

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

QueueUpdateResponse implement urlenc.URLValuesUnmarshaler.

func (*QueueUpdateResponse) Validate 

func (this *QueueUpdateResponse) Validate() error

type QueueUsage 

type QueueUsage struct {
	InUseCPU          float64           `protobuf:"fixed64,1,opt,name=inUseCPU,proto3" json:"inUseCPU,omitempty"`
	InUseMemoryMB     float64           `protobuf:"fixed64,2,opt,name=inUseMemoryMB,proto3" json:"inUseMemoryMB,omitempty"`
	RemainingCPU      float64           `protobuf:"fixed64,3,opt,name=remainingCPU,proto3" json:"remainingCPU,omitempty"`
	RemainingMemoryMB float64           `protobuf:"fixed64,4,opt,name=remainingMemoryMB,proto3" json:"remainingMemoryMB,omitempty"`
	ProcessingCount   int64             `protobuf:"varint,5,opt,name=processingCount,proto3" json:"processingCount,omitempty"`
	PendingCount      int64             `protobuf:"varint,6,opt,name=pendingCount,proto3" json:"pendingCount,omitempty"`
	ProcessingDetails []*QueueUsageItem `protobuf:"bytes,7,rep,name=processingDetails,proto3" json:"processingDetails,omitempty"`
	PendingDetails    []*QueueUsageItem `protobuf:"bytes,8,rep,name=pendingDetails,proto3" json:"pendingDetails,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueUsage) Descriptor deprecated 

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

Deprecated: Use QueueUsage.ProtoReflect.Descriptor instead.

func (*QueueUsage) GetInUseCPU 

func (x *QueueUsage) GetInUseCPU() float64

func (*QueueUsage) GetInUseMemoryMB 

func (x *QueueUsage) GetInUseMemoryMB() float64

func (*QueueUsage) GetPendingCount 

func (x *QueueUsage) GetPendingCount() int64

func (*QueueUsage) GetPendingDetails 

func (x *QueueUsage) GetPendingDetails() []*QueueUsageItem

func (*QueueUsage) GetProcessingCount 

func (x *QueueUsage) GetProcessingCount() int64

func (*QueueUsage) GetProcessingDetails 

func (x *QueueUsage) GetProcessingDetails() []*QueueUsageItem

func (*QueueUsage) GetRemainingCPU 

func (x *QueueUsage) GetRemainingCPU() float64

func (*QueueUsage) GetRemainingMemoryMB 

func (x *QueueUsage) GetRemainingMemoryMB() float64

func (*QueueUsage) MarshalJSON 

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

QueueUsage implement json.Marshaler.

func (*QueueUsage) ProtoMessage 

func (*QueueUsage) ProtoMessage()

func (*QueueUsage) ProtoReflect 

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

func (*QueueUsage) Reset 

func (x *QueueUsage) Reset()

func (*QueueUsage) String 

func (x *QueueUsage) String() string

func (*QueueUsage) UnmarshalJSON 

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

QueueUsage implement json.Marshaler.

func (*QueueUsage) UnmarshalURLValues 

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

QueueUsage implement urlenc.URLValuesUnmarshaler.

func (*QueueUsage) Validate 

func (this *QueueUsage) Validate() error

type QueueUsageItem 

type QueueUsageItem struct {
	PipelineID       uint64                 `protobuf:"varint,1,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	RequestsCPU      float64                `protobuf:"fixed64,2,opt,name=requestsCPU,proto3" json:"requestsCPU,omitempty"`
	RequestsMemoryMB float64                `protobuf:"fixed64,3,opt,name=requestsMemoryMB,proto3" json:"requestsMemoryMB,omitempty"`
	Index            int64                  `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"`
	Priority         int64                  `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"`
	AddedTime        *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=addedTime,proto3" json:"addedTime,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueUsageItem) Descriptor deprecated 

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

Deprecated: Use QueueUsageItem.ProtoReflect.Descriptor instead.

func (*QueueUsageItem) GetAddedTime 

func (x *QueueUsageItem) GetAddedTime() *timestamppb.Timestamp

func (*QueueUsageItem) GetIndex 

func (x *QueueUsageItem) GetIndex() int64

func (*QueueUsageItem) GetPipelineID 

func (x *QueueUsageItem) GetPipelineID() uint64

func (*QueueUsageItem) GetPriority 

func (x *QueueUsageItem) GetPriority() int64

func (*QueueUsageItem) GetRequestsCPU 

func (x *QueueUsageItem) GetRequestsCPU() float64

func (*QueueUsageItem) GetRequestsMemoryMB 

func (x *QueueUsageItem) GetRequestsMemoryMB() float64

func (*QueueUsageItem) MarshalJSON 

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

QueueUsageItem implement json.Marshaler.

func (*QueueUsageItem) ProtoMessage 

func (*QueueUsageItem) ProtoMessage()

func (*QueueUsageItem) ProtoReflect 

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

func (*QueueUsageItem) Reset 

func (x *QueueUsageItem) Reset()

func (*QueueUsageItem) String 

func (x *QueueUsageItem) String() string

func (*QueueUsageItem) UnmarshalJSON 

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

QueueUsageItem implement json.Marshaler.

func (*QueueUsageItem) UnmarshalURLValues 

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

QueueUsageItem implement urlenc.URLValuesUnmarshaler.

func (*QueueUsageItem) Validate 

func (this *QueueUsageItem) Validate() error

type UnimplementedQueueServiceServer 

type UnimplementedQueueServiceServer struct {
}

UnimplementedQueueServiceServer should be embedded to have forward compatible implementations.

func (*UnimplementedQueueServiceServer) CreateQueue 

func (*UnimplementedQueueServiceServer) CreateQueue(context.Context, *QueueCreateRequest) (*QueueCreateResponse, error)

func (*UnimplementedQueueServiceServer) DeleteQueue 

func (*UnimplementedQueueServiceServer) DeleteQueue(context.Context, *QueueDeleteRequest) (*QueueDeleteResponse, error)

func (*UnimplementedQueueServiceServer) GetQueue 

func (*UnimplementedQueueServiceServer) GetQueue(context.Context, *QueueGetRequest) (*QueueGetResponse, error)

func (*UnimplementedQueueServiceServer) PagingQueue 

func (*UnimplementedQueueServiceServer) PagingQueue(context.Context, *QueuePagingRequest) (*QueuePagingResponse, error)

func (*UnimplementedQueueServiceServer) UpdateQueue 

func (*UnimplementedQueueServiceServer) UpdateQueue(context.Context, *QueueUpdateRequest) (*QueueUpdateResponse, 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.