common

package
v0.0.93 Latest Latest
Warning

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

 Go to latest Published: Nov 9, 2021 License: Apache-2.0 Imports: 3 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BackendType_name = map[int32]string{
	0:  "BACKEND_TYPE_UNSET",
	1:  "BACKEND_TYPE_KAFKA",
	2:  "BACKEND_TYPE_RABBIT",
	3:  "BACKEND_TYPE_RABBIT_STREAMS",
	4:  "BACKEND_TYPE_NSQ",
	5:  "BACKEND_TYPE_NATS",
	6:  "BACKEND_TYPE_NATS_STREAMING",
	7:  "BACKEND_TYPE_GCP_PUBSUB",
	8:  "BACKEND_TYPE_AZURE_SERVICE_BUS",
	9:  "BACKEND_TYPE_AZURE_EVENT_HUB",
	10: "BACKEND_TYPE_AWS_SQS",
	11: "BACKEND_TYPE_AWS_SNS",
	12: "BACKEND_TYPE_REDIS_PUBSUB",
	13: "BACKEND_TYPE_REDIS_STREAMS",
	14: "BACKEND_TYPE_ACTIVEMQ",
	15: "BACKEND_TYPE_PULSAR",
	16: "BACKEND_TYPE_MQTT",
	17: "BACKEND_TYPE_POSTGRES_CDC",
	18: "BACKEND_TYPE_MONGODB_CDC",
	19: "BACKEND_TYPE_KUBE_MQ",
}
View Source 
var BackendType_value = map[string]int32{
	"BACKEND_TYPE_UNSET":             0,
	"BACKEND_TYPE_KAFKA":             1,
	"BACKEND_TYPE_RABBIT":            2,
	"BACKEND_TYPE_RABBIT_STREAMS":    3,
	"BACKEND_TYPE_NSQ":               4,
	"BACKEND_TYPE_NATS":              5,
	"BACKEND_TYPE_NATS_STREAMING":    6,
	"BACKEND_TYPE_GCP_PUBSUB":        7,
	"BACKEND_TYPE_AZURE_SERVICE_BUS": 8,
	"BACKEND_TYPE_AZURE_EVENT_HUB":   9,
	"BACKEND_TYPE_AWS_SQS":           10,
	"BACKEND_TYPE_AWS_SNS":           11,
	"BACKEND_TYPE_REDIS_PUBSUB":      12,
	"BACKEND_TYPE_REDIS_STREAMS":     13,
	"BACKEND_TYPE_ACTIVEMQ":          14,
	"BACKEND_TYPE_PULSAR":            15,
	"BACKEND_TYPE_MQTT":              16,
	"BACKEND_TYPE_POSTGRES_CDC":      17,
	"BACKEND_TYPE_MONGODB_CDC":       18,
	"BACKEND_TYPE_KUBE_MQ":           19,
}
View Source 
var Code_name = map[int32]string{
	0:  "OK",
	1:  "CANCELLED",
	2:  "UNKNOWN",
	3:  "INVALID_ARGUMENT",
	4:  "DEADLINE_EXCEEDED",
	5:  "NOT_FOUND",
	6:  "ALREADY_EXISTS",
	7:  "PERMISSION_DENIED",
	16: "UNAUTHENTICATED",
	8:  "RESOURCE_EXHAUSTED",
	9:  "FAILED_PRECONDITION",
	10: "ABORTED",
	11: "OUT_OF_RANGE",
	12: "UNIMPLEMENTED",
	13: "INTERNAL",
	14: "UNAVAILABLE",
	15: "DATA_LOSS",
}
View Source 
var Code_value = map[string]int32{
	"OK":                  0,
	"CANCELLED":           1,
	"UNKNOWN":             2,
	"INVALID_ARGUMENT":    3,
	"DEADLINE_EXCEEDED":   4,
	"NOT_FOUND":           5,
	"ALREADY_EXISTS":      6,
	"PERMISSION_DENIED":   7,
	"UNAUTHENTICATED":     16,
	"RESOURCE_EXHAUSTED":  8,
	"FAILED_PRECONDITION": 9,
	"ABORTED":             10,
	"OUT_OF_RANGE":        11,
	"UNIMPLEMENTED":       12,
	"INTERNAL":            13,
	"UNAVAILABLE":         14,
	"DATA_LOSS":           15,
}

