Documentation ¶
Index ¶
- Variables
- type Function
- func (*Function) Descriptor() ([]byte, []int)deprecated
- func (x *Function) GetDescription() string
- func (x *Function) GetParams() []*FunctionParameter
- func (x *Function) GetType() *FunctionType
- func (*Function) ProtoMessage()
- func (x *Function) ProtoReflect() protoreflect.Message
- func (x *Function) Reset()
- func (x *Function) String() string
- type FunctionContext
- func (*FunctionContext) Descriptor() ([]byte, []int)deprecated
- func (x *FunctionContext) GetFunctionType() *FunctionType
- func (x *FunctionContext) GetId() string
- func (x *FunctionContext) GetReplyResult() *ReplyResult
- func (x *FunctionContext) GetValue() []byte
- func (*FunctionContext) ProtoMessage()
- func (x *FunctionContext) ProtoReflect() protoreflect.Message
- func (x *FunctionContext) Reset()
- func (x *FunctionContext) String() string
- type FunctionMessage
- func (*FunctionMessage) Descriptor() ([]byte, []int)deprecated
- func (x *FunctionMessage) GetMountpoint() string
- func (x *FunctionMessage) GetRoute() *FunctionRoute
- func (x *FunctionMessage) GetType() string
- func (*FunctionMessage) ProtoMessage()
- func (x *FunctionMessage) ProtoReflect() protoreflect.Message
- func (x *FunctionMessage) Reset()
- func (x *FunctionMessage) String() string
- type FunctionParameter
- func (*FunctionParameter) Descriptor() ([]byte, []int)deprecated
- func (x *FunctionParameter) GetDefault() *any.Any
- func (x *FunctionParameter) GetName() string
- func (x *FunctionParameter) GetType() string
- func (*FunctionParameter) ProtoMessage()
- func (x *FunctionParameter) ProtoReflect() protoreflect.Message
- func (x *FunctionParameter) Reset()
- func (x *FunctionParameter) String() string
- type FunctionResult
- func (*FunctionResult) Descriptor() ([]byte, []int)deprecated
- func (x *FunctionResult) GetComplete() bool
- func (x *FunctionResult) GetErrors() []string
- func (x *FunctionResult) GetReplyEgress() *ReplyResult
- func (*FunctionResult) ProtoMessage()
- func (x *FunctionResult) ProtoReflect() protoreflect.Message
- func (x *FunctionResult) Reset()
- func (x *FunctionResult) String() string
- type FunctionRoute
- type FunctionType
- func (*FunctionType) Descriptor() ([]byte, []int)deprecated
- func (x *FunctionType) GetNamespace() string
- func (x *FunctionType) GetType() string
- func (*FunctionType) ProtoMessage()
- func (x *FunctionType) ProtoReflect() protoreflect.Message
- func (x *FunctionType) Reset()
- func (x *FunctionType) String() string
- type ReplyResult
- func (*ReplyResult) Descriptor() ([]byte, []int)deprecated
- func (x *ReplyResult) GetId() string
- func (x *ReplyResult) GetKey() string
- func (x *ReplyResult) GetNamespace() string
- func (x *ReplyResult) GetTopic() string
- func (*ReplyResult) ProtoMessage()
- func (x *ReplyResult) ProtoReflect() protoreflect.Message
- func (x *ReplyResult) Reset()
- func (x *ReplyResult) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_pbtypes_pbfunction_proto protoreflect.FileDescriptor
View Source
var File_pbtypes_pbresult_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Function ¶
type Function struct { Type *FunctionType `protobuf:"bytes,1,opt,name=type,json=function_type,proto3" json:"type,omitempty"` Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` Params []*FunctionParameter `protobuf:"bytes,3,rep,name=params,proto3" json:"params,omitempty"` // contains filtered or unexported fields }
Function - is a CMDB object which represent Flink's stateful function
func (*Function) Descriptor
deprecated
func (*Function) GetDescription ¶
func (*Function) GetParams ¶
func (x *Function) GetParams() []*FunctionParameter
func (*Function) GetType ¶
func (x *Function) GetType() *FunctionType
func (*Function) ProtoMessage ¶
func (*Function) ProtoMessage()
func (*Function) ProtoReflect ¶
func (x *Function) ProtoReflect() protoreflect.Message
type FunctionContext ¶
type FunctionContext struct { FunctionType *FunctionType `protobuf:"bytes,1,opt,name=function_type,proto3" json:"function_type,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` ReplyResult *ReplyResult `protobuf:"bytes,4,opt,name=reply_result,proto3" json:"reply_result,omitempty"` // contains filtered or unexported fields }
func (*FunctionContext) Descriptor
deprecated
func (*FunctionContext) Descriptor() ([]byte, []int)
Deprecated: Use FunctionContext.ProtoReflect.Descriptor instead.
func (*FunctionContext) GetFunctionType ¶
func (x *FunctionContext) GetFunctionType() *FunctionType
func (*FunctionContext) GetId ¶
func (x *FunctionContext) GetId() string
func (*FunctionContext) GetReplyResult ¶
func (x *FunctionContext) GetReplyResult() *ReplyResult
func (*FunctionContext) GetValue ¶
func (x *FunctionContext) GetValue() []byte
func (*FunctionContext) ProtoMessage ¶
func (*FunctionContext) ProtoMessage()
func (*FunctionContext) ProtoReflect ¶
func (x *FunctionContext) ProtoReflect() protoreflect.Message
func (*FunctionContext) Reset ¶
func (x *FunctionContext) Reset()
func (*FunctionContext) String ¶
func (x *FunctionContext) String() string
type FunctionMessage ¶
type FunctionMessage struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Mountpoint string `protobuf:"bytes,2,opt,name=mountpoint,proto3" json:"mountpoint,omitempty"` Route *FunctionRoute `protobuf:"bytes,3,opt,name=route,proto3" json:"route,omitempty"` // contains filtered or unexported fields }
func (*FunctionMessage) Descriptor
deprecated
func (*FunctionMessage) Descriptor() ([]byte, []int)
Deprecated: Use FunctionMessage.ProtoReflect.Descriptor instead.
func (*FunctionMessage) GetMountpoint ¶
func (x *FunctionMessage) GetMountpoint() string
func (*FunctionMessage) GetRoute ¶
func (x *FunctionMessage) GetRoute() *FunctionRoute
func (*FunctionMessage) GetType ¶
func (x *FunctionMessage) GetType() string
func (*FunctionMessage) ProtoMessage ¶
func (*FunctionMessage) ProtoMessage()
func (*FunctionMessage) ProtoReflect ¶
func (x *FunctionMessage) ProtoReflect() protoreflect.Message
func (*FunctionMessage) Reset ¶
func (x *FunctionMessage) Reset()
func (*FunctionMessage) String ¶
func (x *FunctionMessage) String() string
type FunctionParameter ¶
type FunctionParameter struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Default *any.Any `protobuf:"bytes,3,opt,name=default,proto3" json:"default,omitempty"` // contains filtered or unexported fields }
func (*FunctionParameter) Descriptor
deprecated
func (*FunctionParameter) Descriptor() ([]byte, []int)
Deprecated: Use FunctionParameter.ProtoReflect.Descriptor instead.
func (*FunctionParameter) GetDefault ¶
func (x *FunctionParameter) GetDefault() *any.Any
func (*FunctionParameter) GetName ¶
func (x *FunctionParameter) GetName() string
func (*FunctionParameter) GetType ¶
func (x *FunctionParameter) GetType() string
func (*FunctionParameter) ProtoMessage ¶
func (*FunctionParameter) ProtoMessage()
func (*FunctionParameter) ProtoReflect ¶
func (x *FunctionParameter) ProtoReflect() protoreflect.Message
func (*FunctionParameter) Reset ¶
func (x *FunctionParameter) Reset()
func (*FunctionParameter) String ¶
func (x *FunctionParameter) String() string
type FunctionResult ¶
type FunctionResult struct { ReplyEgress *ReplyResult `protobuf:"bytes,1,opt,name=reply_egress,json=replyEgress,proto3" json:"reply_egress,omitempty"` Complete bool `protobuf:"varint,2,opt,name=complete,proto3" json:"complete,omitempty"` Errors []string `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"` // contains filtered or unexported fields }
func (*FunctionResult) Descriptor
deprecated
func (*FunctionResult) Descriptor() ([]byte, []int)
Deprecated: Use FunctionResult.ProtoReflect.Descriptor instead.
func (*FunctionResult) GetComplete ¶
func (x *FunctionResult) GetComplete() bool
func (*FunctionResult) GetErrors ¶
func (x *FunctionResult) GetErrors() []string
func (*FunctionResult) GetReplyEgress ¶
func (x *FunctionResult) GetReplyEgress() *ReplyResult
func (*FunctionResult) ProtoMessage ¶
func (*FunctionResult) ProtoMessage()
func (*FunctionResult) ProtoReflect ¶
func (x *FunctionResult) ProtoReflect() protoreflect.Message
func (*FunctionResult) Reset ¶
func (x *FunctionResult) Reset()
func (*FunctionResult) String ¶
func (x *FunctionResult) String() string
type FunctionRoute ¶
type FunctionRoute struct { Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` // contains filtered or unexported fields }
FunctionRoute - is a LinkMessage from cmdb.Object to Function
func (*FunctionRoute) Descriptor
deprecated
func (*FunctionRoute) Descriptor() ([]byte, []int)
Deprecated: Use FunctionRoute.ProtoReflect.Descriptor instead.
func (*FunctionRoute) GetUrl ¶
func (x *FunctionRoute) GetUrl() string
func (*FunctionRoute) ProtoMessage ¶
func (*FunctionRoute) ProtoMessage()
func (*FunctionRoute) ProtoReflect ¶
func (x *FunctionRoute) ProtoReflect() protoreflect.Message
func (*FunctionRoute) Reset ¶
func (x *FunctionRoute) Reset()
func (*FunctionRoute) String ¶
func (x *FunctionRoute) String() string
type FunctionType ¶
type FunctionType struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*FunctionType) Descriptor
deprecated
func (*FunctionType) Descriptor() ([]byte, []int)
Deprecated: Use FunctionType.ProtoReflect.Descriptor instead.
func (*FunctionType) GetNamespace ¶
func (x *FunctionType) GetNamespace() string
func (*FunctionType) GetType ¶
func (x *FunctionType) GetType() string
func (*FunctionType) ProtoMessage ¶
func (*FunctionType) ProtoMessage()
func (*FunctionType) ProtoReflect ¶
func (x *FunctionType) ProtoReflect() protoreflect.Message
func (*FunctionType) Reset ¶
func (x *FunctionType) Reset()
func (*FunctionType) String ¶
func (x *FunctionType) String() string
type ReplyResult ¶
type ReplyResult struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` Key string `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*ReplyResult) Descriptor
deprecated
func (*ReplyResult) Descriptor() ([]byte, []int)
Deprecated: Use ReplyResult.ProtoReflect.Descriptor instead.
func (*ReplyResult) GetId ¶
func (x *ReplyResult) GetId() string
func (*ReplyResult) GetKey ¶
func (x *ReplyResult) GetKey() string
func (*ReplyResult) GetNamespace ¶
func (x *ReplyResult) GetNamespace() string
func (*ReplyResult) GetTopic ¶
func (x *ReplyResult) GetTopic() string
func (*ReplyResult) ProtoMessage ¶
func (*ReplyResult) ProtoMessage()
func (*ReplyResult) ProtoReflect ¶
func (x *ReplyResult) ProtoReflect() protoreflect.Message
func (*ReplyResult) Reset ¶
func (x *ReplyResult) Reset()
func (*ReplyResult) String ¶
func (x *ReplyResult) String() string
Click to show internal directories.
Click to hide internal directories.