batch

Documentation

Index

• Variables
• func RegisterBatchServiceServer(s *grpc.Server, srv BatchServiceServer)
• type BatchJob
  • func (BatchJob) Descriptor() protoreflect.EnumDescriptor
  • func (x BatchJob) Enum() *BatchJob
  • func (BatchJob) EnumDescriptor() ([]byte, []int)
  • func (x BatchJob) Number() protoreflect.EnumNumber
  • func (x BatchJob) String() string
  • func (BatchJob) Type() protoreflect.EnumType
• type BatchJobRequest
  • func (*BatchJobRequest) Descriptor() ([]byte, []int)
  • func (x *BatchJobRequest) GetJob() BatchJob
  • func (*BatchJobRequest) ProtoMessage()
  • func (x *BatchJobRequest) ProtoReflect() protoreflect.Message
  • func (x *BatchJobRequest) Reset()
  • func (x *BatchJobRequest) String() string
• type BatchJobResponse
  • func (*BatchJobResponse) Descriptor() ([]byte, []int)
  • func (*BatchJobResponse) ProtoMessage()
  • func (x *BatchJobResponse) ProtoReflect() protoreflect.Message
  • func (x *BatchJobResponse) Reset()
  • func (x *BatchJobResponse) String() string
• type BatchServiceClient
  • func NewBatchServiceClient(cc grpc.ClientConnInterface) BatchServiceClient
• type BatchServiceServer
• type UnimplementedBatchServiceServer
  • func (*UnimplementedBatchServiceServer) ExecuteBatchJob(context.Context, *BatchJobRequest) (*BatchJobResponse, error)

Variables

var (
	BatchJob_name = map[int32]string{
		0:  "ExperimentStatusUpdater",
		1:  "ExperimentRunningWatcher",
		2:  "FeatureStaleWatcher",
		3:  "MauCountWatcher",
		4:  "DatetimeWatcher",
		5:  "EventCountWatcher",
		6:  "DomainEventInformer",
		7:  "RedisCounterDeleter",
		8:  "ProgressiveRolloutWatcher",
		9:  "ExperimentCalculator",
		10: "MauSummarizer",
		11: "MauPartitionDeleter",
		12: "MauPartitionCreator",
		13: "FeatureFlagCacher",
		14: "SegmentUserCacher",
		15: "ApiKeyCacher",
		16: "AutoOpsRulesCacher",
		17: "ExperimentCacher",
	}
	BatchJob_value = map[string]int32{
		"ExperimentStatusUpdater":   0,
		"ExperimentRunningWatcher":  1,
		"FeatureStaleWatcher":       2,
		"MauCountWatcher":           3,
		"DatetimeWatcher":           4,
		"EventCountWatcher":         5,
		"DomainEventInformer":       6,
		"RedisCounterDeleter":       7,
		"ProgressiveRolloutWatcher": 8,
		"ExperimentCalculator":      9,
		"MauSummarizer":             10,
		"MauPartitionDeleter":       11,
		"MauPartitionCreator":       12,
		"FeatureFlagCacher":         13,
		"SegmentUserCacher":         14,
		"ApiKeyCacher":              15,
		"AutoOpsRulesCacher":        16,
		"ExperimentCacher":          17,
	}
)

Enum value maps for BatchJob.

var File_proto_batch_service_proto protoreflect.FileDescriptor

Functions

func RegisterBatchServiceServer

func RegisterBatchServiceServer(s *grpc.Server, srv BatchServiceServer)

Types

type BatchJob

type BatchJob int32