Functions

This section is empty.

Types

type Auth 

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

func (*Auth) Descriptor 

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

func (*Auth) GetToken 

func (m *Auth) GetToken() string

func (*Auth) ProtoMessage 

func (*Auth) ProtoMessage()

func (*Auth) Reset 

func (m *Auth) Reset()

func (*Auth) String 

func (m *Auth) String() string

func (*Auth) XXX_DiscardUnknown 

func (m *Auth) XXX_DiscardUnknown()

func (*Auth) XXX_Marshal 

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

func (*Auth) XXX_Merge 

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

func (*Auth) XXX_Size 

func (m *Auth) XXX_Size() int

func (*Auth) XXX_Unmarshal 

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

type BackendType added in v0.0.48 

type BackendType int32
const (
	BackendType_BACKEND_TYPE_UNSET             BackendType = 0
	BackendType_BACKEND_TYPE_KAFKA             BackendType = 1
	BackendType_BACKEND_TYPE_RABBIT            BackendType = 2
	BackendType_BACKEND_TYPE_RABBIT_STREAMS    BackendType = 3
	BackendType_BACKEND_TYPE_NSQ               BackendType = 4
	BackendType_BACKEND_TYPE_NATS              BackendType = 5
	BackendType_BACKEND_TYPE_NATS_STREAMING    BackendType = 6
	BackendType_BACKEND_TYPE_GCP_PUBSUB        BackendType = 7
	BackendType_BACKEND_TYPE_AZURE_SERVICE_BUS BackendType = 8
	BackendType_BACKEND_TYPE_AZURE_EVENT_HUB   BackendType = 9
	BackendType_BACKEND_TYPE_AWS_SQS           BackendType = 10
	BackendType_BACKEND_TYPE_AWS_SNS           BackendType = 11
	BackendType_BACKEND_TYPE_REDIS_PUBSUB      BackendType = 12
	BackendType_BACKEND_TYPE_REDIS_STREAMS     BackendType = 13
	BackendType_BACKEND_TYPE_ACTIVEMQ          BackendType = 14
	BackendType_BACKEND_TYPE_PULSAR            BackendType = 15
	BackendType_BACKEND_TYPE_MQTT              BackendType = 16
	BackendType_BACKEND_TYPE_POSTGRES_CDC      BackendType = 17
	BackendType_BACKEND_TYPE_MONGODB_CDC       BackendType = 18
	BackendType_BACKEND_TYPE_KUBE_MQ           BackendType = 19
)

func (BackendType) EnumDescriptor added in v0.0.48 

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

func (BackendType) String added in v0.0.48 

func (x BackendType) String() string

type Code 

type Code int32

https://github.com/googleapis/googleapis/blob/master/google/rpc/code.proto

The canonical error codes for gRPC APIs.

Sometimes multiple error codes may apply. Services should return the most specific error code that applies. For example, prefer `OUT_OF_RANGE` over `FAILED_PRECONDITION` if both codes apply. Similarly prefer `NOT_FOUND` or `ALREADY_EXISTS` over `FAILED_PRECONDITION`. 

