api

package
v0.0.0-...-05c6a2a Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterCronJobsServer 

func RegisterCronJobsServer(s *grpc.Server, srv CronJobsServer)

func RegisterEventsServer 

func RegisterEventsServer(s *grpc.Server, srv EventsServer)

func RegisterJobsServer 

func RegisterJobsServer(s *grpc.Server, srv JobsServer)

func RegisterLocksServer 

func RegisterLocksServer(s *grpc.Server, srv LocksServer)

Types

type AquireRequest 

type AquireRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AquireRequest) Descriptor 

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

func (*AquireRequest) GetId 

func (m *AquireRequest) GetId() string

func (*AquireRequest) ProtoMessage 

func (*AquireRequest) ProtoMessage()

func (*AquireRequest) Reset 

func (m *AquireRequest) Reset()

func (*AquireRequest) String 

func (m *AquireRequest) String() string

func (*AquireRequest) XXX_DiscardUnknown 

func (m *AquireRequest) XXX_DiscardUnknown()

func (*AquireRequest) XXX_Marshal 

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

func (*AquireRequest) XXX_Merge 

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

func (*AquireRequest) XXX_Size 

func (m *AquireRequest) XXX_Size() int

func (*AquireRequest) XXX_Unmarshal 

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

type AquireResponse 

type AquireResponse struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AquireResponse) Descriptor 

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

func (*AquireResponse) GetId 

func (m *AquireResponse) GetId() string

func (*AquireResponse) ProtoMessage 

func (*AquireResponse) ProtoMessage()

func (*AquireResponse) Reset 

func (m *AquireResponse) Reset()

func (*AquireResponse) String 

func (m *AquireResponse) String() string

func (*AquireResponse) XXX_DiscardUnknown 

func (m *AquireResponse) XXX_DiscardUnknown()

func (*AquireResponse) XXX_Marshal 

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

func (*AquireResponse) XXX_Merge 

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

func (*AquireResponse) XXX_Size 

func (m *AquireResponse) XXX_Size() int

func (*AquireResponse) XXX_Unmarshal 

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

type CreateCronJobRequest 