const (
	BatchJob_ExperimentStatusUpdater   BatchJob = 0
	BatchJob_ExperimentRunningWatcher  BatchJob = 1
	BatchJob_FeatureStaleWatcher       BatchJob = 2
	BatchJob_MauCountWatcher           BatchJob = 3
	BatchJob_DatetimeWatcher           BatchJob = 4
	BatchJob_EventCountWatcher         BatchJob = 5
	BatchJob_DomainEventInformer       BatchJob = 6
	BatchJob_RedisCounterDeleter       BatchJob = 7
	BatchJob_ProgressiveRolloutWatcher BatchJob = 8
	BatchJob_ExperimentCalculator      BatchJob = 9
	BatchJob_MauSummarizer             BatchJob = 10
	BatchJob_MauPartitionDeleter       BatchJob = 11
	BatchJob_MauPartitionCreator       BatchJob = 12
	BatchJob_FeatureFlagCacher         BatchJob = 13
	BatchJob_SegmentUserCacher         BatchJob = 14
	BatchJob_ApiKeyCacher              BatchJob = 15
	BatchJob_AutoOpsRulesCacher        BatchJob = 16
	BatchJob_ExperimentCacher          BatchJob = 17
)

func (BatchJob) Descriptor

func (BatchJob) Descriptor() protoreflect.EnumDescriptor

func (BatchJob) Enum

func (x BatchJob) Enum() *BatchJob

func (BatchJob) EnumDescriptor

func (BatchJob) EnumDescriptor() ([]byte, []int)

Deprecated: Use BatchJob.Descriptor instead.

func (BatchJob) Number

func (x BatchJob) Number() protoreflect.EnumNumber

func (BatchJob) String

func (x BatchJob) String() string

func (BatchJob) Type

func (BatchJob) Type() protoreflect.EnumType

type BatchJobRequest

type BatchJobRequest struct {
	Job BatchJob `protobuf:"varint,1,opt,name=job,proto3,enum=bucketeer.batch.BatchJob" json:"job"`
	// contains filtered or unexported fields
}

func (*BatchJobRequest) Descriptor

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

Deprecated: Use BatchJobRequest.ProtoReflect.Descriptor instead.

func (*BatchJobRequest) GetJob

func (x *BatchJobRequest) GetJob() BatchJob

func (*BatchJobRequest) ProtoMessage

func (*BatchJobRequest) ProtoMessage()

func (*BatchJobRequest) ProtoReflect

func (x *BatchJobRequest) ProtoReflect() protoreflect.Message

func (*BatchJobRequest) Reset

func (x *BatchJobRequest) Reset()

func (*BatchJobRequest) String

func (x *BatchJobRequest) String() string

type BatchJobResponse

type BatchJobResponse struct {
	// contains filtered or unexported fields
}

func (*BatchJobResponse) Descriptor

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

Deprecated: Use BatchJobResponse.ProtoReflect.Descriptor instead.

func (*BatchJobResponse) ProtoMessage

func (*BatchJobResponse) ProtoMessage()

func (*BatchJobResponse) ProtoReflect

func (x *BatchJobResponse) ProtoReflect() protoreflect.Message

func (*BatchJobResponse) Reset

func (x *BatchJobResponse) Reset()

func (*BatchJobResponse) String

func (x *BatchJobResponse) String() string

type BatchServiceClient

type BatchServiceClient interface {
	ExecuteBatchJob(ctx context.Context, in *BatchJobRequest, opts ...grpc.CallOption) (*BatchJobResponse, error)
}

BatchServiceClient is the client API for BatchService service.

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

func NewBatchServiceClient

func NewBatchServiceClient(cc grpc.ClientConnInterface) BatchServiceClient

type BatchServiceServer

type BatchServiceServer interface {
	ExecuteBatchJob(context.Context, *BatchJobRequest) (*BatchJobResponse, error)
}

BatchServiceServer is the server API for BatchService service.

type UnimplementedBatchServiceServer

type UnimplementedBatchServiceServer struct {
}

UnimplementedBatchServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedBatchServiceServer) ExecuteBatchJob

func (*UnimplementedBatchServiceServer) ExecuteBatchJob(context.Context, *BatchJobRequest) (*BatchJobResponse, error)