jobs

package module
v0.0.0-...-7d73fae Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2024 License: MPL-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const Job_TypeID = 0xa05b60b71ca38848

Job_TypeID is the unique identifier for the type Job.

View Source 
const Service_TypeID = 0xb8745454d013cbf0

Service_TypeID is the unique identifier for the type Service.

View Source 
const Service_nextJob_Params_TypeID = 0xea3ba97e764a031c

Service_nextJob_Params_TypeID is the unique identifier for the type Service_nextJob_Params.

View Source 
const Service_nextJob_Results_TypeID = 0xe067ec22521ebebb

Service_nextJob_Results_TypeID is the unique identifier for the type Service_nextJob_Results.

Variables

This section is empty.

Functions

func RegisterSchema 

func RegisterSchema(reg *schemas.Registry)

func Service_Methods 

func Service_Methods(methods []server.Method, s Service_Server) []server.Method

Service_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.

func Service_NewServer 

func Service_NewServer(s Service_Server) *server.Server

Service_NewServer creates a new Server from an implementation of Service_Server.

Types

type Job 

type Job capnp.Struct

func NewJob 

func NewJob(s *capnp.Segment) (Job, error)

func NewRootJob 

func NewRootJob(s *capnp.Segment) (Job, error)

func ReadRootJob 

func ReadRootJob(msg *capnp.Message) (Job, error)

func (Job) Data 

func (s Job) Data() (capnp.Ptr, error)

func (Job) DecodeFromPtr 

func (Job) DecodeFromPtr(p capnp.Ptr) Job

func (Job) EncodeAsPtr 

func (s Job) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Job) HasData 

func (s Job) HasData() bool

func (Job) IsValid 

func (s Job) IsValid() bool

func (Job) Message 

func (s Job) Message() *capnp.Message

func (Job) NoFurtherJobs 

func (s Job) NoFurtherJobs() bool

func (Job) Segment 

func (s Job) Segment() *capnp.Segment

func (Job) SetData 

func (s Job) SetData(v capnp.Ptr) error

func (Job) SetNoFurtherJobs 

func (s Job) SetNoFurtherJobs(v bool)

func (Job) String 

func (s Job) String() string

func (Job) ToPtr 

func (s Job) ToPtr() capnp.Ptr

type Job_Future 

type Job_Future struct{ *capnp.Future }

Job_Future is a wrapper for a Job promised by a client call.

func (Job_Future) Data 

func (p Job_Future) Data() *capnp.Future

func (Job_Future) Struct 

func (f Job_Future) Struct() (Job, error)

type Job_List 

type Job_List = capnp.StructList[Job]

Job_List is a list of Job.

func NewJob_List 

func NewJob_List(s *capnp.Segment, sz int32) (Job_List, error)

NewJob creates a new list of Job.

type Service 

type Service capnp.Client

func Service_ServerToClient 

func Service_ServerToClient(s Service_Server) Service

Service_ServerToClient creates a new Client from an implementation of Service_Server. The caller is responsible for calling Release on the returned Client.

func (Service) AddRef 

func (c Service) AddRef() Service

AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.

func (Service) DecodeFromPtr 

func (Service) DecodeFromPtr(p capnp.Ptr) Service

func (Service) EncodeAsPtr 

func (c Service) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Service) GetFlowLimiter 

func (c Service) GetFlowLimiter() fc.FlowLimiter

Get the current flowcontrol.FlowLimiter used to manage flow control for this client.

func (Service) Info 

func (c Service) Info(ctx context.Context, params func(common.Identifiable_info_Params) error) (common.IdInformation_Future, capnp.ReleaseFunc)

func (Service) IsSame 

func (c Service) IsSame(other Service) bool

IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.

func (Service) IsValid 

func (c Service) IsValid() bool

IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.

func (Service) NextJob 

func (c Service) NextJob(ctx context.Context, params func(Service_nextJob_Params) error) (Service_nextJob_Results_Future, capnp.ReleaseFunc)

func (Service) Release 

func (c Service) Release()

Release releases a capability reference. If this is the last reference to the capability, then the underlying resources associated with the capability will be released.

Release will panic if c has already been released, but not if c is nil or resolved to null.

func (Service) Resolve 

func (c Service) Resolve(ctx context.Context) error

Resolve blocks until the capability is fully resolved or the Context expires.

func (Service) Save 

func (c Service) Save(ctx context.Context, params func(persistence.Persistent_SaveParams) error) (persistence.Persistent_SaveResults_Future, capnp.ReleaseFunc)

func (Service) SetFlowLimiter 

func (c Service) SetFlowLimiter(lim fc.FlowLimiter)

Update the flowcontrol.FlowLimiter used to manage flow control for this client. This affects all future calls, but not calls already waiting to send. Passing nil sets the value to flowcontrol.NopLimiter, which is also the default.

func (Service) String 

func (c Service) String() string

String returns a string that identifies this capability for debugging purposes. Its format should not be depended on: in particular, it should not be used to compare clients. Use IsSame to compare clients for equality.

func (Service) WaitStreaming 

func (c Service) WaitStreaming() error

type Service_List 

type Service_List = capnp.CapList[Service]

Service_List is a list of Service.

func NewService_List 

func NewService_List(s *capnp.Segment, sz int32) (Service_List, error)

NewService creates a new list of Service.

type Service_Server 