type CreateCronJobRequest struct {
	Queue                string            `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	Name                 string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	Spec                 []byte            `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	Cron                 string            `protobuf:"bytes,5,opt,name=cron,proto3" json:"cron,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CreateCronJobRequest) Descriptor 

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

func (*CreateCronJobRequest) GetCron 

func (m *CreateCronJobRequest) GetCron() string

func (*CreateCronJobRequest) GetLabels 

func (m *CreateCronJobRequest) GetLabels() map[string]string

func (*CreateCronJobRequest) GetName 

func (m *CreateCronJobRequest) GetName() string

func (*CreateCronJobRequest) GetQueue 

func (m *CreateCronJobRequest) GetQueue() string

func (*CreateCronJobRequest) GetSpec 

func (m *CreateCronJobRequest) GetSpec() []byte

func (*CreateCronJobRequest) ProtoMessage 

func (*CreateCronJobRequest) ProtoMessage()

func (*CreateCronJobRequest) Reset 

func (m *CreateCronJobRequest) Reset()

func (*CreateCronJobRequest) String 

func (m *CreateCronJobRequest) String() string

func (*CreateCronJobRequest) XXX_DiscardUnknown 

func (m *CreateCronJobRequest) XXX_DiscardUnknown()

func (*CreateCronJobRequest) XXX_Marshal 

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

func (*CreateCronJobRequest) XXX_Merge 

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

func (*CreateCronJobRequest) XXX_Size 

func (m *CreateCronJobRequest) XXX_Size() int

func (*CreateCronJobRequest) XXX_Unmarshal 

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

type CreateJobRequest 

type CreateJobRequest struct {
	Queue                string            `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	Spec                 []byte            `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CreateJobRequest) Descriptor 

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

func (*CreateJobRequest) GetLabels 

func (m *CreateJobRequest) GetLabels() map[string]string

func (*CreateJobRequest) GetQueue 

func (m *CreateJobRequest) GetQueue() string

func (*CreateJobRequest) GetSpec 

func (m *CreateJobRequest) GetSpec() []byte

func (*CreateJobRequest) ProtoMessage 

func (*CreateJobRequest) ProtoMessage()

func (*CreateJobRequest) Reset 

func (m *CreateJobRequest) Reset()

func (*CreateJobRequest) String 

func (m *CreateJobRequest) String() string

func (*CreateJobRequest) XXX_DiscardUnknown 

func (m *CreateJobRequest) XXX_DiscardUnknown()

func (*CreateJobRequest) XXX_Marshal 

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

func (*CreateJobRequest) XXX_Merge 

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

func (*CreateJobRequest) XXX_Size 

func (m *CreateJobRequest) XXX_Size() int

func (*CreateJobRequest) XXX_Unmarshal 

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

type CronJob 

type CronJob struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Queue                string               `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Spec                 []byte               `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	Cron                 string               `protobuf:"bytes,5,opt,name=cron,proto3" json:"cron,omitempty"`
	Labels               map[string]string    `` /* 153-byte string literal not displayed */
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	NextRunAt            *timestamp.Timestamp `protobuf:"bytes,8,opt,name=next_run_at,json=nextRunAt,proto3" json:"next_run_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*CronJob) Descriptor 

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

func (*CronJob) GetCreatedAt 

func (m *CronJob) GetCreatedAt() *timestamp.Timestamp

func (*CronJob) GetCron 

func (m *CronJob) GetCron() string

func (*CronJob) GetId 

func (m *CronJob) GetId() string

func (*CronJob) GetLabels 

func (m *CronJob) GetLabels() map[string]string

func (*CronJob) GetName 

func (m *CronJob) GetName() string

func (*CronJob) GetNextRunAt 

func (m *CronJob) GetNextRunAt() *timestamp.Timestamp

func (*CronJob) GetQueue 

func (m *CronJob) GetQueue() string

func (*CronJob) GetSpec 

func (m *CronJob) GetSpec() []byte

func (*CronJob) ProtoMessage 

func (*CronJob) ProtoMessage()

func (*CronJob) Reset 

func (m *CronJob) Reset()

func (*CronJob) String 

func (m *CronJob) String() string

func (*CronJob) XXX_DiscardUnknown 

func (m *CronJob) XXX_DiscardUnknown()

func (*CronJob) XXX_Marshal 

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

func (*CronJob) XXX_Merge 

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

func (*CronJob) XXX_Size 

func (m *CronJob) XXX_Size() int

func (*CronJob) XXX_Unmarshal 

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

type CronJobsClient 

type CronJobsClient interface {
	Create(ctx context.Context, in *CreateCronJobRequest, opts ...grpc.CallOption) (*CronJob, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*CronJob, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*CronJob, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (CronJobs_ListClient, error)
}

CronJobsClient is the client API for CronJobs service.

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

func NewCronJobsClient 

func NewCronJobsClient(cc *grpc.ClientConn) CronJobsClient

type CronJobsServer 

type CronJobsServer interface {
	Create(context.Context, *CreateCronJobRequest) (*CronJob, error)
	Get(context.Context, *GetRequest) (*CronJob, error)
	Delete(context.Context, *DeleteRequest) (*CronJob, error)
	List(*ListRequest, CronJobs_ListServer) error
}

CronJobsServer is the server API for CronJobs service.

type CronJobs_ListClient 

type CronJobs_ListClient interface {
	Recv() (*CronJob, error)
	grpc.ClientStream
}

type CronJobs_ListServer 

type CronJobs_ListServer interface {
	Send(*CronJob) error
	grpc.ServerStream
}

type DeleteRequest 

type DeleteRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetId 

func (m *DeleteRequest) GetId() string

func (*DeleteRequest) GetName 

func (m *DeleteRequest) GetName() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type Event 

type Event struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Topic                string               `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Labels               map[string]string    `` /* 153-byte string literal not displayed */
	Sequence             uint64               `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Payload              []byte               `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Event) Descriptor 

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

func (*Event) GetCreatedAt 

func (m *Event) GetCreatedAt() *timestamp.Timestamp

func (*Event) GetId 

func (m *Event) GetId() string

func (*Event) GetLabels 

func (m *Event) GetLabels() map[string]string

func (*Event) GetPayload 

func (m *Event) GetPayload() []byte

func (*Event) GetSequence 

func (m *Event) GetSequence() uint64

func (*Event) GetTopic 

func (m *Event) GetTopic() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type EventsClient 

type EventsClient interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*Event, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Events_SubscribeClient, error)
}

EventsClient is the client API for Events service.

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

func NewEventsClient 

func NewEventsClient(cc *grpc.ClientConn) EventsClient

type EventsServer 

type EventsServer interface {
	Publish(context.Context, *PublishRequest) (*Event, error)
	Subscribe(*SubscribeRequest, Events_SubscribeServer) error
}

EventsServer is the server API for Events service.

type Events_SubscribeClient 

type Events_SubscribeClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type Events_SubscribeServer 

type Events_SubscribeServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type GetRequest 

type GetRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetId 

func (m *GetRequest) GetId() string

func (*GetRequest) GetName 

func (m *GetRequest) GetName() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type HeartbeatRequest 

type HeartbeatRequest struct {
	JobId                string   `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	State                []byte   `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	Finished             bool     `protobuf:"varint,3,opt,name=finished,proto3" json:"finished,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HeartbeatRequest) Descriptor 

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

func (*HeartbeatRequest) GetFinished 

func (m *HeartbeatRequest) GetFinished() bool

func (*HeartbeatRequest) GetJobId 

func (m *HeartbeatRequest) GetJobId() string

func (*HeartbeatRequest) GetState 

func (m *HeartbeatRequest) GetState() []byte

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) Reset 

func (m *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (m *HeartbeatRequest) String() string

func (*HeartbeatRequest) XXX_DiscardUnknown 

func (m *HeartbeatRequest) XXX_DiscardUnknown()

func (*HeartbeatRequest) XXX_Marshal 

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

func (*HeartbeatRequest) XXX_Merge 

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

func (*HeartbeatRequest) XXX_Size 

func (m *HeartbeatRequest) XXX_Size() int

func (*HeartbeatRequest) XXX_Unmarshal 

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

type HoldRequest 

type HoldRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HoldRequest) Descriptor 

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

func (*HoldRequest) GetId 

func (m *HoldRequest) GetId() string

func (*HoldRequest) ProtoMessage 

func (*HoldRequest) ProtoMessage()

func (*HoldRequest) Reset 

func (m *HoldRequest) Reset()

func (*HoldRequest) String 

func (m *HoldRequest) String() string

func (*HoldRequest) XXX_DiscardUnknown 

func (m *HoldRequest) XXX_DiscardUnknown()

func (*HoldRequest) XXX_Marshal 

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

func (*HoldRequest) XXX_Merge 

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

func (*HoldRequest) XXX_Size 

func (m *HoldRequest) XXX_Size() int

func (*HoldRequest) XXX_Unmarshal 

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

type HoldResponse 

type HoldResponse struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HoldResponse) Descriptor 

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

