proto

package
v3.4.2 Latest Latest
Warning

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

 Go to latest Published: Feb 14, 2025 License: AGPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBlockbuilder = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBlockbuilder   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterSchedulerServiceServer 

func RegisterSchedulerServiceServer(s *grpc.Server, srv SchedulerServiceServer)

Types

type CompleteJobRequest 

type CompleteJobRequest struct {
	BuilderId string `protobuf:"bytes,1,opt,name=builder_id,json=builderId,proto3" json:"builder_id,omitempty"`
	Job       *Job   `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	Success   bool   `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"`
}

CompleteJobRequest represents a job completion notification

func (*CompleteJobRequest) Descriptor 

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

func (*CompleteJobRequest) Equal 

func (this *CompleteJobRequest) Equal(that interface{}) bool

func (*CompleteJobRequest) GetBuilderId 

func (m *CompleteJobRequest) GetBuilderId() string

func (*CompleteJobRequest) GetJob 

func (m *CompleteJobRequest) GetJob() *Job

func (*CompleteJobRequest) GetSuccess 

func (m *CompleteJobRequest) GetSuccess() bool

func (*CompleteJobRequest) GoString 

func (this *CompleteJobRequest) GoString() string

func (*CompleteJobRequest) Marshal 

func (m *CompleteJobRequest) Marshal() (dAtA []byte, err error)

func (*CompleteJobRequest) MarshalTo 

func (m *CompleteJobRequest) MarshalTo(dAtA []byte) (int, error)

func (*CompleteJobRequest) MarshalToSizedBuffer 

func (m *CompleteJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompleteJobRequest) ProtoMessage 

func (*CompleteJobRequest) ProtoMessage()

func (*CompleteJobRequest) Reset 

func (m *CompleteJobRequest) Reset()

func (*CompleteJobRequest) Size 

func (m *CompleteJobRequest) Size() (n int)

func (*CompleteJobRequest) String 

func (this *CompleteJobRequest) String() string

func (*CompleteJobRequest) Unmarshal 

func (m *CompleteJobRequest) Unmarshal(dAtA []byte) error

func (*CompleteJobRequest) XXX_DiscardUnknown 

func (m *CompleteJobRequest) XXX_DiscardUnknown()

func (*CompleteJobRequest) XXX_Marshal 

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

func (*CompleteJobRequest) XXX_Merge 

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

func (*CompleteJobRequest) XXX_Size 

func (m *CompleteJobRequest) XXX_Size() int

func (*CompleteJobRequest) XXX_Unmarshal 

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

type CompleteJobResponse 

type CompleteJobResponse struct {
}

CompleteJobResponse is an empty response for job completion

func (*CompleteJobResponse) Descriptor 

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

func (*CompleteJobResponse) Equal 

func (this *CompleteJobResponse) Equal(that interface{}) bool

func (*CompleteJobResponse) GoString 

func (this *CompleteJobResponse) GoString() string

func (*CompleteJobResponse) Marshal 

func (m *CompleteJobResponse) Marshal() (dAtA []byte, err error)

func (*CompleteJobResponse) MarshalTo 

func (m *CompleteJobResponse) MarshalTo(dAtA []byte) (int, error)

func (*CompleteJobResponse) MarshalToSizedBuffer 

func (m *CompleteJobResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompleteJobResponse) ProtoMessage 

func (*CompleteJobResponse) ProtoMessage()

func (*CompleteJobResponse) Reset 

func (m *CompleteJobResponse) Reset()

func (*CompleteJobResponse) Size 

func (m *CompleteJobResponse) Size() (n int)

func (*CompleteJobResponse) String 

func (this *CompleteJobResponse) String() string

func (*CompleteJobResponse) Unmarshal 

func (m *CompleteJobResponse) Unmarshal(dAtA []byte) error

func (*CompleteJobResponse) XXX_DiscardUnknown 

func (m *CompleteJobResponse) XXX_DiscardUnknown()