const (
	// Not an error; returned on success
	//
	// HTTP Mapping: 200 OK
	Code_OK Code = 0
	// The operation was cancelled, typically by the caller.
	//
	// HTTP Mapping: 499 Client Closed Request
	Code_CANCELLED Code = 1
	// Unknown error.  For example, this error may be returned when
	// a `Status` value received from another address space belongs to
	// an error space that is not known in this address space.  Also
	// errors raised by APIs that do not return enough error information
	// may be converted to this error.
	//
	// HTTP Mapping: 500 Internal Server Error
	Code_UNKNOWN Code = 2
	// The client specified an invalid argument.  Note that this differs
	// from `FAILED_PRECONDITION`.  `INVALID_ARGUMENT` indicates arguments
	// that are problematic regardless of the state of the system
	// (e.g., a malformed file name).
	//
	// HTTP Mapping: 400 Bad Request
	Code_INVALID_ARGUMENT Code = 3
	// The deadline expired before the operation could complete. For operations
	// that change the state of the system, this error may be returned
	// even if the operation has completed successfully.  For example, a
	// successful response from a server could have been delayed long
	// enough for the deadline to expire.
	//
	// HTTP Mapping: 504 Gateway Timeout
	Code_DEADLINE_EXCEEDED Code = 4
	// Some requested entity (e.g., file or directory) was not found.
	//
	// Note to server developers: if a request is denied for an entire class
	// of users, such as gradual feature rollout or undocumented whitelist,
	// `NOT_FOUND` may be used. If a request is denied for some users within
	// a class of users, such as user-based access control, `PERMISSION_DENIED`
	// must be used.
	//
	// HTTP Mapping: 404 Not Found
	Code_NOT_FOUND Code = 5
	// The entity that a client attempted to create (e.g., file or directory)
	// already exists.
	//
	// HTTP Mapping: 409 Conflict
	Code_ALREADY_EXISTS Code = 6
	// The caller does not have permission to execute the specified
	// operation. `PERMISSION_DENIED` must not be used for rejections
	// caused by exhausting some resource (use `RESOURCE_EXHAUSTED`
	// instead for those errors). `PERMISSION_DENIED` must not be
	// used if the caller can not be identified (use `UNAUTHENTICATED`
	// instead for those errors). This error code does not imply the
	// request is valid or the requested entity exists or satisfies
	// other pre-conditions.
	//
	// HTTP Mapping: 403 Forbidden
	Code_PERMISSION_DENIED Code = 7
	// The request does not have valid authentication credentials for the
	// operation.
	//
	// HTTP Mapping: 401 Unauthorized
	Code_UNAUTHENTICATED Code = 16
	// Some resource has been exhausted, perhaps a per-user quota, or
	// perhaps the entire file system is out of space.
	//
	// HTTP Mapping: 429 Too Many Requests
	Code_RESOURCE_EXHAUSTED Code = 8
	// The operation was rejected because the system is not in a state
	// required for the operation's execution.  For example, the directory
	// to be deleted is non-empty, an rmdir operation is applied to
	// a non-directory, etc.
	//
	// Service implementors can use the following guidelines to decide
	// between `FAILED_PRECONDITION`, `ABORTED`, and `UNAVAILABLE`:
	//  (a) Use `UNAVAILABLE` if the client can retry just the failing call.
	//  (b) Use `ABORTED` if the client should retry at a higher level
	//      (e.g., when a client-specified test-and-set fails, indicating the
	//      client should restart a read-modify-write sequence).
	//  (c) Use `FAILED_PRECONDITION` if the client should not retry until
	//      the system state has been explicitly fixed.  E.g., if an "rmdir"
	//      fails because the directory is non-empty, `FAILED_PRECONDITION`
	//      should be returned since the client should not retry unless
	//      the files are deleted from the directory.
	//
	// HTTP Mapping: 400 Bad Request
	Code_FAILED_PRECONDITION Code = 9
	// The operation was aborted, typically due to a concurrency issue such as
	// a sequencer check failure or transaction abort.
	//
	// See the guidelines above for deciding between `FAILED_PRECONDITION`,
	// `ABORTED`, and `UNAVAILABLE`.
	//
	// HTTP Mapping: 409 Conflict
	Code_ABORTED Code = 10
	// The operation was attempted past the valid range.  E.g., seeking or
	// reading past end-of-file.
	//
	// Unlike `INVALID_ARGUMENT`, this error indicates a problem that may
	// be fixed if the system state changes. For example, a 32-bit file
	// system will generate `INVALID_ARGUMENT` if asked to read at an
	// offset that is not in the range [0,2^32-1], but it will generate
	// `OUT_OF_RANGE` if asked to read from an offset past the current
	// file size.
	//
	// There is a fair bit of overlap between `FAILED_PRECONDITION` and
	// `OUT_OF_RANGE`.  We recommend using `OUT_OF_RANGE` (the more specific
	// error) when it applies so that callers who are iterating through
	// a space can easily look for an `OUT_OF_RANGE` error to detect when
	// they are done.
	//
	// HTTP Mapping: 400 Bad Request
	Code_OUT_OF_RANGE Code = 11
	// The operation is not implemented or is not supported/enabled in this
	// service.
	//
	// HTTP Mapping: 501 Not Implemented
	Code_UNIMPLEMENTED Code = 12
	// Internal errors.  This means that some invariants expected by the
	// underlying system have been broken.  This error code is reserved
	// for serious errors.
	//
	// HTTP Mapping: 500 Internal Server Error
	Code_INTERNAL Code = 13
	// The service is currently unavailable.  This is most likely a
	// transient condition, which can be corrected by retrying with
	// a backoff. Note that it is not always safe to retry
	// non-idempotent operations.
	//
	// See the guidelines above for deciding between `FAILED_PRECONDITION`,
	// `ABORTED`, and `UNAVAILABLE`.
	//
	// HTTP Mapping: 503 Service Unavailable
	Code_UNAVAILABLE Code = 14
	// Unrecoverable data loss or corruption.
	//
	// HTTP Mapping: 500 Internal Server Error
	Code_DATA_LOSS Code = 15
)