func (*HoldResponse) GetId 

func (m *HoldResponse) GetId() string

func (*HoldResponse) ProtoMessage 

func (*HoldResponse) ProtoMessage()

func (*HoldResponse) Reset 

func (m *HoldResponse) Reset()

func (*HoldResponse) String 

func (m *HoldResponse) String() string

func (*HoldResponse) XXX_DiscardUnknown 

func (m *HoldResponse) XXX_DiscardUnknown()

func (*HoldResponse) XXX_Marshal 

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

func (*HoldResponse) XXX_Merge 

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

func (*HoldResponse) XXX_Size 

func (m *HoldResponse) XXX_Size() int

func (*HoldResponse) XXX_Unmarshal 

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

type Job 

type Job struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Queue                string               `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	Spec                 []byte               `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	State                []byte               `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	Labels               map[string]string    `` /* 153-byte string literal not displayed */
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StartedAt            *timestamp.Timestamp `protobuf:"bytes,7,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	FinishedAt           *timestamp.Timestamp `protobuf:"bytes,9,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Job) Descriptor 

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

func (*Job) GetCreatedAt 

func (m *Job) GetCreatedAt() *timestamp.Timestamp

func (*Job) GetFinishedAt 

func (m *Job) GetFinishedAt() *timestamp.Timestamp