func (*CompleteJobResponse) XXX_Marshal 

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

func (*CompleteJobResponse) XXX_Merge 

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

func (*CompleteJobResponse) XXX_Size 

func (m *CompleteJobResponse) XXX_Size() int

func (*CompleteJobResponse) XXX_Unmarshal 

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

type GetJobRequest 

type GetJobRequest struct {
	BuilderId string `protobuf:"bytes,1,opt,name=builder_id,json=builderId,proto3" json:"builder_id,omitempty"`
}

GetJobRequest represents a request for a new job

func (*GetJobRequest) Descriptor 

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

func (*GetJobRequest) Equal 

func (this *GetJobRequest) Equal(that interface{}) bool

func (*GetJobRequest) GetBuilderId 

func (m *GetJobRequest) GetBuilderId() string

func (*GetJobRequest) GoString 

func (this *GetJobRequest) GoString() string

func (*GetJobRequest) Marshal 

func (m *GetJobRequest) Marshal() (dAtA []byte, err error)

func (*GetJobRequest) MarshalTo 

func (m *GetJobRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetJobRequest) MarshalToSizedBuffer 

func (m *GetJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) Reset 

func (m *GetJobRequest) Reset()

func (*GetJobRequest) Size 

func (m *GetJobRequest) Size() (n int)

func (*GetJobRequest) String 

func (this *GetJobRequest) String() string

func (*GetJobRequest) Unmarshal 

func (m *GetJobRequest) Unmarshal(dAtA []byte) error

func (*GetJobRequest) XXX_DiscardUnknown 

func (m *GetJobRequest) XXX_DiscardUnknown()

func (*GetJobRequest) XXX_Marshal 

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

func (*GetJobRequest) XXX_Merge 

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

func (*GetJobRequest) XXX_Size 

func (m *GetJobRequest) XXX_Size() int

func (*GetJobRequest) XXX_Unmarshal 

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

type GetJobResponse 

type GetJobResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Ok  bool `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
}

GetJobResponse contains the response for a job request

func (*GetJobResponse) Descriptor 

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

func (*GetJobResponse) Equal 

func (this *GetJobResponse) Equal(that interface{}) bool

func (*GetJobResponse) GetJob 

func (m *GetJobResponse) GetJob() *Job

func (*GetJobResponse) GetOk 

func (m *GetJobResponse) GetOk() bool

func (*GetJobResponse) GoString 

func (this *GetJobResponse) GoString() string

func (*GetJobResponse) Marshal 

func (m *GetJobResponse) Marshal() (dAtA []byte, err error)

func (*GetJobResponse) MarshalTo 

func (m *GetJobResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetJobResponse) MarshalToSizedBuffer 

func (m *GetJobResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) Reset 

func (m *GetJobResponse) Reset()

func (*GetJobResponse) Size 

func (m *GetJobResponse) Size() (n int)

func (*GetJobResponse) String 

func (this *GetJobResponse) String() string

func (*GetJobResponse) Unmarshal 

func (m *GetJobResponse) Unmarshal(dAtA []byte) error

func (*GetJobResponse) XXX_DiscardUnknown 

func (m *GetJobResponse) XXX_DiscardUnknown()

func (*GetJobResponse) XXX_Marshal 

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

func (*GetJobResponse) XXX_Merge 

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

func (*GetJobResponse) XXX_Size 

func (m *GetJobResponse) XXX_Size() int

func (*GetJobResponse) XXX_Unmarshal 

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

type Job 

type Job struct {
	Id        string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Partition int32    `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	Offsets   *Offsets `protobuf:"bytes,3,opt,name=offsets,proto3" json:"offsets,omitempty"`
}

Job represents a block building job

func (*Job) Descriptor 

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

func (*Job) Equal 

func (this *Job) Equal(that interface{}) bool

func (*Job) GetId 

func (m *Job) GetId() string

func (*Job) GetOffsets 

func (m *Job) GetOffsets() *Offsets