func (Code) EnumDescriptor 

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

func (Code) String 

func (x Code) String() string

type Status 

type Status struct {
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=protos.common.Code" json:"code,omitempty"`
	// Message containing status details
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Set by the backend (to enable troubleshooting)
	RequestId            string   `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Status) Descriptor 

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

func (*Status) GetCode 

func (m *Status) GetCode() Code

func (*Status) GetMessage 

func (m *Status) GetMessage() string

func (*Status) GetRequestId 

func (m *Status) GetRequestId() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) String 

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

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

func (*Status) XXX_Merge 

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

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

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

type Validation added in v0.0.90 

type Validation struct {
	XId                  string              `protobuf:"bytes,1,opt,name=_id,json=Id,proto3" json:"_id,omitempty"`
	SchemaId             string              `protobuf:"bytes,2,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
	Fields               []*Validation_Field `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*Validation) Descriptor added in v0.0.90 

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

func (*Validation) GetFields added in v0.0.90 

func (m *Validation) GetFields() []*Validation_Field

func (*Validation) GetSchemaId added in v0.0.90 

func (m *Validation) GetSchemaId() string

func (*Validation) GetXId added in v0.0.90 

func (m *Validation) GetXId() string

func (*Validation) ProtoMessage added in v0.0.90 

func (*Validation) ProtoMessage()

func (*Validation) Reset added in v0.0.90 

func (m *Validation) Reset()

func (*Validation) String added in v0.0.90 

func (m *Validation) String() string

func (*Validation) XXX_DiscardUnknown added in v0.0.90 

func (m *Validation) XXX_DiscardUnknown()

func (*Validation) XXX_Marshal added in v0.0.90 

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

func (*Validation) XXX_Merge added in v0.0.90 

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

func (*Validation) XXX_Size added in v0.0.90 

func (m *Validation) XXX_Size() int

func (*Validation) XXX_Unmarshal added in v0.0.90 

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

type Validation_Field added in v0.0.90 

type Validation_Field struct {
	// path in our jsonquery filter syntax
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// https://github.com/batchcorp/lucene2x/blob/55f43862dfc294d5594758cba6a5c0ba088c0040/jsonquery/validate.go#L22
	ValidationType string `protobuf:"bytes,2,opt,name=validation_type,json=validationType,proto3" json:"validation_type,omitempty"`
	// For Regex / HasPrefix / HasSuffix / StringContains validation types only. Ignored for all others
	MatchValue           string   `protobuf:"bytes,3,opt,name=match_value,json=matchValue,proto3" json:"match_value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Validation_Field) Descriptor added in v0.0.90 

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

func (*Validation_Field) GetMatchValue added in v0.0.90 

func (m *Validation_Field) GetMatchValue() string

func (*Validation_Field) GetPath added in v0.0.90 

func (m *Validation_Field) GetPath() string

func (*Validation_Field) GetValidationType added in v0.0.90 

func (m *Validation_Field) GetValidationType() string

func (*Validation_Field) ProtoMessage added in v0.0.90 

func (*Validation_Field) ProtoMessage()

func (*Validation_Field) Reset added in v0.0.90 

func (m *Validation_Field) Reset()

func (*Validation_Field) String added in v0.0.90 

func (m *Validation_Field) String() string

func (*Validation_Field) XXX_DiscardUnknown added in v0.0.90 

func (m *Validation_Field) XXX_DiscardUnknown()

func (*Validation_Field) XXX_Marshal added in v0.0.90 

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

func (*Validation_Field) XXX_Merge added in v0.0.90 

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

func (*Validation_Field) XXX_Size added in v0.0.90 

func (m *Validation_Field) XXX_Size() int

func (*Validation_Field) XXX_Unmarshal added in v0.0.90 

func (m *Validation_Field) 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.