func (*Job) GetId 

func (m *Job) GetId() string

func (*Job) GetLabels 

func (m *Job) GetLabels() map[string]string

func (*Job) GetQueue 

func (m *Job) GetQueue() string

func (*Job) GetSpec 

func (m *Job) GetSpec() []byte

func (*Job) GetStartedAt 

func (m *Job) GetStartedAt() *timestamp.Timestamp

func (*Job) GetState 

func (m *Job) GetState() []byte

func (*Job) GetUpdatedAt 

func (m *Job) GetUpdatedAt() *timestamp.Timestamp

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) String 

func (m *Job) String() string

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 JobsClient 

type JobsClient interface {
	Create(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error)
	Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (Jobs_ListenClient, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*Job, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*Job, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*Job, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (Jobs_ListClient, error)
}

JobsClient is the client API for Jobs service.

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

func NewJobsClient 

func NewJobsClient(cc *grpc.ClientConn) JobsClient

type JobsServer 

type JobsServer interface {
	Create(context.Context, *CreateJobRequest) (*Job, error)
	Listen(*ListenRequest, Jobs_ListenServer) error
	Heartbeat(context.Context, *HeartbeatRequest) (*Job, error)
	Get(context.Context, *GetRequest) (*Job, error)
	Delete(context.Context, *DeleteRequest) (*Job, error)
	List(*ListRequest, Jobs_ListServer) error
}

JobsServer is the server API for Jobs service.

type Jobs_ListClient 

type Jobs_ListClient interface {
	Recv() (*Job, error)
	grpc.ClientStream
}

type Jobs_ListServer 

type Jobs_ListServer interface {
	Send(*Job) error
	grpc.ServerStream
}

type Jobs_ListenClient 

type Jobs_ListenClient interface {
	Recv() (*Job, error)
	grpc.ClientStream
}

type Jobs_ListenServer 

type Jobs_ListenServer interface {
	Send(*Job) error
	grpc.ServerStream
}

type ListRequest 

type ListRequest struct {
	Queues               []string          `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	ExcludeFinished      bool              `protobuf:"varint,3,opt,name=exclude_finished,json=excludeFinished,proto3" json:"exclude_finished,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListRequest) Descriptor 

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

func (*ListRequest) GetExcludeFinished 

func (m *ListRequest) GetExcludeFinished() bool

func (*ListRequest) GetLabels 

func (m *ListRequest) GetLabels() map[string]string

func (*ListRequest) GetQueues 

func (m *ListRequest) GetQueues() []string

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) String 

func (m *ListRequest) String() string

func (*ListRequest) XXX_DiscardUnknown 

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal 

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

func (*ListRequest) XXX_Merge 

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

func (*ListRequest) XXX_Size 

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal 

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

type ListenRequest 

type ListenRequest struct {
	Queue                string   `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListenRequest) Descriptor 

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

func (*ListenRequest) GetQueue 

func (m *ListenRequest) GetQueue() string

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) Reset 

func (m *ListenRequest) Reset()

func (*ListenRequest) String 

func (m *ListenRequest) String() string

func (*ListenRequest) XXX_DiscardUnknown 

func (m *ListenRequest) XXX_DiscardUnknown()

func (*ListenRequest) XXX_Marshal 

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

func (*ListenRequest) XXX_Merge 

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

func (*ListenRequest) XXX_Size 

func (m *ListenRequest) XXX_Size() int

func (*ListenRequest) XXX_Unmarshal 

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

type LocksClient 

type LocksClient interface {
	Aquire(ctx context.Context, in *AquireRequest, opts ...grpc.CallOption) (*AquireResponse, error)
	Hold(ctx context.Context, in *HoldRequest, opts ...grpc.CallOption) (*HoldResponse, error)
	Release(ctx context.Context, in *ReleaseRequest, opts ...grpc.CallOption) (*ReleaseResponse, error)
}

LocksClient is the client API for Locks service.

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

func NewLocksClient 

func NewLocksClient(cc *grpc.ClientConn) LocksClient

type LocksServer 

type LocksServer interface {
	Aquire(context.Context, *AquireRequest) (*AquireResponse, error)
	Hold(context.Context, *HoldRequest) (*HoldResponse, error)
	Release(context.Context, *ReleaseRequest) (*ReleaseResponse, error)
}

LocksServer is the server API for Locks service.

type PublishRequest 

type PublishRequest struct {
	Topic                string            `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	Payload              []byte            `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*PublishRequest) Descriptor 

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

func (*PublishRequest) GetLabels 

func (m *PublishRequest) GetLabels() map[string]string

func (*PublishRequest) GetPayload 

func (m *PublishRequest) GetPayload() []byte

func (*PublishRequest) GetTopic 

func (m *PublishRequest) GetTopic() string

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset 

func (m *PublishRequest) Reset()

func (*PublishRequest) String 

func (m *PublishRequest) String() string

func (*PublishRequest) XXX_DiscardUnknown 

func (m *PublishRequest) XXX_DiscardUnknown()

func (*PublishRequest) XXX_Marshal 

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

func (*PublishRequest) XXX_Merge 

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

func (*PublishRequest) XXX_Size 

func (m *PublishRequest) XXX_Size() int

func (*PublishRequest) XXX_Unmarshal 

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

type ReleaseRequest 

type ReleaseRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReleaseRequest) Descriptor 

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

func (*ReleaseRequest) GetId 

func (m *ReleaseRequest) GetId() string

func (*ReleaseRequest) ProtoMessage 

func (*ReleaseRequest) ProtoMessage()

func (*ReleaseRequest) Reset 

func (m *ReleaseRequest) Reset()

func (*ReleaseRequest) String 

func (m *ReleaseRequest) String() string

func (*ReleaseRequest) XXX_DiscardUnknown 

func (m *ReleaseRequest) XXX_DiscardUnknown()

func (*ReleaseRequest) XXX_Marshal 

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

func (*ReleaseRequest) XXX_Merge 

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

func (*ReleaseRequest) XXX_Size 

func (m *ReleaseRequest) XXX_Size() int

func (*ReleaseRequest) XXX_Unmarshal 

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

type ReleaseResponse 

type ReleaseResponse struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReleaseResponse) Descriptor 

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

func (*ReleaseResponse) GetId 

func (m *ReleaseResponse) GetId() string

func (*ReleaseResponse) ProtoMessage 

func (*ReleaseResponse) ProtoMessage()

func (*ReleaseResponse) Reset 

func (m *ReleaseResponse) Reset()

func (*ReleaseResponse) String 

func (m *ReleaseResponse) String() string

func (*ReleaseResponse) XXX_DiscardUnknown 

func (m *ReleaseResponse) XXX_DiscardUnknown()

func (*ReleaseResponse) XXX_Marshal 

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

func (*ReleaseResponse) XXX_Merge 

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

func (*ReleaseResponse) XXX_Size 

func (m *ReleaseResponse) XXX_Size() int

func (*ReleaseResponse) XXX_Unmarshal 

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

type SubscribeRequest 

type SubscribeRequest struct {
	Topic                string               `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Labels               map[string]string    `` /* 153-byte string literal not displayed */
	SinceSequence        uint64               `protobuf:"varint,3,opt,name=since_sequence,json=sinceSequence,proto3" json:"since_sequence,omitempty"`
	SinceCreatedAt       *timestamp.Timestamp `protobuf:"bytes,4,opt,name=since_created_at,json=sinceCreatedAt,proto3" json:"since_created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) GetLabels 

func (m *SubscribeRequest) GetLabels() map[string]string

func (*SubscribeRequest) GetSinceCreatedAt 

func (m *SubscribeRequest) GetSinceCreatedAt() *timestamp.Timestamp

func (*SubscribeRequest) GetSinceSequence 

func (m *SubscribeRequest) GetSinceSequence() uint64

func (*SubscribeRequest) GetTopic 

func (m *SubscribeRequest) GetTopic() string

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

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

func (*SubscribeRequest) XXX_Merge 

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

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

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

type UnimplementedCronJobsServer 

type UnimplementedCronJobsServer struct {
}

UnimplementedCronJobsServer can be embedded to have forward compatible implementations.

func (*UnimplementedCronJobsServer) Create 

func (*UnimplementedCronJobsServer) Create(ctx context.Context, req *CreateCronJobRequest) (*CronJob, error)

func (*UnimplementedCronJobsServer) Delete 

func (*UnimplementedCronJobsServer) Delete(ctx context.Context, req *DeleteRequest) (*CronJob, error)

func (*UnimplementedCronJobsServer) Get 

func (*UnimplementedCronJobsServer) Get(ctx context.Context, req *GetRequest) (*CronJob, error)

func (*UnimplementedCronJobsServer) List 

func (*UnimplementedCronJobsServer) List(req *ListRequest, srv CronJobs_ListServer) error

type UnimplementedEventsServer 

type UnimplementedEventsServer struct {
}

UnimplementedEventsServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventsServer) Publish 

func (*UnimplementedEventsServer) Publish(ctx context.Context, req *PublishRequest) (*Event, error)

func (*UnimplementedEventsServer) Subscribe 

func (*UnimplementedEventsServer) Subscribe(req *SubscribeRequest, srv Events_SubscribeServer) error

type UnimplementedJobsServer 

type UnimplementedJobsServer struct {
}

UnimplementedJobsServer can be embedded to have forward compatible implementations.

func (*UnimplementedJobsServer) Create 

func (*UnimplementedJobsServer) Create(ctx context.Context, req *CreateJobRequest) (*Job, error)

func (*UnimplementedJobsServer) Delete 

func (*UnimplementedJobsServer) Delete(ctx context.Context, req *DeleteRequest) (*Job, error)

func (*UnimplementedJobsServer) Get 

func (*UnimplementedJobsServer) Get(ctx context.Context, req *GetRequest) (*Job, error)

func (*UnimplementedJobsServer) Heartbeat 

func (*UnimplementedJobsServer) Heartbeat(ctx context.Context, req *HeartbeatRequest) (*Job, error)

func (*UnimplementedJobsServer) List 

func (*UnimplementedJobsServer) List(req *ListRequest, srv Jobs_ListServer) error

func (*UnimplementedJobsServer) Listen 

func (*UnimplementedJobsServer) Listen(req *ListenRequest, srv Jobs_ListenServer) error

type UnimplementedLocksServer 

type UnimplementedLocksServer struct {
}

UnimplementedLocksServer can be embedded to have forward compatible implementations.

func (*UnimplementedLocksServer) Aquire 

func (*UnimplementedLocksServer) Aquire(ctx context.Context, req *AquireRequest) (*AquireResponse, error)

func (*UnimplementedLocksServer) Hold 

func (*UnimplementedLocksServer) Hold(ctx context.Context, req *HoldRequest) (*HoldResponse, error)

func (*UnimplementedLocksServer) Release 

func (*UnimplementedLocksServer) Release(ctx context.Context, req *ReleaseRequest) (*ReleaseResponse, 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.