consts

Documentation

Index

• Constants
• Variables
• func ErrKafkaTopicEmpty(prefix string) error
• func ErrKakfaAddressEmpty(prefix string) error

Constants

const (
	CTX_KEY_INVOKER_LIB_PROCESSOR_NAME = contextKey("invoker_lib_processor_name")
	CTX_KEY_INVOKER_LIB_WORKER_ID      = contextKey("invoker_lib_worker_id")
	CTX_KEY_INVOKER_LIB_WORKER_INDEX   = contextKey("invoker_lib_worker_index")
	CTX_KEY_INVOKER_LIB_WORKER_TOPIC   = contextKey("invoker_lib_worker_topic")
	CTX_KEY_INVOKER_LIB_CRON           = contextKey("invoker_lib_cron")
)

const (
	REQUEST_KEY_COMMAND = "invoker_command"
	REQUEST_KEY_PARAMS  = "invoker_params"
)

const (
	MimeTypeJson              = "application/json"
	MimeTypeMultipartFormData = "multipart/form-data"
)

const (
	ProcessorTypeProcess = "process"
	ProcessorTypeJoin    = "join"
)

const CacheSize = 500 * 1024 * 1024

const DefaultCatLimit = 1000

const JoinKeyBufferMinCapacity = 8

const JoinMinWindowSize = 10

const MetricsNamespace = "invoker"

const RedisPingRetryTimes = 3

Variables

var (
	ErrProcessorTypeNotRecognized = fmt.Errorf("unrecognized processor type")
	ErrInputProcessorNotComplete  = fmt.Errorf("left input processor and right input processor must not be empty")
	ErrConfigNotInitialized       = fmt.Errorf("config is not initialized")
	ErrReadPtrSameAsWritePtr      = fmt.Errorf("read ptr is same as write ptr")
	ErrLockBufferFailure          = fmt.Errorf("fail to lock buffer")
	ErrLockSlotFailure            = fmt.Errorf("fail to lock slot")
	ErrStateStoreKeyNotExist      = fmt.Errorf("state store key does not exists")
)

Functions

func ErrKafkaTopicEmpty

func ErrKafkaTopicEmpty(prefix string) error

func ErrKakfaAddressEmpty

func ErrKakfaAddressEmpty(prefix string) error