func (*Job) GetPartition 

func (m *Job) GetPartition() int32

func (*Job) GoString 

func (this *Job) GoString() string

func (*Job) Marshal 

func (m *Job) Marshal() (dAtA []byte, err error)

func (*Job) MarshalTo 

func (m *Job) MarshalTo(dAtA []byte) (int, error)

func (*Job) MarshalToSizedBuffer 

func (m *Job) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) Size 

func (m *Job) Size() (n int)

func (*Job) String 

func (this *Job) String() string

func (*Job) Unmarshal 

func (m *Job) Unmarshal(dAtA []byte) error

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

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

func (*Job) XXX_Merge 

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

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

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

type Offsets 

type Offsets struct {
	Min int64 `protobuf:"varint,1,opt,name=min,proto3" json:"min,omitempty"`
	Max int64 `protobuf:"varint,2,opt,name=max,proto3" json:"max,omitempty"`
}

Offsets represents the start and end offsets for a job

func (*Offsets) Descriptor 

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

func (*Offsets) Equal 

func (this *Offsets) Equal(that interface{}) bool

func (*Offsets) GetMax 

func (m *Offsets) GetMax() int64

func (*Offsets) GetMin 

func (m *Offsets) GetMin() int64

func (*Offsets) GoString 

func (this *Offsets) GoString() string

func (*Offsets) Marshal 

func (m *Offsets) Marshal() (dAtA []byte, err error)

func (*Offsets) MarshalTo 

func (m *Offsets) MarshalTo(dAtA []byte) (int, error)

func (*Offsets) MarshalToSizedBuffer 

func (m *Offsets) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Offsets) ProtoMessage 

func (*Offsets) ProtoMessage()

func (*Offsets) Reset 

func (m *Offsets) Reset()

func (*Offsets) Size 

func (m *Offsets) Size() (n int)

func (*Offsets) String 

func (this *Offsets) String() string

func (*Offsets) Unmarshal 

func (m *Offsets) Unmarshal(dAtA []byte) error

func (*Offsets) XXX_DiscardUnknown 

func (m *Offsets) XXX_DiscardUnknown()

func (*Offsets) XXX_Marshal 

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

func (*Offsets) XXX_Merge 

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

func (*Offsets) XXX_Size 

func (m *Offsets) XXX_Size() int

func (*Offsets) XXX_Unmarshal 

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

type SchedulerServiceClient 

type SchedulerServiceClient interface {
	// GetJob requests a new job from the scheduler
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
	// CompleteJob notifies the scheduler that a job has been completed
	CompleteJob(ctx context.Context, in *CompleteJobRequest, opts ...grpc.CallOption) (*CompleteJobResponse, error)
	// SyncJob syncs job state with the scheduler
	SyncJob(ctx context.Context, in *SyncJobRequest, opts ...grpc.CallOption) (*SyncJobResponse, error)
}

SchedulerServiceClient is the client API for SchedulerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSchedulerServiceClient 

func NewSchedulerServiceClient(cc *grpc.ClientConn) SchedulerServiceClient

type SchedulerServiceServer 

type SchedulerServiceServer interface {
	// GetJob requests a new job from the scheduler
	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
	// CompleteJob notifies the scheduler that a job has been completed
	CompleteJob(context.Context, *CompleteJobRequest) (*CompleteJobResponse, error)
	// SyncJob syncs job state with the scheduler
	SyncJob(context.Context, *SyncJobRequest) (*SyncJobResponse, error)
}

SchedulerServiceServer is the server API for SchedulerService service.

type SyncJobRequest 