type Service_Server interface {
	NextJob(context.Context, Service_nextJob) error

	Info(context.Context, common.Identifiable_info) error

	Save(context.Context, persistence.Persistent_save) error
}

A Service_Server is a Service with a local implementation.

type Service_nextJob 

type Service_nextJob struct {
	*server.Call
}

Service_nextJob holds the state for a server call to Service.nextJob. See server.Call for documentation.

func (Service_nextJob) AllocResults 

func (c Service_nextJob) AllocResults() (Service_nextJob_Results, error)

AllocResults allocates the results struct.

func (Service_nextJob) Args 

func (c Service_nextJob) Args() Service_nextJob_Params

Args returns the call's arguments.

type Service_nextJob_Params 

type Service_nextJob_Params capnp.Struct

func NewRootService_nextJob_Params 

func NewRootService_nextJob_Params(s *capnp.Segment) (Service_nextJob_Params, error)

func NewService_nextJob_Params 

func NewService_nextJob_Params(s *capnp.Segment) (Service_nextJob_Params, error)

func ReadRootService_nextJob_Params 

func ReadRootService_nextJob_Params(msg *capnp.Message) (Service_nextJob_Params, error)

func (Service_nextJob_Params) DecodeFromPtr 

func (Service_nextJob_Params) DecodeFromPtr(p capnp.Ptr) Service_nextJob_Params

func (Service_nextJob_Params) EncodeAsPtr 

func (s Service_nextJob_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Service_nextJob_Params) IsValid 

func (s Service_nextJob_Params) IsValid() bool

func (Service_nextJob_Params) Message 

func (s Service_nextJob_Params) Message() *capnp.Message

func (Service_nextJob_Params) Segment 

func (s Service_nextJob_Params) Segment() *capnp.Segment

func (Service_nextJob_Params) String 

func (s Service_nextJob_Params) String() string

func (Service_nextJob_Params) ToPtr 

func (s Service_nextJob_Params) ToPtr() capnp.Ptr

type Service_nextJob_Params_Future 

type Service_nextJob_Params_Future struct{ *capnp.Future }

Service_nextJob_Params_Future is a wrapper for a Service_nextJob_Params promised by a client call.

func (Service_nextJob_Params_Future) Struct 

func (f Service_nextJob_Params_Future) Struct() (Service_nextJob_Params, error)

type Service_nextJob_Params_List 

type Service_nextJob_Params_List = capnp.StructList[Service_nextJob_Params]

Service_nextJob_Params_List is a list of Service_nextJob_Params.

func NewService_nextJob_Params_List 

func NewService_nextJob_Params_List(s *capnp.Segment, sz int32) (Service_nextJob_Params_List, error)

NewService_nextJob_Params creates a new list of Service_nextJob_Params.

type Service_nextJob_Results 

type Service_nextJob_Results capnp.Struct

func NewRootService_nextJob_Results 

func NewRootService_nextJob_Results(s *capnp.Segment) (Service_nextJob_Results, error)

func NewService_nextJob_Results 

func NewService_nextJob_Results(s *capnp.Segment) (Service_nextJob_Results, error)

func ReadRootService_nextJob_Results 

func ReadRootService_nextJob_Results(msg *capnp.Message) (Service_nextJob_Results, error)

func (Service_nextJob_Results) DecodeFromPtr 

func (Service_nextJob_Results) DecodeFromPtr(p capnp.Ptr) Service_nextJob_Results

func (Service_nextJob_Results) EncodeAsPtr 

func (s Service_nextJob_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Service_nextJob_Results) HasJob 

func (s Service_nextJob_Results) HasJob() bool

func (Service_nextJob_Results) IsValid 

func (s Service_nextJob_Results) IsValid() bool

func (Service_nextJob_Results) Job 

func (s Service_nextJob_Results) Job() (Job, error)

func (Service_nextJob_Results) Message 

func (s Service_nextJob_Results) Message() *capnp.Message

func (Service_nextJob_Results) NewJob 

func (s Service_nextJob_Results) NewJob() (Job, error)

NewJob sets the job field to a newly allocated Job struct, preferring placement in s's segment.

func (Service_nextJob_Results) Segment 

func (s Service_nextJob_Results) Segment() *capnp.Segment

func (Service_nextJob_Results) SetJob 

func (s Service_nextJob_Results) SetJob(v Job) error

func (Service_nextJob_Results) String 

func (s Service_nextJob_Results) String() string

func (Service_nextJob_Results) ToPtr 

func (s Service_nextJob_Results) ToPtr() capnp.Ptr

type Service_nextJob_Results_Future 

type Service_nextJob_Results_Future struct{ *capnp.Future }

Service_nextJob_Results_Future is a wrapper for a Service_nextJob_Results promised by a client call.

func (Service_nextJob_Results_Future) Job 

func (p Service_nextJob_Results_Future) Job() Job_Future

func (Service_nextJob_Results_Future) Struct 

func (f Service_nextJob_Results_Future) Struct() (Service_nextJob_Results, error)

type Service_nextJob_Results_List 

type Service_nextJob_Results_List = capnp.StructList[Service_nextJob_Results]

Service_nextJob_Results_List is a list of Service_nextJob_Results.

func NewService_nextJob_Results_List 

func NewService_nextJob_Results_List(s *capnp.Segment, sz int32) (Service_nextJob_Results_List, error)

NewService_nextJob_Results creates a new list of Service_nextJob_Results.

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.