local

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Sep 15, 2022 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Checkpoint 

type Checkpoint struct {
	Seq                  uint64   `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	From                 int64    `protobuf:"varint,2,opt,name=from,proto3" json:"from,omitempty"`
	To                   int64    `protobuf:"varint,3,opt,name=to,proto3" json:"to,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Checkpoint stores a time range. It is used to store the last load performed as a checkpoint to resume processing where it was left off.

func (*Checkpoint) Descriptor 

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

func (*Checkpoint) GetFrom 

func (m *Checkpoint) GetFrom() int64

func (*Checkpoint) GetSeq 

func (m *Checkpoint) GetSeq() uint64

func (*Checkpoint) GetTo 

func (m *Checkpoint) GetTo() int64

func (*Checkpoint) ProtoMessage 

func (*Checkpoint) ProtoMessage()

func (*Checkpoint) Reset 

func (m *Checkpoint) Reset()

func (*Checkpoint) String 

func (m *Checkpoint) String() string

func (*Checkpoint) XXX_DiscardUnknown 

func (m *Checkpoint) XXX_DiscardUnknown()

func (*Checkpoint) XXX_Marshal 

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

func (*Checkpoint) XXX_Merge 

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

func (*Checkpoint) XXX_Size 

func (m *Checkpoint) XXX_Size() int

func (*Checkpoint) XXX_Unmarshal 

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

type Event 

type Event struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Due                  int64    `protobuf:"varint,2,opt,name=due,proto3" json:"due,omitempty"`
	Attempt              uint32   `protobuf:"varint,3,opt,name=attempt,proto3" json:"attempt,omitempty"`
	Job                  *Job     `protobuf:"bytes,15,opt,name=job,proto3" json:"job,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

An Event is an occurence of a job executed at a specific time. There is one event per job execution.

func (*Event) Descriptor 

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

func (*Event) GetAttempt 

func (m *Event) GetAttempt() uint32

func (*Event) GetDue 

func (m *Event) GetDue() int64

func (*Event) GetId 

func (m *Event) GetId() string

func (*Event) GetJob 

func (m *Event) GetJob() *Job

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 Job 

type Job struct {
	Id                   string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Target               string      `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Due                  int64       `protobuf:"varint,3,opt,name=due,proto3" json:"due,omitempty"`
	Data                 []byte      `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Options              *JobOptions `protobuf:"bytes,14,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

A Job is a one-time task definition

func (*Job) Descriptor 

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

func (*Job) GetData 

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

func (*Job) GetDue 

func (m *Job) GetDue() int64

func (*Job) GetId 

func (m *Job) GetId() string

func (*Job) GetOptions 

func (m *Job) GetOptions() *JobOptions

func (*Job) GetTarget 

func (m *Job) GetTarget() string

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 JobOptions 

type JobOptions struct {
	RetryLimit           uint32   `protobuf:"varint,1,opt,name=retryLimit,proto3" json:"retryLimit,omitempty"`
	MinBackOff           int64    `protobuf:"varint,2,opt,name=minBackOff,proto3" json:"minBackOff,omitempty"`
	MaxBackOff           int64    `protobuf:"varint,3,opt,name=maxBackOff,proto3" json:"maxBackOff,omitempty"`
	AgeLimit             int64    `protobuf:"varint,4,opt,name=ageLimit,proto3" json:"ageLimit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

JobOptions contains job execution options

func (*JobOptions) Descriptor 

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

func (*JobOptions) GetAgeLimit 

func (m *JobOptions) GetAgeLimit() int64

func (*JobOptions) GetMaxBackOff 

func (m *JobOptions) GetMaxBackOff() int64

func (*JobOptions) GetMinBackOff 

func (m *JobOptions) GetMinBackOff() int64

func (*JobOptions) GetRetryLimit 

func (m *JobOptions) GetRetryLimit() uint32

func (*JobOptions) ProtoMessage 

func (*JobOptions) ProtoMessage()

func (*JobOptions) Reset 

func (m *JobOptions) Reset()

func (*JobOptions) String 

func (m *JobOptions) String() string

func (*JobOptions) XXX_DiscardUnknown 

func (m *JobOptions) XXX_DiscardUnknown()

func (*JobOptions) XXX_Marshal 

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

func (*JobOptions) XXX_Merge 

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

func (*JobOptions) XXX_Size 

func (m *JobOptions) XXX_Size() int

func (*JobOptions) XXX_Unmarshal 

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

type Partition 

type Partition struct {
	From                 int64    `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To                   int64    `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	Keys                 []string `protobuf:"bytes,3,rep,name=keys,proto3" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A Partition stores event keys within a specific time range

func (*Partition) Descriptor 

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

func (*Partition) GetFrom 

func (m *Partition) GetFrom() int64

func (*Partition) GetKeys 

func (m *Partition) GetKeys() []string

func (*Partition) GetTo 

func (m *Partition) GetTo() int64

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) Reset 

func (m *Partition) Reset()

func (*Partition) String 

func (m *Partition) String() string

func (*Partition) XXX_DiscardUnknown 

func (m *Partition) XXX_DiscardUnknown()

func (*Partition) XXX_Marshal 

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

func (*Partition) XXX_Merge 

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

func (*Partition) XXX_Size 

func (m *Partition) XXX_Size() int

func (*Partition) XXX_Unmarshal 

func (m *Partition) XXX_Unmarshal(b []byte) 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.