type SyncJobRequest struct {
	BuilderId string `protobuf:"bytes,1,opt,name=builder_id,json=builderId,proto3" json:"builder_id,omitempty"`
	Job       *Job   `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
}

SyncJobRequest represents a job sync request

func (*SyncJobRequest) Descriptor 

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

func (*SyncJobRequest) Equal 

func (this *SyncJobRequest) Equal(that interface{}) bool

func (*SyncJobRequest) GetBuilderId 

func (m *SyncJobRequest) GetBuilderId() string

func (*SyncJobRequest) GetJob 

func (m *SyncJobRequest) GetJob() *Job

func (*SyncJobRequest) GoString 

func (this *SyncJobRequest) GoString() string

func (*SyncJobRequest) Marshal 

func (m *SyncJobRequest) Marshal() (dAtA []byte, err error)

func (*SyncJobRequest) MarshalTo 

func (m *SyncJobRequest) MarshalTo(dAtA []byte) (int, error)

func (*SyncJobRequest) MarshalToSizedBuffer 

func (m *SyncJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncJobRequest) ProtoMessage 

func (*SyncJobRequest) ProtoMessage()

func (*SyncJobRequest) Reset 

func (m *SyncJobRequest) Reset()

func (*SyncJobRequest) Size 

func (m *SyncJobRequest) Size() (n int)

func (*SyncJobRequest) String 

func (this *SyncJobRequest) String() string

func (*SyncJobRequest) Unmarshal 

func (m *SyncJobRequest) Unmarshal(dAtA []byte) error

func (*SyncJobRequest) XXX_DiscardUnknown 

func (m *SyncJobRequest) XXX_DiscardUnknown()

func (*SyncJobRequest) XXX_Marshal 

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

func (*SyncJobRequest) XXX_Merge 

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

func (*SyncJobRequest) XXX_Size 

func (m *SyncJobRequest) XXX_Size() int

func (*SyncJobRequest) XXX_Unmarshal 

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

type SyncJobResponse 

type SyncJobResponse struct {
}

SyncJobResponse is an empty response for job sync

func (*SyncJobResponse) Descriptor 

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

func (*SyncJobResponse) Equal 

func (this *SyncJobResponse) Equal(that interface{}) bool

func (*SyncJobResponse) GoString 

func (this *SyncJobResponse) GoString() string

func (*SyncJobResponse) Marshal 

func (m *SyncJobResponse) Marshal() (dAtA []byte, err error)

func (*SyncJobResponse) MarshalTo 

func (m *SyncJobResponse) MarshalTo(dAtA []byte) (int, error)

func (*SyncJobResponse) MarshalToSizedBuffer 

func (m *SyncJobResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncJobResponse) ProtoMessage 

func (*SyncJobResponse) ProtoMessage()

func (*SyncJobResponse) Reset 

func (m *SyncJobResponse) Reset()

func (*SyncJobResponse) Size 

func (m *SyncJobResponse) Size() (n int)

func (*SyncJobResponse) String 

func (this *SyncJobResponse) String() string

func (*SyncJobResponse) Unmarshal 

func (m *SyncJobResponse) Unmarshal(dAtA []byte) error

func (*SyncJobResponse) XXX_DiscardUnknown 

func (m *SyncJobResponse) XXX_DiscardUnknown()

func (*SyncJobResponse) XXX_Marshal 

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

func (*SyncJobResponse) XXX_Merge 

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

func (*SyncJobResponse) XXX_Size 

func (m *SyncJobResponse) XXX_Size() int

func (*SyncJobResponse) XXX_Unmarshal 

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

type UnimplementedSchedulerServiceServer 

type UnimplementedSchedulerServiceServer struct {
}

UnimplementedSchedulerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSchedulerServiceServer) CompleteJob 

func (*UnimplementedSchedulerServiceServer) CompleteJob(ctx context.Context, req *CompleteJobRequest) (*CompleteJobResponse, error)

func (*UnimplementedSchedulerServiceServer) GetJob 

func (*UnimplementedSchedulerServiceServer) GetJob(ctx context.Context, req *GetJobRequest) (*GetJobResponse, error)

func (*UnimplementedSchedulerServiceServer) SyncJob 

func (*UnimplementedSchedulerServiceServer) SyncJob(ctx context.Context, req *SyncJobRequest) (*SyncJobResponse, 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.