Versions in this module Expand all Collapse all v0 v0.3.1 Dec 6, 2024 Changes in this version + var File_proto_api_failurepolicy_proto protoreflect.FileDescriptor + var File_proto_api_job_proto protoreflect.FileDescriptor + var File_proto_api_list_proto protoreflect.FileDescriptor + var File_proto_api_trigger_proto protoreflect.FileDescriptor + var TriggerResponseResult_name = map[int32]string + var TriggerResponseResult_value = map[string]int32 + type FailurePolicy struct + Policy isFailurePolicy_Policy + func (*FailurePolicy) Descriptor() ([]byte, []int) + func (*FailurePolicy) ProtoMessage() + func (m *FailurePolicy) GetPolicy() isFailurePolicy_Policy + func (x *FailurePolicy) GetConstant() *FailurePolicyConstant + func (x *FailurePolicy) GetDrop() *FailurePolicyDrop + func (x *FailurePolicy) ProtoReflect() protoreflect.Message + func (x *FailurePolicy) Reset() + func (x *FailurePolicy) String() string + type FailurePolicyConstant struct + Interval *durationpb.Duration + MaxRetries *uint32 + func (*FailurePolicyConstant) Descriptor() ([]byte, []int) + func (*FailurePolicyConstant) ProtoMessage() + func (x *FailurePolicyConstant) GetInterval() *durationpb.Duration + func (x *FailurePolicyConstant) GetMaxRetries() uint32 + func (x *FailurePolicyConstant) ProtoReflect() protoreflect.Message + func (x *FailurePolicyConstant) Reset() + func (x *FailurePolicyConstant) String() string + type FailurePolicyDrop struct + func (*FailurePolicyDrop) Descriptor() ([]byte, []int) + func (*FailurePolicyDrop) ProtoMessage() + func (x *FailurePolicyDrop) ProtoReflect() protoreflect.Message + func (x *FailurePolicyDrop) Reset() + func (x *FailurePolicyDrop) String() string + type FailurePolicy_Constant struct + Constant *FailurePolicyConstant + type FailurePolicy_Drop struct + Drop *FailurePolicyDrop + type Interface interface + Add func(ctx context.Context, name string, job *Job) error + Delete func(ctx context.Context, name string) error + DeletePrefixes func(ctx context.Context, prefixes ...string) error + DeliverablePrefixes func(ctx context.Context, prefixes ...string) (context.CancelFunc, error) + Get func(ctx context.Context, name string) (*Job, error) + List func(ctx context.Context, prefix string) (*ListResponse, error) + Run func(ctx context.Context) error type Job + FailurePolicy *FailurePolicy + func (x *Job) GetFailurePolicy() *FailurePolicy + type ListResponse struct + Jobs []*NamedJob + func (*ListResponse) Descriptor() ([]byte, []int) + func (*ListResponse) ProtoMessage() + func (x *ListResponse) GetJobs() []*NamedJob + func (x *ListResponse) ProtoReflect() protoreflect.Message + func (x *ListResponse) Reset() + func (x *ListResponse) String() string + type NamedJob struct + Job *Job + Name string + func (*NamedJob) Descriptor() ([]byte, []int) + func (*NamedJob) ProtoMessage() + func (x *NamedJob) GetJob() *Job + func (x *NamedJob) GetName() string + func (x *NamedJob) ProtoReflect() protoreflect.Message + func (x *NamedJob) Reset() + func (x *NamedJob) String() string + type TriggerFunction func(context.Context, *TriggerRequest) *TriggerResponse + type TriggerResponse struct + Result TriggerResponseResult + func (*TriggerResponse) Descriptor() ([]byte, []int) + func (*TriggerResponse) ProtoMessage() + func (x *TriggerResponse) GetResult() TriggerResponseResult + func (x *TriggerResponse) ProtoReflect() protoreflect.Message + func (x *TriggerResponse) Reset() + func (x *TriggerResponse) String() string + type TriggerResponseResult int32 + const TriggerResponseResult_FAILED + const TriggerResponseResult_SUCCESS + const TriggerResponseResult_UNDELIVERABLE + func (TriggerResponseResult) Descriptor() protoreflect.EnumDescriptor + func (TriggerResponseResult) EnumDescriptor() ([]byte, []int) + func (TriggerResponseResult) Type() protoreflect.EnumType + func (x TriggerResponseResult) Enum() *TriggerResponseResult + func (x TriggerResponseResult) Number() protoreflect.EnumNumber + func (x TriggerResponseResult) String() string v0.3.0 Sep 5, 2024 v0.2.3 Aug 6, 2024 v0.2.2 Jul 24, 2024 v0.2.1 Jul 24, 2024 v0.2.0 Jul 22, 2024 v0.1.0 Jun 25, 2024 Changes in this version + var File_proto_counter_proto protoreflect.FileDescriptor + var File_proto_job_proto protoreflect.FileDescriptor + var File_proto_trigger_proto protoreflect.FileDescriptor + type Counter struct + Count uint32 + JobPartitionId uint32 + LastTrigger *timestamppb.Timestamp + func (*Counter) Descriptor() ([]byte, []int) + func (*Counter) ProtoMessage() + func (x *Counter) GetCount() uint32 + func (x *Counter) GetJobPartitionId() uint32 + func (x *Counter) GetLastTrigger() *timestamppb.Timestamp + func (x *Counter) ProtoReflect() protoreflect.Message + func (x *Counter) Reset() + func (x *Counter) String() string + type Job struct + DueTime *string + Metadata *anypb.Any + Payload *anypb.Any + Repeats *uint32 + Schedule *string + Ttl *string + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (x *Job) GetDueTime() string + func (x *Job) GetMetadata() *anypb.Any + func (x *Job) GetPayload() *anypb.Any + func (x *Job) GetRepeats() uint32 + func (x *Job) GetSchedule() string + func (x *Job) GetTtl() string + func (x *Job) ProtoReflect() protoreflect.Message + func (x *Job) Reset() + func (x *Job) String() string + type JobStored struct + Begin isJobStored_Begin + Expiration *timestamppb.Timestamp + Job *Job + PartitionId uint32 + func (*JobStored) Descriptor() ([]byte, []int) + func (*JobStored) ProtoMessage() + func (m *JobStored) GetBegin() isJobStored_Begin + func (x *JobStored) GetDueTime() *timestamppb.Timestamp + func (x *JobStored) GetExpiration() *timestamppb.Timestamp + func (x *JobStored) GetJob() *Job + func (x *JobStored) GetPartitionId() uint32 + func (x *JobStored) GetStart() *timestamppb.Timestamp + func (x *JobStored) ProtoReflect() protoreflect.Message + func (x *JobStored) Reset() + func (x *JobStored) String() string + type JobStored_DueTime struct + DueTime *timestamppb.Timestamp + type JobStored_Start struct + Start *timestamppb.Timestamp + type TriggerRequest struct + Metadata *anypb.Any + Name string + Payload *anypb.Any + func (*TriggerRequest) Descriptor() ([]byte, []int) + func (*TriggerRequest) ProtoMessage() + func (x *TriggerRequest) GetMetadata() *anypb.Any + func (x *TriggerRequest) GetName() string + func (x *TriggerRequest) GetPayload() *anypb.Any + func (x *TriggerRequest) ProtoReflect() protoreflect.Message + func (x *TriggerRequest) Reset() + func (x *TriggerRequest) String() string
Go to main page