gapi

package module
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2020 License: MIT Imports: 15 Imported by: 0

README

grpc-api-go

Documentation

Index

Constants

View Source 
const (
	AnyPipe = ""
)

Variables

View Source 
var FlowStatus_name = map[int32]string{
	0: "STOPPED",
	1: "STARTING",
	2: "RUNNING",
}
View Source 
var FlowStatus_value = map[string]int32{
	"STOPPED":  0,
	"STARTING": 1,
	"RUNNING":  2,
}
View Source 
var FlowUIVariableType_name = map[int32]string{
	0: "UNDEFINED",
	1: "BUTTON",
}
View Source 
var FlowUIVariableType_value = map[string]int32{
	"UNDEFINED": 0,
	"BUTTON":    1,
}
View Source 
var PipeDescriptorParamView_Type_name = map[int32]string{
	0: "TextInput",
	1: "NumberInput",
}
View Source 
var PipeDescriptorParamView_Type_value = map[string]int32{
	"TextInput":   0,
	"NumberInput": 1,
}
View Source 
var PipeDescriptorParam_Type_name = map[int32]string{
	0: "Unknown",
	1: "Int",
	2: "String",
	3: "Bool",
	4: "JSON",
	5: "JS",
}
View Source 
var PipeDescriptorParam_Type_value = map[string]int32{
	"Unknown": 0,
	"Int":     1,
	"String":  2,
	"Bool":    3,
	"JSON":    4,
	"JS":      5,
}
View Source 
var SortDirection_name = map[int32]string{
	0: "NO_SORT",
	1: "ASC",
	2: "DESC",
}
View Source 
var SortDirection_value = map[string]int32{
	"NO_SORT": 0,
	"ASC":     1,
	"DESC":    2,
}
View Source 
var Sort_By_name = map[int32]string{
	0: "ASC",
	1: "DESC",
}
View Source 
var Sort_By_value = map[string]int32{
	"ASC":  0,
	"DESC": 1,
}
View Source 
var VarType_name = map[int32]string{
	0: "INT",
	1: "BOOL",
	2: "STRING",
}
View Source 
var VarType_value = map[string]int32{
	"INT":    0,
	"BOOL":   1,
	"STRING": 2,
}

Functions

func AnyMap 

func AnyMap(m map[string]interface{}) map[string]*Any

func InterfaceMap 

func InterfaceMap(m map[string]*Any) map[string]interface{}

func RegisterDeviceServiceServer 

func RegisterDeviceServiceServer(s *grpc.Server, srv DeviceServiceServer)

func RegisterDeviceTypeServiceServer 

func RegisterDeviceTypeServiceServer(s *grpc.Server, srv DeviceTypeServiceServer)

func RegisterFlowDescriptorServiceServer 

func RegisterFlowDescriptorServiceServer(s *grpc.Server, srv FlowDescriptorServiceServer)

func RegisterFlowServiceServer 

func RegisterFlowServiceServer(s *grpc.Server, srv FlowServiceServer)

func RegisterPipeDescriptorServiceServer 

func RegisterPipeDescriptorServiceServer(s *grpc.Server, srv PipeDescriptorServiceServer)

func RegisterPluginReceiveServiceServer 

func RegisterPluginReceiveServiceServer(s *grpc.Server, srv PluginReceiveServiceServer)

func RegisterPluginSendServiceServer 

func RegisterPluginSendServiceServer(s *grpc.Server, srv PluginSendServiceServer)

func RegisterPluginServiceServer 

func RegisterPluginServiceServer(s *grpc.Server, srv PluginServiceServer)

func RegisterUserServiceServer 

func RegisterUserServiceServer(s *grpc.Server, srv UserServiceServer)

func SendMsg 

func SendMsg(ctx context.Context, fromPipe *PipeExt, fromOutputID string, msg map[string]*Any)

func SendStreamMsg 

func SendStreamMsg(ctx context.Context, fromPipe *Pipe, fromOutputID string, msg map[string]*Any)

Types

type ActivePipe 

type ActivePipe interface {
	InitPipe(req *InitPipeReq)
	DestroyPipe(req *DestroyPipeReq)
}

type AddDeviceReq 

type AddDeviceReq struct {
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	DeviceTypeId         string   `protobuf:"bytes,3,opt,name=device_type_id,json=deviceTypeId,proto3" json:"device_type_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddDeviceReq) Descriptor 

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

func (*AddDeviceReq) GetDeviceTypeId 

func (m *AddDeviceReq) GetDeviceTypeId() string

func (*AddDeviceReq) GetName 

func (m *AddDeviceReq) GetName() string

func (*AddDeviceReq) ProtoMessage 

func (*AddDeviceReq) ProtoMessage()

func (*AddDeviceReq) Reset 

func (m *AddDeviceReq) Reset()

func (*AddDeviceReq) String 

func (m *AddDeviceReq) String() string

func (*AddDeviceReq) XXX_DiscardUnknown 

func (m *AddDeviceReq) XXX_DiscardUnknown()

func (*AddDeviceReq) XXX_Marshal 

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

func (*AddDeviceReq) XXX_Merge 

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

func (*AddDeviceReq) XXX_Size 

func (m *AddDeviceReq) XXX_Size() int

func (*AddDeviceReq) XXX_Unmarshal 

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

type AddDeviceRes 

type AddDeviceRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddDeviceRes) Descriptor 

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

func (*AddDeviceRes) GetId 

func (m *AddDeviceRes) GetId() string

func (*AddDeviceRes) GetOk 

func (m *AddDeviceRes) GetOk() bool

func (*AddDeviceRes) ProtoMessage 

func (*AddDeviceRes) ProtoMessage()

func (*AddDeviceRes) Reset 

func (m *AddDeviceRes) Reset()

func (*AddDeviceRes) String 

func (m *AddDeviceRes) String() string

func (*AddDeviceRes) XXX_DiscardUnknown 

func (m *AddDeviceRes) XXX_DiscardUnknown()

func (*AddDeviceRes) XXX_Marshal 

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

func (*AddDeviceRes) XXX_Merge 

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

func (*AddDeviceRes) XXX_Size 

func (m *AddDeviceRes) XXX_Size() int

func (*AddDeviceRes) XXX_Unmarshal 

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

type AddDeviceTypeReq 

type AddDeviceTypeReq struct {
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	FlowDescriptorId     string   `protobuf:"bytes,4,opt,name=flow_descriptor_id,json=flowDescriptorId,proto3" json:"flow_descriptor_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddDeviceTypeReq) Descriptor 

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

func (*AddDeviceTypeReq) GetFlowDescriptorId 

func (m *AddDeviceTypeReq) GetFlowDescriptorId() string

func (*AddDeviceTypeReq) GetName 

func (m *AddDeviceTypeReq) GetName() string

func (*AddDeviceTypeReq) ProtoMessage 

func (*AddDeviceTypeReq) ProtoMessage()

func (*AddDeviceTypeReq) Reset 

func (m *AddDeviceTypeReq) Reset()

func (*AddDeviceTypeReq) String 

func (m *AddDeviceTypeReq) String() string

func (*AddDeviceTypeReq) XXX_DiscardUnknown 

func (m *AddDeviceTypeReq) XXX_DiscardUnknown()

func (*AddDeviceTypeReq) XXX_Marshal 

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

func (*AddDeviceTypeReq) XXX_Merge 

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

func (*AddDeviceTypeReq) XXX_Size 

func (m *AddDeviceTypeReq) XXX_Size() int

func (*AddDeviceTypeReq) XXX_Unmarshal 

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

type AddDeviceTypeRes 

type AddDeviceTypeRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddDeviceTypeRes) Descriptor 

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

func (*AddDeviceTypeRes) GetId 

func (m *AddDeviceTypeRes) GetId() string

func (*AddDeviceTypeRes) GetOk 

func (m *AddDeviceTypeRes) GetOk() bool

func (*AddDeviceTypeRes) ProtoMessage 

func (*AddDeviceTypeRes) ProtoMessage()

func (*AddDeviceTypeRes) Reset 

func (m *AddDeviceTypeRes) Reset()

func (*AddDeviceTypeRes) String 

func (m *AddDeviceTypeRes) String() string

func (*AddDeviceTypeRes) XXX_DiscardUnknown 

func (m *AddDeviceTypeRes) XXX_DiscardUnknown()

func (*AddDeviceTypeRes) XXX_Marshal 

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

func (*AddDeviceTypeRes) XXX_Merge 

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

func (*AddDeviceTypeRes) XXX_Size 

func (m *AddDeviceTypeRes) XXX_Size() int

func (*AddDeviceTypeRes) XXX_Unmarshal 

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

type AddFlowDescriptorReq 

type AddFlowDescriptorReq struct {
	Name                 string                    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Variables            []*FlowVariableDescriptor `protobuf:"bytes,2,rep,name=variables,proto3" json:"variables,omitempty"`
	Pipes                []*Pipe                   `protobuf:"bytes,3,rep,name=pipes,proto3" json:"pipes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*AddFlowDescriptorReq) Descriptor 

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

func (*AddFlowDescriptorReq) GetName 

func (m *AddFlowDescriptorReq) GetName() string

func (*AddFlowDescriptorReq) GetPipes 

func (m *AddFlowDescriptorReq) GetPipes() []*Pipe

func (*AddFlowDescriptorReq) GetVariables 

func (m *AddFlowDescriptorReq) GetVariables() []*FlowVariableDescriptor

func (*AddFlowDescriptorReq) ProtoMessage 

func (*AddFlowDescriptorReq) ProtoMessage()

func (*AddFlowDescriptorReq) Reset 

func (m *AddFlowDescriptorReq) Reset()

func (*AddFlowDescriptorReq) String 

func (m *AddFlowDescriptorReq) String() string

func (*AddFlowDescriptorReq) XXX_DiscardUnknown 

func (m *AddFlowDescriptorReq) XXX_DiscardUnknown()

func (*AddFlowDescriptorReq) XXX_Marshal 

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

func (*AddFlowDescriptorReq) XXX_Merge 

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

func (*AddFlowDescriptorReq) XXX_Size 

func (m *AddFlowDescriptorReq) XXX_Size() int

func (*AddFlowDescriptorReq) XXX_Unmarshal 

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

type AddFlowDescriptorRes 

type AddFlowDescriptorRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddFlowDescriptorRes) Descriptor 

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

func (*AddFlowDescriptorRes) GetId 

func (m *AddFlowDescriptorRes) GetId() string

func (*AddFlowDescriptorRes) GetOk 

func (m *AddFlowDescriptorRes) GetOk() bool

func (*AddFlowDescriptorRes) ProtoMessage 

func (*AddFlowDescriptorRes) ProtoMessage()

func (*AddFlowDescriptorRes) Reset 

func (m *AddFlowDescriptorRes) Reset()

func (*AddFlowDescriptorRes) String 

func (m *AddFlowDescriptorRes) String() string

func (*AddFlowDescriptorRes) XXX_DiscardUnknown 

func (m *AddFlowDescriptorRes) XXX_DiscardUnknown()

func (*AddFlowDescriptorRes) XXX_Marshal 

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

func (*AddFlowDescriptorRes) XXX_Merge 

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

func (*AddFlowDescriptorRes) XXX_Size 

func (m *AddFlowDescriptorRes) XXX_Size() int

func (*AddFlowDescriptorRes) XXX_Unmarshal 

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

type AddFlowReq 

type AddFlowReq struct {
	FlowDescriptorId     string   `protobuf:"bytes,1,opt,name=flow_descriptor_id,json=flowDescriptorId,proto3" json:"flow_descriptor_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddFlowReq) Descriptor 

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

func (*AddFlowReq) GetFlowDescriptorId 

func (m *AddFlowReq) GetFlowDescriptorId() string

func (*AddFlowReq) ProtoMessage 

func (*AddFlowReq) ProtoMessage()

func (*AddFlowReq) Reset 

func (m *AddFlowReq) Reset()

func (*AddFlowReq) String 

func (m *AddFlowReq) String() string

func (*AddFlowReq) XXX_DiscardUnknown 

func (m *AddFlowReq) XXX_DiscardUnknown()

func (*AddFlowReq) XXX_Marshal 

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

func (*AddFlowReq) XXX_Merge 

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

func (*AddFlowReq) XXX_Size 

func (m *AddFlowReq) XXX_Size() int

func (*AddFlowReq) XXX_Unmarshal 

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

type AddFlowRes 

type AddFlowRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddFlowRes) Descriptor 

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

func (*AddFlowRes) GetId 

func (m *AddFlowRes) GetId() string

func (*AddFlowRes) GetOk 

func (m *AddFlowRes) GetOk() bool

func (*AddFlowRes) ProtoMessage 

func (*AddFlowRes) ProtoMessage()

func (*AddFlowRes) Reset 

func (m *AddFlowRes) Reset()

func (*AddFlowRes) String 

func (m *AddFlowRes) String() string

func (*AddFlowRes) XXX_DiscardUnknown 

func (m *AddFlowRes) XXX_DiscardUnknown()

func (*AddFlowRes) XXX_Marshal 

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

func (*AddFlowRes) XXX_Merge 

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

func (*AddFlowRes) XXX_Size 

func (m *AddFlowRes) XXX_Size() int

func (*AddFlowRes) XXX_Unmarshal 

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

type AddPipeDescriptorReq 

type AddPipeDescriptorReq struct {
	Name                 string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description          string                 `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	PluginId             string                 `protobuf:"bytes,3,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	Params               []*PipeDescriptorParam `protobuf:"bytes,5,rep,name=params,proto3" json:"params,omitempty"`
	Inputs               []string               `protobuf:"bytes,6,rep,name=inputs,proto3" json:"inputs,omitempty"`
	InputsExp            string                 `protobuf:"bytes,9,opt,name=inputs_exp,json=inputsExp,proto3" json:"inputs_exp,omitempty"`
	Outputs              []string               `protobuf:"bytes,7,rep,name=outputs,proto3" json:"outputs,omitempty"`
	OutputsExp           string                 `protobuf:"bytes,10,opt,name=outputs_exp,json=outputsExp,proto3" json:"outputs_exp,omitempty"`
	NeedInit             bool                   `protobuf:"varint,8,opt,name=need_init,json=needInit,proto3" json:"need_init,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*AddPipeDescriptorReq) Descriptor 

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

func (*AddPipeDescriptorReq) GetDescription 

func (m *AddPipeDescriptorReq) GetDescription() string

func (*AddPipeDescriptorReq) GetInputs 

func (m *AddPipeDescriptorReq) GetInputs() []string

func (*AddPipeDescriptorReq) GetInputsExp 

func (m *AddPipeDescriptorReq) GetInputsExp() string

func (*AddPipeDescriptorReq) GetName 

func (m *AddPipeDescriptorReq) GetName() string

func (*AddPipeDescriptorReq) GetNeedInit 

func (m *AddPipeDescriptorReq) GetNeedInit() bool

func (*AddPipeDescriptorReq) GetOutputs 

func (m *AddPipeDescriptorReq) GetOutputs() []string

func (*AddPipeDescriptorReq) GetOutputsExp 

func (m *AddPipeDescriptorReq) GetOutputsExp() string

func (*AddPipeDescriptorReq) GetParams 

func (m *AddPipeDescriptorReq) GetParams() []*PipeDescriptorParam

func (*AddPipeDescriptorReq) GetPluginId 

func (m *AddPipeDescriptorReq) GetPluginId() string

func (*AddPipeDescriptorReq) ProtoMessage 

func (*AddPipeDescriptorReq) ProtoMessage()

func (*AddPipeDescriptorReq) Reset 

func (m *AddPipeDescriptorReq) Reset()

func (*AddPipeDescriptorReq) String 

func (m *AddPipeDescriptorReq) String() string

func (*AddPipeDescriptorReq) XXX_DiscardUnknown 

func (m *AddPipeDescriptorReq) XXX_DiscardUnknown()

func (*AddPipeDescriptorReq) XXX_Marshal 

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

func (*AddPipeDescriptorReq) XXX_Merge 

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

func (*AddPipeDescriptorReq) XXX_Size 

func (m *AddPipeDescriptorReq) XXX_Size() int

func (*AddPipeDescriptorReq) XXX_Unmarshal 

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

type AddPipeDescriptorRes 

type AddPipeDescriptorRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddPipeDescriptorRes) Descriptor 

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

func (*AddPipeDescriptorRes) GetId 

func (m *AddPipeDescriptorRes) GetId() string

func (*AddPipeDescriptorRes) GetOk 

func (m *AddPipeDescriptorRes) GetOk() bool

func (*AddPipeDescriptorRes) ProtoMessage 

func (*AddPipeDescriptorRes) ProtoMessage()

func (*AddPipeDescriptorRes) Reset 

func (m *AddPipeDescriptorRes) Reset()

func (*AddPipeDescriptorRes) String 

func (m *AddPipeDescriptorRes) String() string

func (*AddPipeDescriptorRes) XXX_DiscardUnknown 

func (m *AddPipeDescriptorRes) XXX_DiscardUnknown()

func (*AddPipeDescriptorRes) XXX_Marshal 

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

func (*AddPipeDescriptorRes) XXX_Merge 

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

func (*AddPipeDescriptorRes) XXX_Size 

func (m *AddPipeDescriptorRes) XXX_Size() int

func (*AddPipeDescriptorRes) XXX_Unmarshal 

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

type AddPluginReq 

type AddPluginReq struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PluginUri            string   `protobuf:"bytes,2,opt,name=plugin_uri,json=pluginUri,proto3" json:"plugin_uri,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddPluginReq) Descriptor 

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

func (*AddPluginReq) GetName 

func (m *AddPluginReq) GetName() string

func (*AddPluginReq) GetPluginUri 

func (m *AddPluginReq) GetPluginUri() string

func (*AddPluginReq) ProtoMessage 

func (*AddPluginReq) ProtoMessage()

func (*AddPluginReq) Reset 

func (m *AddPluginReq) Reset()

func (*AddPluginReq) String 

func (m *AddPluginReq) String() string

func (*AddPluginReq) XXX_DiscardUnknown 

func (m *AddPluginReq) XXX_DiscardUnknown()

func (*AddPluginReq) XXX_Marshal 

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

func (*AddPluginReq) XXX_Merge 

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

func (*AddPluginReq) XXX_Size 

func (m *AddPluginReq) XXX_Size() int

func (*AddPluginReq) XXX_Unmarshal 

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

type AddPluginRes 

type AddPluginRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddPluginRes) Descriptor 

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

func (*AddPluginRes) GetId 

func (m *AddPluginRes) GetId() string

func (*AddPluginRes) GetOk 

func (m *AddPluginRes) GetOk() bool

func (*AddPluginRes) ProtoMessage 

func (*AddPluginRes) ProtoMessage()

func (*AddPluginRes) Reset 

func (m *AddPluginRes) Reset()

func (*AddPluginRes) String 

func (m *AddPluginRes) String() string

func (*AddPluginRes) XXX_DiscardUnknown 

func (m *AddPluginRes) XXX_DiscardUnknown()

func (*AddPluginRes) XXX_Marshal 

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

func (*AddPluginRes) XXX_Merge 

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

func (*AddPluginRes) XXX_Size 

func (m *AddPluginRes) XXX_Size() int

func (*AddPluginRes) XXX_Unmarshal 

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

type Any 

type Any struct {
	// Types that are valid to be assigned to Value:
	//	*Any_StrValue
	//	*Any_MsgpackValue
	//	*Any_BoolValue
	//	*Any_Int32Value
	//	*Any_Int64Value
	//	*Any_Uint32Value
	//	*Any_Uint64Value
	//	*Any_FloatValue
	//	*Any_DoubleValue
	//	*Any_BinaryValue
	//	*Any_NilValue
	Value                isAny_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func NewAny 

func NewAny(i interface{}) *Any

NewAny create Any with value, which maybe a bool, int, uint, float, string, array, slice and map

func NewAnyInt32 added in v1.0.1 

func NewAnyInt32(i int) *Any

func (*Any) Descriptor 

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

func (*Any) Equal 

func (any *Any) Equal(any2 *Any) bool

Equal returns true if any equal to any2

func (*Any) GetBinaryValue 

func (m *Any) GetBinaryValue() []byte

func (*Any) GetBoolValue 

func (m *Any) GetBoolValue() bool

func (*Any) GetDoubleValue 

func (m *Any) GetDoubleValue() float64

func (*Any) GetFloatValue 

func (m *Any) GetFloatValue() float32

func (*Any) GetInt32Value 

func (m *Any) GetInt32Value() int32

func (*Any) GetInt64Value 

func (m *Any) GetInt64Value() int64

func (*Any) GetMsgpackValue 

func (m *Any) GetMsgpackValue() []byte

func (*Any) GetNilValue 

func (m *Any) GetNilValue() bool

func (*Any) GetStrValue 

func (m *Any) GetStrValue() string

func (*Any) GetUint32Value 

func (m *Any) GetUint32Value() uint32

func (*Any) GetUint64Value 

func (m *Any) GetUint64Value() uint64

func (*Any) GetValue 

func (m *Any) GetValue() isAny_Value

func (*Any) IsBinary 

func (any *Any) IsBinary() bool

IsBinary returns true if it is a []byte

func (*Any) IsBool 

func (any *Any) IsBool() bool

IsBool returns true if it is a bool

func (*Any) IsFloat 

func (any *Any) IsFloat() bool

IsFloat returns true if it is a float

func (*Any) IsFloat32 

func (any *Any) IsFloat32() bool

IsFloat32 returns true if it is a float32

func (*Any) IsFloat64 

func (any *Any) IsFloat64() bool

IsFloat64 returns true if it is a float64

func (*Any) IsInt 

func (any *Any) IsInt() bool

IsInt returns true if it is a int

func (*Any) IsInt32 

func (any *Any) IsInt32() bool

IsInt32 returns true if it is a int32

func (*Any) IsInt64 

func (any *Any) IsInt64() bool

IsInt64 returns true if it is a int64

func (*Any) IsMsgpack 

func (any *Any) IsMsgpack() bool

IsMsgpack returns true if it is a array, slice, map or other value

func (*Any) IsString 

func (any *Any) IsString() bool

IsString returns true if it is a string

func (*Any) IsUint 

func (any *Any) IsUint() bool

IsUint returns true if it is a uint

func (*Any) IsUint32 

func (any *Any) IsUint32() bool

IsUint32 returns true if it is a uint32

func (*Any) IsUint64 

func (any *Any) IsUint64() bool

IsUint64 returns true if it is a uint64

func (*Any) Parse 

func (any *Any) Parse() (interface{}, error)

Parse return value

func (*Any) ParseTo 

func (any *Any) ParseTo(value interface{}) error

ParseTo parse any to value

func (*Any) ProtoMessage 

func (*Any) ProtoMessage()

func (*Any) Reset 

func (m *Any) Reset()

func (*Any) String 

func (m *Any) String() string

func (*Any) ToBinary 

func (any *Any) ToBinary() []byte

func (*Any) ToBoolean 

func (any *Any) ToBoolean() bool

func (*Any) ToFloat32 

func (any *Any) ToFloat32() float32

func (*Any) ToFloat64 

func (any *Any) ToFloat64() float64

func (*Any) ToInt32 

func (any *Any) ToInt32() int32

func (*Any) ToInt64 

func (any *Any) ToInt64() int64

func (*Any) ToString 

func (any *Any) ToString() string

func (*Any) ToUint32 

func (any *Any) ToUint32() uint32

func (*Any) ToUint64 

func (any *Any) ToUint64() uint64

func (*Any) XXX_DiscardUnknown 

func (m *Any) XXX_DiscardUnknown()

func (*Any) XXX_Marshal 

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

func (*Any) XXX_Merge 

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

func (*Any) XXX_OneofWrappers 

func (*Any) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Any) XXX_Size 

func (m *Any) XXX_Size() int

func (*Any) XXX_Unmarshal 

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

type Any_BinaryValue 

type Any_BinaryValue struct {
	BinaryValue []byte `protobuf:"bytes,11,opt,name=binary_value,json=binaryValue,proto3,oneof"`
}

type Any_BoolValue 

type Any_BoolValue struct {
	BoolValue bool `protobuf:"varint,4,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type Any_DoubleValue 

type Any_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,10,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type Any_FloatValue 

type Any_FloatValue struct {
	FloatValue float32 `protobuf:"fixed32,9,opt,name=float_value,json=floatValue,proto3,oneof"`
}

type Any_Int32Value 

type Any_Int32Value struct {
	Int32Value int32 `protobuf:"varint,5,opt,name=int32_value,json=int32Value,proto3,oneof"`
}

type Any_Int64Value 

type Any_Int64Value struct {
	Int64Value int64 `protobuf:"varint,6,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

type Any_MsgpackValue 

type Any_MsgpackValue struct {
	MsgpackValue []byte `protobuf:"bytes,2,opt,name=msgpack_value,json=msgpackValue,proto3,oneof"`
}

type Any_NilValue 

type Any_NilValue struct {
	NilValue bool `protobuf:"varint,12,opt,name=nil_value,json=nilValue,proto3,oneof"`
}

type Any_StrValue 

type Any_StrValue struct {
	StrValue string `protobuf:"bytes,1,opt,name=str_value,json=strValue,proto3,oneof"`
}

type Any_Uint32Value 

type Any_Uint32Value struct {
	Uint32Value uint32 `protobuf:"varint,7,opt,name=uint32_value,json=uint32Value,proto3,oneof"`
}

type Any_Uint64Value 

type Any_Uint64Value struct {
	Uint64Value uint64 `protobuf:"varint,8,opt,name=uint64_value,json=uint64Value,proto3,oneof"`
}

type ChangeUserPasswordReq 

type ChangeUserPasswordReq struct {
	OldPass              string   `protobuf:"bytes,1,opt,name=old_pass,json=oldPass,proto3" json:"old_pass,omitempty"`
	NewPass              string   `protobuf:"bytes,2,opt,name=new_pass,json=newPass,proto3" json:"new_pass,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChangeUserPasswordReq) Descriptor 

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

func (*ChangeUserPasswordReq) GetNewPass 

func (m *ChangeUserPasswordReq) GetNewPass() string

func (*ChangeUserPasswordReq) GetOldPass 

func (m *ChangeUserPasswordReq) GetOldPass() string

func (*ChangeUserPasswordReq) ProtoMessage 

func (*ChangeUserPasswordReq) ProtoMessage()

func (*ChangeUserPasswordReq) Reset 

func (m *ChangeUserPasswordReq) Reset()

func (*ChangeUserPasswordReq) String 

func (m *ChangeUserPasswordReq) String() string

func (*ChangeUserPasswordReq) XXX_DiscardUnknown 

func (m *ChangeUserPasswordReq) XXX_DiscardUnknown()

func (*ChangeUserPasswordReq) XXX_Marshal 

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

func (*ChangeUserPasswordReq) XXX_Merge 

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

func (*ChangeUserPasswordReq) XXX_Size 

func (m *ChangeUserPasswordReq) XXX_Size() int

func (*ChangeUserPasswordReq) XXX_Unmarshal 

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

type ChangeUserPasswordRes 

type ChangeUserPasswordRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChangeUserPasswordRes) Descriptor 

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

func (*ChangeUserPasswordRes) GetOk 

func (m *ChangeUserPasswordRes) GetOk() bool

func (*ChangeUserPasswordRes) ProtoMessage 

func (*ChangeUserPasswordRes) ProtoMessage()

func (*ChangeUserPasswordRes) Reset 

func (m *ChangeUserPasswordRes) Reset()

func (*ChangeUserPasswordRes) String 

func (m *ChangeUserPasswordRes) String() string

func (*ChangeUserPasswordRes) XXX_DiscardUnknown 

func (m *ChangeUserPasswordRes) XXX_DiscardUnknown()

func (*ChangeUserPasswordRes) XXX_Marshal 

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

func (*ChangeUserPasswordRes) XXX_Merge 

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

func (*ChangeUserPasswordRes) XXX_Size 

func (m *ChangeUserPasswordRes) XXX_Size() int

func (*ChangeUserPasswordRes) XXX_Unmarshal 

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

type CreateUserReq 

type CreateUserReq struct {
	Email                string   `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	Pass                 string   `protobuf:"bytes,2,opt,name=pass,proto3" json:"pass,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateUserReq) Descriptor 

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

func (*CreateUserReq) GetEmail 

func (m *CreateUserReq) GetEmail() string

func (*CreateUserReq) GetPass 

func (m *CreateUserReq) GetPass() string

func (*CreateUserReq) ProtoMessage 

func (*CreateUserReq) ProtoMessage()

func (*CreateUserReq) Reset 

func (m *CreateUserReq) Reset()

func (*CreateUserReq) String 

func (m *CreateUserReq) String() string

func (*CreateUserReq) XXX_DiscardUnknown 

func (m *CreateUserReq) XXX_DiscardUnknown()

func (*CreateUserReq) XXX_Marshal 

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

func (*CreateUserReq) XXX_Merge 

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

func (*CreateUserReq) XXX_Size 

func (m *CreateUserReq) XXX_Size() int

func (*CreateUserReq) XXX_Unmarshal 

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

type DestroyPipeReq 

type DestroyPipeReq struct {
	PipeId               string   `protobuf:"bytes,1,opt,name=pipe_id,json=pipeId,proto3" json:"pipe_id,omitempty"`
	PipeDescriptorName   string   `protobuf:"bytes,2,opt,name=pipe_descriptor_name,json=pipeDescriptorName,proto3" json:"pipe_descriptor_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DestroyPipeReq) Descriptor 

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

func (*DestroyPipeReq) GetPipeDescriptorName 

func (m *DestroyPipeReq) GetPipeDescriptorName() string

func (*DestroyPipeReq) GetPipeId 

func (m *DestroyPipeReq) GetPipeId() string

func (*DestroyPipeReq) ProtoMessage 

func (*DestroyPipeReq) ProtoMessage()

func (*DestroyPipeReq) Reset 

func (m *DestroyPipeReq) Reset()

func (*DestroyPipeReq) String 

func (m *DestroyPipeReq) String() string

func (*DestroyPipeReq) XXX_DiscardUnknown 

func (m *DestroyPipeReq) XXX_DiscardUnknown()

func (*DestroyPipeReq) XXX_Marshal 

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

func (*DestroyPipeReq) XXX_Merge 

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

func (*DestroyPipeReq) XXX_Size 

func (m *DestroyPipeReq) XXX_Size() int

func (*DestroyPipeReq) XXX_Unmarshal 

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

type DestroyPipeRes 

type DestroyPipeRes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DestroyPipeRes) Descriptor 

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

func (*DestroyPipeRes) ProtoMessage 

func (*DestroyPipeRes) ProtoMessage()

func (*DestroyPipeRes) Reset 

func (m *DestroyPipeRes) Reset()

func (*DestroyPipeRes) String 

func (m *DestroyPipeRes) String() string

func (*DestroyPipeRes) XXX_DiscardUnknown 

func (m *DestroyPipeRes) XXX_DiscardUnknown()

func (*DestroyPipeRes) XXX_Marshal 

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

func (*DestroyPipeRes) XXX_Merge 

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

func (*DestroyPipeRes) XXX_Size 

func (m *DestroyPipeRes) XXX_Size() int

func (*DestroyPipeRes) XXX_Unmarshal 

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

type Device 

type Device struct {
	Id                   string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	DeviceTypeId         string    `protobuf:"bytes,3,opt,name=device_type_id,json=deviceTypeId,proto3" json:"device_type_id,omitempty"`
	UserId               string    `protobuf:"bytes,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	CreatedAt            *UnixTime `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Device) Descriptor 

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

func (*Device) GetCreatedAt 

func (m *Device) GetCreatedAt() *UnixTime

func (*Device) GetDeviceTypeId 

func (m *Device) GetDeviceTypeId() string

func (*Device) GetId 

func (m *Device) GetId() string

func (*Device) GetName 

func (m *Device) GetName() string

func (*Device) GetUserId 

func (m *Device) GetUserId() string

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) Reset 

func (m *Device) Reset()

func (*Device) String 

func (m *Device) String() string

func (*Device) XXX_DiscardUnknown 

func (m *Device) XXX_DiscardUnknown()

func (*Device) XXX_Marshal 

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

func (*Device) XXX_Merge 

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

func (*Device) XXX_Size 

func (m *Device) XXX_Size() int

func (*Device) XXX_Unmarshal 

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

type DeviceServiceClient 

type DeviceServiceClient interface {
	GetDevice(ctx context.Context, in *GetDeviceReq, opts ...grpc.CallOption) (*Device, error)
	AddDevice(ctx context.Context, in *AddDeviceReq, opts ...grpc.CallOption) (*AddDeviceRes, error)
	UpdateDevice(ctx context.Context, in *UpdateDeviceReq, opts ...grpc.CallOption) (*UpdateDeviceRes, error)
	RemoveDevice(ctx context.Context, in *RemoveDeviceReq, opts ...grpc.CallOption) (*RemoveDeviceRes, error)
	ListDevices(ctx context.Context, in *ListDevicesReq, opts ...grpc.CallOption) (*ListDevicesRes, error)
}

DeviceServiceClient is the client API for DeviceService service.

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

func NewDeviceServiceClient 

func NewDeviceServiceClient(cc *grpc.ClientConn) DeviceServiceClient

type DeviceServiceServer 

type DeviceServiceServer interface {
	GetDevice(context.Context, *GetDeviceReq) (*Device, error)
	AddDevice(context.Context, *AddDeviceReq) (*AddDeviceRes, error)
	UpdateDevice(context.Context, *UpdateDeviceReq) (*UpdateDeviceRes, error)
	RemoveDevice(context.Context, *RemoveDeviceReq) (*RemoveDeviceRes, error)
	ListDevices(context.Context, *ListDevicesReq) (*ListDevicesRes, error)
}

DeviceServiceServer is the server API for DeviceService service.

type DeviceType 

type DeviceType struct {
	Id                   string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	FlowDescriptorId     string    `protobuf:"bytes,4,opt,name=flow_descriptor_id,json=flowDescriptorId,proto3" json:"flow_descriptor_id,omitempty"`
	UserId               string    `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	CreatedAt            *UnixTime `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DeviceType) Descriptor 

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

func (*DeviceType) GetCreatedAt 

func (m *DeviceType) GetCreatedAt() *UnixTime

func (*DeviceType) GetFlowDescriptorId 

func (m *DeviceType) GetFlowDescriptorId() string

func (*DeviceType) GetId 

func (m *DeviceType) GetId() string

func (*DeviceType) GetName 

func (m *DeviceType) GetName() string

func (*DeviceType) GetUserId 

func (m *DeviceType) GetUserId() string

func (*DeviceType) ProtoMessage 

func (*DeviceType) ProtoMessage()

func (*DeviceType) Reset 

func (m *DeviceType) Reset()

func (*DeviceType) String 

func (m *DeviceType) String() string

func (*DeviceType) XXX_DiscardUnknown 

func (m *DeviceType) XXX_DiscardUnknown()

func (*DeviceType) XXX_Marshal 

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

func (*DeviceType) XXX_Merge 

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

func (*DeviceType) XXX_Size 

func (m *DeviceType) XXX_Size() int

func (*DeviceType) XXX_Unmarshal 

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

type DeviceTypeServiceClient 

type DeviceTypeServiceClient interface {
	GetDeviceType(ctx context.Context, in *GetDeviceTypeReq, opts ...grpc.CallOption) (*DeviceType, error)
	AddDeviceType(ctx context.Context, in *AddDeviceTypeReq, opts ...grpc.CallOption) (*AddDeviceTypeRes, error)
	UpdateDeviceType(ctx context.Context, in *UpdateDeviceTypeReq, opts ...grpc.CallOption) (*UpdateDeviceTypeRes, error)
	RemoveDeviceType(ctx context.Context, in *RemoveDeviceTypeReq, opts ...grpc.CallOption) (*RemoveDeviceTypeRes, error)
	ListDeviceTypes(ctx context.Context, in *ListDeviceTypesReq, opts ...grpc.CallOption) (*ListDeviceTypesRes, error)
}

DeviceTypeServiceClient is the client API for DeviceTypeService service.

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

func NewDeviceTypeServiceClient 

func NewDeviceTypeServiceClient(cc *grpc.ClientConn) DeviceTypeServiceClient

type DeviceTypeServiceServer 

type DeviceTypeServiceServer interface {
	GetDeviceType(context.Context, *GetDeviceTypeReq) (*DeviceType, error)
	AddDeviceType(context.Context, *AddDeviceTypeReq) (*AddDeviceTypeRes, error)
	UpdateDeviceType(context.Context, *UpdateDeviceTypeReq) (*UpdateDeviceTypeRes, error)
	RemoveDeviceType(context.Context, *RemoveDeviceTypeReq) (*RemoveDeviceTypeRes, error)
	ListDeviceTypes(context.Context, *ListDeviceTypesReq) (*ListDeviceTypesRes, error)
}

DeviceTypeServiceServer is the server API for DeviceTypeService service.

type Flow 

type Flow struct {
	Id                   string          `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	FlowDescriptorId     string          `protobuf:"bytes,3,opt,name=flow_descriptor_id,json=flowDescriptorId,proto3" json:"flow_descriptor_id,omitempty"`
	Status               FlowStatus      `protobuf:"varint,4,opt,name=status,proto3,enum=schema.FlowStatus" json:"status,omitempty"`
	CreatedAt            *UnixTime       `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            *UnixTime       `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Variables            map[string]*Any `` /* 159-byte string literal not displayed */
	UiVariables          map[string]*Any `` /* 182-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Flow) Descriptor 

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

func (*Flow) GetCreatedAt 

func (m *Flow) GetCreatedAt() *UnixTime

func (*Flow) GetFlowDescriptorId 

func (m *Flow) GetFlowDescriptorId() string

func (*Flow) GetId 

func (m *Flow) GetId() string

func (*Flow) GetStatus 

func (m *Flow) GetStatus() FlowStatus

func (*Flow) GetUiVariables 

func (m *Flow) GetUiVariables() map[string]*Any

func (*Flow) GetUpdatedAt 

func (m *Flow) GetUpdatedAt() *UnixTime

func (*Flow) GetVariables 

func (m *Flow) GetVariables() map[string]*Any

func (*Flow) ProtoMessage 

func (*Flow) ProtoMessage()

func (*Flow) Reset 

func (m *Flow) Reset()

func (*Flow) String 

func (m *Flow) String() string

func (*Flow) XXX_DiscardUnknown 

func (m *Flow) XXX_DiscardUnknown()

func (*Flow) XXX_Marshal 

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

func (*Flow) XXX_Merge 

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

func (*Flow) XXX_Size 

func (m *Flow) XXX_Size() int

func (*Flow) XXX_Unmarshal 

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

type FlowDescriptor 

type FlowDescriptor struct {
	Id                   string                      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string                      `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	Variables            []*FlowVariableDescriptor   `protobuf:"bytes,2,rep,name=variables,proto3" json:"variables,omitempty"`
	UiVariables          []*FlowUIVariableDescriptor `protobuf:"bytes,8,rep,name=ui_variables,json=uiVariables,proto3" json:"ui_variables,omitempty"`
	Pipes                []*Pipe                     `protobuf:"bytes,3,rep,name=pipes,proto3" json:"pipes,omitempty"`
	UserId               string                      `protobuf:"bytes,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	CreatedAt            *UnixTime                   `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            *UnixTime                   `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*FlowDescriptor) Descriptor 

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

func (*FlowDescriptor) GetCreatedAt 

func (m *FlowDescriptor) GetCreatedAt() *UnixTime

func (*FlowDescriptor) GetId 

func (m *FlowDescriptor) GetId() string

func (*FlowDescriptor) GetName 

func (m *FlowDescriptor) GetName() string

func (*FlowDescriptor) GetPipes 

func (m *FlowDescriptor) GetPipes() []*Pipe

func (*FlowDescriptor) GetUiVariables 

func (m *FlowDescriptor) GetUiVariables() []*FlowUIVariableDescriptor

func (*FlowDescriptor) GetUpdatedAt 

func (m *FlowDescriptor) GetUpdatedAt() *UnixTime

func (*FlowDescriptor) GetUserId 

func (m *FlowDescriptor) GetUserId() string

func (*FlowDescriptor) GetVariables 

func (m *FlowDescriptor) GetVariables() []*FlowVariableDescriptor

func (*FlowDescriptor) ProtoMessage 

func (*FlowDescriptor) ProtoMessage()

func (*FlowDescriptor) Reset 

func (m *FlowDescriptor) Reset()

func (*FlowDescriptor) String 

func (m *FlowDescriptor) String() string

func (*FlowDescriptor) XXX_DiscardUnknown 

func (m *FlowDescriptor) XXX_DiscardUnknown()

func (*FlowDescriptor) XXX_Marshal 

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

func (*FlowDescriptor) XXX_Merge 

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

func (*FlowDescriptor) XXX_Size 

func (m *FlowDescriptor) XXX_Size() int

func (*FlowDescriptor) XXX_Unmarshal 

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

type FlowDescriptorServiceClient 

type FlowDescriptorServiceClient interface {
	GetFlowDescriptor(ctx context.Context, in *GetFlowDescriptorReq, opts ...grpc.CallOption) (*FlowDescriptor, error)
	AddFlowDescriptor(ctx context.Context, in *AddFlowDescriptorReq, opts ...grpc.CallOption) (*AddFlowDescriptorRes, error)
	UpdateFlowDescriptor(ctx context.Context, in *UpdateFlowDescriptorReq, opts ...grpc.CallOption) (*UpdateFlowDescriptorRes, error)
	RemoveFlowDescriptor(ctx context.Context, in *RemoveFlowDescriptorReq, opts ...grpc.CallOption) (*RemoveFlowDescriptorRes, error)
	// unimplemented
	ListFlowDescriptors(ctx context.Context, in *ListFlowDescriptorsReq, opts ...grpc.CallOption) (*ListFlowDescriptorsRes, error)
}

FlowDescriptorServiceClient is the client API for FlowDescriptorService service.

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

func NewFlowDescriptorServiceClient 

func NewFlowDescriptorServiceClient(cc *grpc.ClientConn) FlowDescriptorServiceClient

type FlowDescriptorServiceServer 

type FlowDescriptorServiceServer interface {
	GetFlowDescriptor(context.Context, *GetFlowDescriptorReq) (*FlowDescriptor, error)
	AddFlowDescriptor(context.Context, *AddFlowDescriptorReq) (*AddFlowDescriptorRes, error)
	UpdateFlowDescriptor(context.Context, *UpdateFlowDescriptorReq) (*UpdateFlowDescriptorRes, error)
	RemoveFlowDescriptor(context.Context, *RemoveFlowDescriptorReq) (*RemoveFlowDescriptorRes, error)
	// unimplemented
	ListFlowDescriptors(context.Context, *ListFlowDescriptorsReq) (*ListFlowDescriptorsRes, error)
}

FlowDescriptorServiceServer is the server API for FlowDescriptorService service.

type FlowServiceClient 

type FlowServiceClient interface {
	GetFlow(ctx context.Context, in *GetFlowReq, opts ...grpc.CallOption) (*Flow, error)
	AddFlow(ctx context.Context, in *AddFlowReq, opts ...grpc.CallOption) (*AddFlowRes, error)
	RemoveFlow(ctx context.Context, in *RemoveFlowReq, opts ...grpc.CallOption) (*RemoveFlowRes, error)
	GetFlowVariable(ctx context.Context, in *GetFlowVariableReq, opts ...grpc.CallOption) (*GetFlowVariableRes, error)
	SetFlowVariable(ctx context.Context, in *SetFlowVariableReq, opts ...grpc.CallOption) (*SetFlowVariableRes, error)
	WatchFlowVariable(ctx context.Context, in *WatchFlowVariableReq, opts ...grpc.CallOption) (FlowService_WatchFlowVariableClient, error)
	ListFlowUI(ctx context.Context, in *ListFlowUIReq, opts ...grpc.CallOption) (*ListFlowUIRes, error)
	SendFlowUI(ctx context.Context, in *SendFlowUIReq, opts ...grpc.CallOption) (*SendFlowUIRes, error)
	WatchFlowUI(ctx context.Context, in *WatchFlowUIReq, opts ...grpc.CallOption) (FlowService_WatchFlowUIClient, error)
	SetFlowStatus(ctx context.Context, in *SetFlowStatusReq, opts ...grpc.CallOption) (*SetFlowStatusRes, error)
	StartFlow(ctx context.Context, in *StartFlowReq, opts ...grpc.CallOption) (*StartFlowRes, error)
	// unimplemented
	StopFlow(ctx context.Context, in *StopFlowReq, opts ...grpc.CallOption) (*StopFlowRes, error)
}

FlowServiceClient is the client API for FlowService service.

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

func NewFlowServiceClient 

func NewFlowServiceClient(cc *grpc.ClientConn) FlowServiceClient

type FlowServiceServer 

type FlowServiceServer interface {
	GetFlow(context.Context, *GetFlowReq) (*Flow, error)
	AddFlow(context.Context, *AddFlowReq) (*AddFlowRes, error)
	RemoveFlow(context.Context, *RemoveFlowReq) (*RemoveFlowRes, error)
	GetFlowVariable(context.Context, *GetFlowVariableReq) (*GetFlowVariableRes, error)
	SetFlowVariable(context.Context, *SetFlowVariableReq) (*SetFlowVariableRes, error)
	WatchFlowVariable(*WatchFlowVariableReq, FlowService_WatchFlowVariableServer) error
	ListFlowUI(context.Context, *ListFlowUIReq) (*ListFlowUIRes, error)
	SendFlowUI(context.Context, *SendFlowUIReq) (*SendFlowUIRes, error)
	WatchFlowUI(*WatchFlowUIReq, FlowService_WatchFlowUIServer) error
	SetFlowStatus(context.Context, *SetFlowStatusReq) (*SetFlowStatusRes, error)
	StartFlow(context.Context, *StartFlowReq) (*StartFlowRes, error)
	// unimplemented
	StopFlow(context.Context, *StopFlowReq) (*StopFlowRes, error)
}

FlowServiceServer is the server API for FlowService service.

type FlowService_WatchFlowUIClient 

type FlowService_WatchFlowUIClient interface {
	Recv() (*WatchFlowUIRes, error)
	grpc.ClientStream
}

type FlowService_WatchFlowUIServer 

type FlowService_WatchFlowUIServer interface {
	Send(*WatchFlowUIRes) error
	grpc.ServerStream
}

type FlowService_WatchFlowVariableClient 

type FlowService_WatchFlowVariableClient interface {
	Recv() (*WatchFlowVariableRes, error)
	grpc.ClientStream
}

type FlowService_WatchFlowVariableServer 

type FlowService_WatchFlowVariableServer interface {
	Send(*WatchFlowVariableRes) error
	grpc.ServerStream
}

type FlowStatus 

type FlowStatus int32
const (
	FlowStatus_STOPPED  FlowStatus = 0
	FlowStatus_STARTING FlowStatus = 1
	FlowStatus_RUNNING  FlowStatus = 2
)

func (FlowStatus) EnumDescriptor 

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

func (FlowStatus) String 

func (x FlowStatus) String() string

type FlowUIVariableDescriptor 

type FlowUIVariableDescriptor struct {
	Name                 string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                 FlowUIVariableType `protobuf:"varint,3,opt,name=type,proto3,enum=schema.FlowUIVariableType" json:"type,omitempty"`
	Tags                 []string           `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	DefaultValue         *Any               `protobuf:"bytes,4,opt,name=defaultValue,proto3" json:"defaultValue,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*FlowUIVariableDescriptor) Descriptor 

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

func (*FlowUIVariableDescriptor) GetDefaultValue added in v1.0.1 

func (m *FlowUIVariableDescriptor) GetDefaultValue() *Any

func (*FlowUIVariableDescriptor) GetName 

func (m *FlowUIVariableDescriptor) GetName() string

func (*FlowUIVariableDescriptor) GetTags 

func (m *FlowUIVariableDescriptor) GetTags() []string

func (*FlowUIVariableDescriptor) GetType 

func (m *FlowUIVariableDescriptor) GetType() FlowUIVariableType

func (*FlowUIVariableDescriptor) ProtoMessage 

func (*FlowUIVariableDescriptor) ProtoMessage()

func (*FlowUIVariableDescriptor) Reset 

func (m *FlowUIVariableDescriptor) Reset()

func (*FlowUIVariableDescriptor) String 

func (m *FlowUIVariableDescriptor) String() string

func (*FlowUIVariableDescriptor) XXX_DiscardUnknown 

func (m *FlowUIVariableDescriptor) XXX_DiscardUnknown()

func (*FlowUIVariableDescriptor) XXX_Marshal 

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

func (*FlowUIVariableDescriptor) XXX_Merge 

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

func (*FlowUIVariableDescriptor) XXX_Size 

func (m *FlowUIVariableDescriptor) XXX_Size() int

func (*FlowUIVariableDescriptor) XXX_Unmarshal 

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

type FlowUIVariableType 

type FlowUIVariableType int32
const (
	FlowUIVariableType_UNDEFINED FlowUIVariableType = 0
	FlowUIVariableType_BUTTON    FlowUIVariableType = 1
)

func (FlowUIVariableType) EnumDescriptor 

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

func (FlowUIVariableType) String 

func (x FlowUIVariableType) String() string

type FlowVariableDescriptor 

type FlowVariableDescriptor struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                 VarType  `protobuf:"varint,2,opt,name=type,proto3,enum=schema.VarType" json:"type,omitempty"`
	Description          string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	DefaultValue         *Any     `protobuf:"bytes,4,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FlowVariableDescriptor) Descriptor 

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

func (*FlowVariableDescriptor) GetDefaultValue 

func (m *FlowVariableDescriptor) GetDefaultValue() *Any

func (*FlowVariableDescriptor) GetDescription 

func (m *FlowVariableDescriptor) GetDescription() string

func (*FlowVariableDescriptor) GetName 

func (m *FlowVariableDescriptor) GetName() string

func (*FlowVariableDescriptor) GetType 

func (m *FlowVariableDescriptor) GetType() VarType

func (*FlowVariableDescriptor) ProtoMessage 

func (*FlowVariableDescriptor) ProtoMessage()

func (*FlowVariableDescriptor) Reset 

func (m *FlowVariableDescriptor) Reset()

func (*FlowVariableDescriptor) String 

func (m *FlowVariableDescriptor) String() string

func (*FlowVariableDescriptor) XXX_DiscardUnknown 

func (m *FlowVariableDescriptor) XXX_DiscardUnknown()

func (*FlowVariableDescriptor) XXX_Marshal 

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

func (*FlowVariableDescriptor) XXX_Merge 

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

func (*FlowVariableDescriptor) XXX_Size 

func (m *FlowVariableDescriptor) XXX_Size() int

func (*FlowVariableDescriptor) XXX_Unmarshal 

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

type GetDeviceReq 

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

func (*GetDeviceReq) Descriptor 

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

func (*GetDeviceReq) GetId 

func (m *GetDeviceReq) GetId() string

func (*GetDeviceReq) ProtoMessage 

func (*GetDeviceReq) ProtoMessage()

func (*GetDeviceReq) Reset 

func (m *GetDeviceReq) Reset()

func (*GetDeviceReq) String 

func (m *GetDeviceReq) String() string

func (*GetDeviceReq) XXX_DiscardUnknown 

func (m *GetDeviceReq) XXX_DiscardUnknown()

func (*GetDeviceReq) XXX_Marshal 

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

func (*GetDeviceReq) XXX_Merge 

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

func (*GetDeviceReq) XXX_Size 

func (m *GetDeviceReq) XXX_Size() int

func (*GetDeviceReq) XXX_Unmarshal 

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

type GetDeviceTypeReq 

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

func (*GetDeviceTypeReq) Descriptor 

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

func (*GetDeviceTypeReq) GetId 

func (m *GetDeviceTypeReq) GetId() string

func (*GetDeviceTypeReq) ProtoMessage 

func (*GetDeviceTypeReq) ProtoMessage()

func (*GetDeviceTypeReq) Reset 

func (m *GetDeviceTypeReq) Reset()

func (*GetDeviceTypeReq) String 

func (m *GetDeviceTypeReq) String() string

func (*GetDeviceTypeReq) XXX_DiscardUnknown 

func (m *GetDeviceTypeReq) XXX_DiscardUnknown()

func (*GetDeviceTypeReq) XXX_Marshal 

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

func (*GetDeviceTypeReq) XXX_Merge 

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

func (*GetDeviceTypeReq) XXX_Size 

func (m *GetDeviceTypeReq) XXX_Size() int

func (*GetDeviceTypeReq) XXX_Unmarshal 

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

type GetFlowDescriptorReq 

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

func (*GetFlowDescriptorReq) Descriptor 

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

func (*GetFlowDescriptorReq) GetId 

func (m *GetFlowDescriptorReq) GetId() string

func (*GetFlowDescriptorReq) ProtoMessage 

func (*GetFlowDescriptorReq) ProtoMessage()

func (*GetFlowDescriptorReq) Reset 

func (m *GetFlowDescriptorReq) Reset()

func (*GetFlowDescriptorReq) String 

func (m *GetFlowDescriptorReq) String() string

func (*GetFlowDescriptorReq) XXX_DiscardUnknown 

func (m *GetFlowDescriptorReq) XXX_DiscardUnknown()

func (*GetFlowDescriptorReq) XXX_Marshal 

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

func (*GetFlowDescriptorReq) XXX_Merge 

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

func (*GetFlowDescriptorReq) XXX_Size 

func (m *GetFlowDescriptorReq) XXX_Size() int

func (*GetFlowDescriptorReq) XXX_Unmarshal 

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

type GetFlowReq 

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

func (*GetFlowReq) Descriptor 

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

func (*GetFlowReq) GetId 

func (m *GetFlowReq) GetId() string

func (*GetFlowReq) ProtoMessage 

func (*GetFlowReq) ProtoMessage()

func (*GetFlowReq) Reset 

func (m *GetFlowReq) Reset()

func (*GetFlowReq) String 

func (m *GetFlowReq) String() string

func (*GetFlowReq) XXX_DiscardUnknown 

func (m *GetFlowReq) XXX_DiscardUnknown()

func (*GetFlowReq) XXX_Marshal 

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

func (*GetFlowReq) XXX_Merge 

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

func (*GetFlowReq) XXX_Size 

func (m *GetFlowReq) XXX_Size() int

func (*GetFlowReq) XXX_Unmarshal 

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

type GetFlowVariableReq 

type GetFlowVariableReq struct {
	FlowId               string   `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetFlowVariableReq) Descriptor 

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

func (*GetFlowVariableReq) GetFlowId 

func (m *GetFlowVariableReq) GetFlowId() string

func (*GetFlowVariableReq) GetName 

func (m *GetFlowVariableReq) GetName() string

func (*GetFlowVariableReq) ProtoMessage 

func (*GetFlowVariableReq) ProtoMessage()

func (*GetFlowVariableReq) Reset 

func (m *GetFlowVariableReq) Reset()

func (*GetFlowVariableReq) String 

func (m *GetFlowVariableReq) String() string

func (*GetFlowVariableReq) XXX_DiscardUnknown 

func (m *GetFlowVariableReq) XXX_DiscardUnknown()

func (*GetFlowVariableReq) XXX_Marshal 

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

func (*GetFlowVariableReq) XXX_Merge 

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

func (*GetFlowVariableReq) XXX_Size 

func (m *GetFlowVariableReq) XXX_Size() int

func (*GetFlowVariableReq) XXX_Unmarshal 

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

type GetFlowVariableRes 

type GetFlowVariableRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Value                *Any     `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetFlowVariableRes) Descriptor 

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

func (*GetFlowVariableRes) GetOk 

func (m *GetFlowVariableRes) GetOk() bool

func (*GetFlowVariableRes) GetValue 

func (m *GetFlowVariableRes) GetValue() *Any

func (*GetFlowVariableRes) ProtoMessage 

func (*GetFlowVariableRes) ProtoMessage()

func (*GetFlowVariableRes) Reset 

func (m *GetFlowVariableRes) Reset()

func (*GetFlowVariableRes) String 

func (m *GetFlowVariableRes) String() string

func (*GetFlowVariableRes) XXX_DiscardUnknown 

func (m *GetFlowVariableRes) XXX_DiscardUnknown()

func (*GetFlowVariableRes) XXX_Marshal 

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

func (*GetFlowVariableRes) XXX_Merge 

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

func (*GetFlowVariableRes) XXX_Size 

func (m *GetFlowVariableRes) XXX_Size() int

func (*GetFlowVariableRes) XXX_Unmarshal 

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

type GetPipeDescriptorReq 

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

func (*GetPipeDescriptorReq) Descriptor 

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

func (*GetPipeDescriptorReq) GetId 

func (m *GetPipeDescriptorReq) GetId() string

func (*GetPipeDescriptorReq) ProtoMessage 

func (*GetPipeDescriptorReq) ProtoMessage()

func (*GetPipeDescriptorReq) Reset 

func (m *GetPipeDescriptorReq) Reset()

func (*GetPipeDescriptorReq) String 

func (m *GetPipeDescriptorReq) String() string

func (*GetPipeDescriptorReq) XXX_DiscardUnknown 

func (m *GetPipeDescriptorReq) XXX_DiscardUnknown()

func (*GetPipeDescriptorReq) XXX_Marshal 

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

func (*GetPipeDescriptorReq) XXX_Merge 

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

func (*GetPipeDescriptorReq) XXX_Size 

func (m *GetPipeDescriptorReq) XXX_Size() int

func (*GetPipeDescriptorReq) XXX_Unmarshal 

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

type GetPluginReq 

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

func (*GetPluginReq) Descriptor 

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

func (*GetPluginReq) GetId 

func (m *GetPluginReq) GetId() string

func (*GetPluginReq) ProtoMessage 

func (*GetPluginReq) ProtoMessage()

func (*GetPluginReq) Reset 

func (m *GetPluginReq) Reset()

func (*GetPluginReq) String 

func (m *GetPluginReq) String() string

func (*GetPluginReq) XXX_DiscardUnknown 

func (m *GetPluginReq) XXX_DiscardUnknown()

func (*GetPluginReq) XXX_Marshal 

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

func (*GetPluginReq) XXX_Merge 

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

func (*GetPluginReq) XXX_Size 

func (m *GetPluginReq) XXX_Size() int

func (*GetPluginReq) XXX_Unmarshal 

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

type GetUserReq 

type GetUserReq struct {
	// Types that are valid to be assigned to Filter:
	//	*GetUserReq_Id
	//	*GetUserReq_Email
	//	*GetUserReq_Token
	Filter               isGetUserReq_Filter `protobuf_oneof:"filter"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*GetUserReq) Descriptor 

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

func (*GetUserReq) GetEmail 

func (m *GetUserReq) GetEmail() string

func (*GetUserReq) GetFilter 

func (m *GetUserReq) GetFilter() isGetUserReq_Filter

func (*GetUserReq) GetId 

func (m *GetUserReq) GetId() string

func (*GetUserReq) GetToken 

func (m *GetUserReq) GetToken() string

func (*GetUserReq) ProtoMessage 

func (*GetUserReq) ProtoMessage()

func (*GetUserReq) Reset 

func (m *GetUserReq) Reset()

func (*GetUserReq) String 

func (m *GetUserReq) String() string

func (*GetUserReq) XXX_DiscardUnknown 

func (m *GetUserReq) XXX_DiscardUnknown()

func (*GetUserReq) XXX_Marshal 

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

func (*GetUserReq) XXX_Merge 

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

func (*GetUserReq) XXX_OneofWrappers 

func (*GetUserReq) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetUserReq) XXX_Size 

func (m *GetUserReq) XXX_Size() int

func (*GetUserReq) XXX_Unmarshal 

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

type GetUserReq_Email 

type GetUserReq_Email struct {
	Email string `protobuf:"bytes,2,opt,name=email,proto3,oneof"`
}

type GetUserReq_Id 

type GetUserReq_Id struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3,oneof"`
}

type GetUserReq_Token 

type GetUserReq_Token struct {
	Token string `protobuf:"bytes,3,opt,name=token,proto3,oneof"`
}

type GetUserTokensReq 

type GetUserTokensReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetUserTokensReq) Descriptor 

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

func (*GetUserTokensReq) ProtoMessage 

func (*GetUserTokensReq) ProtoMessage()

func (*GetUserTokensReq) Reset 

func (m *GetUserTokensReq) Reset()

func (*GetUserTokensReq) String 

func (m *GetUserTokensReq) String() string

func (*GetUserTokensReq) XXX_DiscardUnknown 

func (m *GetUserTokensReq) XXX_DiscardUnknown()

func (*GetUserTokensReq) XXX_Marshal 

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

func (*GetUserTokensReq) XXX_Merge 

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

func (*GetUserTokensReq) XXX_Size 

func (m *GetUserTokensReq) XXX_Size() int

func (*GetUserTokensReq) XXX_Unmarshal 

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

type GetUserTokensRes 

type GetUserTokensRes struct {
	Tokens               []*Token `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetUserTokensRes) Descriptor 

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

func (*GetUserTokensRes) GetTokens 

func (m *GetUserTokensRes) GetTokens() []*Token

func (*GetUserTokensRes) ProtoMessage 

func (*GetUserTokensRes) ProtoMessage()

func (*GetUserTokensRes) Reset 

func (m *GetUserTokensRes) Reset()

func (*GetUserTokensRes) String 

func (m *GetUserTokensRes) String() string

func (*GetUserTokensRes) XXX_DiscardUnknown 

func (m *GetUserTokensRes) XXX_DiscardUnknown()

func (*GetUserTokensRes) XXX_Marshal 

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

func (*GetUserTokensRes) XXX_Merge 

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

func (*GetUserTokensRes) XXX_Size 

func (m *GetUserTokensRes) XXX_Size() int

func (*GetUserTokensRes) XXX_Unmarshal 

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

type InitPipeReq 

type InitPipeReq struct {
	Pipe                 *PipeExt `protobuf:"bytes,1,opt,name=pipe,proto3" json:"pipe,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InitPipeReq) Descriptor 

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

func (*InitPipeReq) GetPipe 

func (m *InitPipeReq) GetPipe() *PipeExt

func (*InitPipeReq) ProtoMessage 

func (*InitPipeReq) ProtoMessage()

func (*InitPipeReq) Reset 

func (m *InitPipeReq) Reset()

func (*InitPipeReq) String 

func (m *InitPipeReq) String() string

func (*InitPipeReq) XXX_DiscardUnknown 

func (m *InitPipeReq) XXX_DiscardUnknown()

func (*InitPipeReq) XXX_Marshal 

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

func (*InitPipeReq) XXX_Merge 

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

func (*InitPipeReq) XXX_Size 

func (m *InitPipeReq) XXX_Size() int

func (*InitPipeReq) XXX_Unmarshal 

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

type InitPipeRes 

type InitPipeRes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InitPipeRes) Descriptor 

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

func (*InitPipeRes) ProtoMessage 

func (*InitPipeRes) ProtoMessage()

func (*InitPipeRes) Reset 

func (m *InitPipeRes) Reset()

func (*InitPipeRes) String 

func (m *InitPipeRes) String() string

func (*InitPipeRes) XXX_DiscardUnknown 

func (m *InitPipeRes) XXX_DiscardUnknown()

func (*InitPipeRes) XXX_Marshal 

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

func (*InitPipeRes) XXX_Merge 

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

func (*InitPipeRes) XXX_Size 

func (m *InitPipeRes) XXX_Size() int

func (*InitPipeRes) XXX_Unmarshal 

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

type InputPipe 

type InputPipe interface {
	ReceiveMsg(msg *ReceiveMsgReq)
}

type ListDeviceTypesReq 

type ListDeviceTypesReq struct {
	Filter               *ListDeviceTypesReq_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Sort                 *ListDeviceTypesReq_Sort   `protobuf:"bytes,4,opt,name=sort,proto3" json:"sort,omitempty"`
	Page                 *Page                      `protobuf:"bytes,5,opt,name=page,proto3" json:"page,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ListDeviceTypesReq) Descriptor 

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

func (*ListDeviceTypesReq) GetFilter 

func (m *ListDeviceTypesReq) GetFilter() *ListDeviceTypesReq_Filter

func (*ListDeviceTypesReq) GetPage 

func (m *ListDeviceTypesReq) GetPage() *Page

func (*ListDeviceTypesReq) GetSort 

func (m *ListDeviceTypesReq) GetSort() *ListDeviceTypesReq_Sort

func (*ListDeviceTypesReq) ProtoMessage 

func (*ListDeviceTypesReq) ProtoMessage()

func (*ListDeviceTypesReq) Reset 

func (m *ListDeviceTypesReq) Reset()

func (*ListDeviceTypesReq) String 

func (m *ListDeviceTypesReq) String() string

func (*ListDeviceTypesReq) XXX_DiscardUnknown 

func (m *ListDeviceTypesReq) XXX_DiscardUnknown()

func (*ListDeviceTypesReq) XXX_Marshal 

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

func (*ListDeviceTypesReq) XXX_Merge 

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

func (*ListDeviceTypesReq) XXX_Size 

func (m *ListDeviceTypesReq) XXX_Size() int

func (*ListDeviceTypesReq) XXX_Unmarshal 

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

type ListDeviceTypesReq_Filter 

type ListDeviceTypesReq_Filter struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	UserId               string   `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListDeviceTypesReq_Filter) Descriptor 

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

func (*ListDeviceTypesReq_Filter) GetName 

func (m *ListDeviceTypesReq_Filter) GetName() string

func (*ListDeviceTypesReq_Filter) GetUserId 

func (m *ListDeviceTypesReq_Filter) GetUserId() string

func (*ListDeviceTypesReq_Filter) ProtoMessage 

func (*ListDeviceTypesReq_Filter) ProtoMessage()

func (*ListDeviceTypesReq_Filter) Reset 

func (m *ListDeviceTypesReq_Filter) Reset()

func (*ListDeviceTypesReq_Filter) String 

func (m *ListDeviceTypesReq_Filter) String() string

func (*ListDeviceTypesReq_Filter) XXX_DiscardUnknown 

func (m *ListDeviceTypesReq_Filter) XXX_DiscardUnknown()

func (*ListDeviceTypesReq_Filter) XXX_Marshal 

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

func (*ListDeviceTypesReq_Filter) XXX_Merge 

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

func (*ListDeviceTypesReq_Filter) XXX_Size 

func (m *ListDeviceTypesReq_Filter) XXX_Size() int

func (*ListDeviceTypesReq_Filter) XXX_Unmarshal 

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

type ListDeviceTypesReq_Sort 

type ListDeviceTypesReq_Sort struct {
	Name                 SortDirection `protobuf:"varint,2,opt,name=name,proto3,enum=schema.SortDirection" json:"name,omitempty"`
	CreatedAt            SortDirection `protobuf:"varint,1,opt,name=created_at,json=createdAt,proto3,enum=schema.SortDirection" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListDeviceTypesReq_Sort) Descriptor 

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

func (*ListDeviceTypesReq_Sort) GetCreatedAt 

func (m *ListDeviceTypesReq_Sort) GetCreatedAt() SortDirection

func (*ListDeviceTypesReq_Sort) GetName 

func (m *ListDeviceTypesReq_Sort) GetName() SortDirection

func (*ListDeviceTypesReq_Sort) ProtoMessage 

func (*ListDeviceTypesReq_Sort) ProtoMessage()

func (*ListDeviceTypesReq_Sort) Reset 

func (m *ListDeviceTypesReq_Sort) Reset()

func (*ListDeviceTypesReq_Sort) String 

func (m *ListDeviceTypesReq_Sort) String() string

func (*ListDeviceTypesReq_Sort) XXX_DiscardUnknown 

func (m *ListDeviceTypesReq_Sort) XXX_DiscardUnknown()

func (*ListDeviceTypesReq_Sort) XXX_Marshal 

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

func (*ListDeviceTypesReq_Sort) XXX_Merge 

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

func (*ListDeviceTypesReq_Sort) XXX_Size 

func (m *ListDeviceTypesReq_Sort) XXX_Size() int

func (*ListDeviceTypesReq_Sort) XXX_Unmarshal 

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

type ListDeviceTypesRes 

type ListDeviceTypesRes struct {
	DeviceTypes          []*DeviceType `protobuf:"bytes,1,rep,name=device_types,json=deviceTypes,proto3" json:"device_types,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListDeviceTypesRes) Descriptor 

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

func (*ListDeviceTypesRes) GetDeviceTypes 

func (m *ListDeviceTypesRes) GetDeviceTypes() []*DeviceType

func (*ListDeviceTypesRes) ProtoMessage 

func (*ListDeviceTypesRes) ProtoMessage()

func (*ListDeviceTypesRes) Reset 

func (m *ListDeviceTypesRes) Reset()

func (*ListDeviceTypesRes) String 

func (m *ListDeviceTypesRes) String() string

func (*ListDeviceTypesRes) XXX_DiscardUnknown 

func (m *ListDeviceTypesRes) XXX_DiscardUnknown()

func (*ListDeviceTypesRes) XXX_Marshal 

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

func (*ListDeviceTypesRes) XXX_Merge 

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

func (*ListDeviceTypesRes) XXX_Size 

func (m *ListDeviceTypesRes) XXX_Size() int

func (*ListDeviceTypesRes) XXX_Unmarshal 

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

type ListDevicesReq 

type ListDevicesReq struct {
	Filter               *ListDevicesReq_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Sort                 *ListDevicesReq_Sort   `protobuf:"bytes,4,opt,name=sort,proto3" json:"sort,omitempty"`
	Page                 *Page                  `protobuf:"bytes,5,opt,name=page,proto3" json:"page,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ListDevicesReq) Descriptor 

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

func (*ListDevicesReq) GetFilter 

func (m *ListDevicesReq) GetFilter() *ListDevicesReq_Filter

func (*ListDevicesReq) GetPage 

func (m *ListDevicesReq) GetPage() *Page

func (*ListDevicesReq) GetSort 

func (m *ListDevicesReq) GetSort() *ListDevicesReq_Sort

func (*ListDevicesReq) ProtoMessage 

func (*ListDevicesReq) ProtoMessage()

func (*ListDevicesReq) Reset 

func (m *ListDevicesReq) Reset()

func (*ListDevicesReq) String 

func (m *ListDevicesReq) String() string

func (*ListDevicesReq) XXX_DiscardUnknown 

func (m *ListDevicesReq) XXX_DiscardUnknown()

func (*ListDevicesReq) XXX_Marshal 

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

func (*ListDevicesReq) XXX_Merge 

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

func (*ListDevicesReq) XXX_Size 

func (m *ListDevicesReq) XXX_Size() int

func (*ListDevicesReq) XXX_Unmarshal 

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

type ListDevicesReq_Filter 

type ListDevicesReq_Filter struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	UserId               string   `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListDevicesReq_Filter) Descriptor 

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

func (*ListDevicesReq_Filter) GetName 

func (m *ListDevicesReq_Filter) GetName() string

func (*ListDevicesReq_Filter) GetUserId 

func (m *ListDevicesReq_Filter) GetUserId() string

func (*ListDevicesReq_Filter) ProtoMessage 

func (*ListDevicesReq_Filter) ProtoMessage()

func (*ListDevicesReq_Filter) Reset 

func (m *ListDevicesReq_Filter) Reset()

func (*ListDevicesReq_Filter) String 

func (m *ListDevicesReq_Filter) String() string

func (*ListDevicesReq_Filter) XXX_DiscardUnknown 

func (m *ListDevicesReq_Filter) XXX_DiscardUnknown()

func (*ListDevicesReq_Filter) XXX_Marshal 

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

func (*ListDevicesReq_Filter) XXX_Merge 

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

func (*ListDevicesReq_Filter) XXX_Size 

func (m *ListDevicesReq_Filter) XXX_Size() int

func (*ListDevicesReq_Filter) XXX_Unmarshal 

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

type ListDevicesReq_Sort 

type ListDevicesReq_Sort struct {
	Name                 SortDirection `protobuf:"varint,2,opt,name=name,proto3,enum=schema.SortDirection" json:"name,omitempty"`
	CreatedAt            SortDirection `protobuf:"varint,1,opt,name=created_at,json=createdAt,proto3,enum=schema.SortDirection" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListDevicesReq_Sort) Descriptor 

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

func (*ListDevicesReq_Sort) GetCreatedAt 

func (m *ListDevicesReq_Sort) GetCreatedAt() SortDirection

func (*ListDevicesReq_Sort) GetName 

func (m *ListDevicesReq_Sort) GetName() SortDirection

func (*ListDevicesReq_Sort) ProtoMessage 

func (*ListDevicesReq_Sort) ProtoMessage()

func (*ListDevicesReq_Sort) Reset 

func (m *ListDevicesReq_Sort) Reset()

func (*ListDevicesReq_Sort) String 

func (m *ListDevicesReq_Sort) String() string

func (*ListDevicesReq_Sort) XXX_DiscardUnknown 

func (m *ListDevicesReq_Sort) XXX_DiscardUnknown()

func (*ListDevicesReq_Sort) XXX_Marshal 

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

func (*ListDevicesReq_Sort) XXX_Merge 

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

func (*ListDevicesReq_Sort) XXX_Size 

func (m *ListDevicesReq_Sort) XXX_Size() int

func (*ListDevicesReq_Sort) XXX_Unmarshal 

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

type ListDevicesRes 

type ListDevicesRes struct {
	Devices              []*Device `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListDevicesRes) Descriptor 

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

func (*ListDevicesRes) GetDevices 

func (m *ListDevicesRes) GetDevices() []*Device

func (*ListDevicesRes) ProtoMessage 

func (*ListDevicesRes) ProtoMessage()

func (*ListDevicesRes) Reset 

func (m *ListDevicesRes) Reset()

func (*ListDevicesRes) String 

func (m *ListDevicesRes) String() string

func (*ListDevicesRes) XXX_DiscardUnknown 

func (m *ListDevicesRes) XXX_DiscardUnknown()

func (*ListDevicesRes) XXX_Marshal 

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

func (*ListDevicesRes) XXX_Merge 

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

func (*ListDevicesRes) XXX_Size 

func (m *ListDevicesRes) XXX_Size() int

func (*ListDevicesRes) XXX_Unmarshal 

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

type ListFlowDescriptorsReq 

type ListFlowDescriptorsReq struct {
	UserId               string   `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Sort                 *Sort    `protobuf:"bytes,4,opt,name=sort,proto3" json:"sort,omitempty"`
	Page                 *Page    `protobuf:"bytes,5,opt,name=page,proto3" json:"page,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListFlowDescriptorsReq) Descriptor 

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

func (*ListFlowDescriptorsReq) GetPage 

func (m *ListFlowDescriptorsReq) GetPage() *Page

func (*ListFlowDescriptorsReq) GetSort 

func (m *ListFlowDescriptorsReq) GetSort() *Sort

func (*ListFlowDescriptorsReq) GetUserId 

func (m *ListFlowDescriptorsReq) GetUserId() string

func (*ListFlowDescriptorsReq) ProtoMessage 

func (*ListFlowDescriptorsReq) ProtoMessage()

func (*ListFlowDescriptorsReq) Reset 

func (m *ListFlowDescriptorsReq) Reset()

func (*ListFlowDescriptorsReq) String 

func (m *ListFlowDescriptorsReq) String() string

func (*ListFlowDescriptorsReq) XXX_DiscardUnknown 

func (m *ListFlowDescriptorsReq) XXX_DiscardUnknown()

func (*ListFlowDescriptorsReq) XXX_Marshal 

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

func (*ListFlowDescriptorsReq) XXX_Merge 

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

func (*ListFlowDescriptorsReq) XXX_Size 

func (m *ListFlowDescriptorsReq) XXX_Size() int

func (*ListFlowDescriptorsReq) XXX_Unmarshal 

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

type ListFlowDescriptorsRes 

type ListFlowDescriptorsRes struct {
	FlowDescriptors      []*FlowDescriptor `protobuf:"bytes,1,rep,name=flow_descriptors,json=flowDescriptors,proto3" json:"flow_descriptors,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListFlowDescriptorsRes) Descriptor 

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

func (*ListFlowDescriptorsRes) GetFlowDescriptors 

func (m *ListFlowDescriptorsRes) GetFlowDescriptors() []*FlowDescriptor

func (*ListFlowDescriptorsRes) ProtoMessage 

func (*ListFlowDescriptorsRes) ProtoMessage()

func (*ListFlowDescriptorsRes) Reset 

func (m *ListFlowDescriptorsRes) Reset()

func (*ListFlowDescriptorsRes) String 

func (m *ListFlowDescriptorsRes) String() string

func (*ListFlowDescriptorsRes) XXX_DiscardUnknown 

func (m *ListFlowDescriptorsRes) XXX_DiscardUnknown()

func (*ListFlowDescriptorsRes) XXX_Marshal 

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

func (*ListFlowDescriptorsRes) XXX_Merge 

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

func (*ListFlowDescriptorsRes) XXX_Size 

func (m *ListFlowDescriptorsRes) XXX_Size() int

func (*ListFlowDescriptorsRes) XXX_Unmarshal 

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

type ListFlowUIReq added in v1.0.1 

type ListFlowUIReq struct {
	FlowId               string   `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListFlowUIReq) Descriptor added in v1.0.1 

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

func (*ListFlowUIReq) GetFlowId added in v1.0.1 

func (m *ListFlowUIReq) GetFlowId() string

func (*ListFlowUIReq) ProtoMessage added in v1.0.1 

func (*ListFlowUIReq) ProtoMessage()

func (*ListFlowUIReq) Reset added in v1.0.1 

func (m *ListFlowUIReq) Reset()

func (*ListFlowUIReq) String added in v1.0.1 

func (m *ListFlowUIReq) String() string

func (*ListFlowUIReq) XXX_DiscardUnknown added in v1.0.1 

func (m *ListFlowUIReq) XXX_DiscardUnknown()

func (*ListFlowUIReq) XXX_Marshal added in v1.0.1 

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

func (*ListFlowUIReq) XXX_Merge added in v1.0.1 

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

func (*ListFlowUIReq) XXX_Size added in v1.0.1 

func (m *ListFlowUIReq) XXX_Size() int

func (*ListFlowUIReq) XXX_Unmarshal added in v1.0.1 

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

type ListFlowUIRes added in v1.0.1 

type ListFlowUIRes struct {
	List                 []*ListFlowUIRes_UIItem `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ListFlowUIRes) Descriptor added in v1.0.1 

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

func (*ListFlowUIRes) GetList added in v1.0.1 

func (m *ListFlowUIRes) GetList() []*ListFlowUIRes_UIItem

func (*ListFlowUIRes) ProtoMessage added in v1.0.1 

func (*ListFlowUIRes) ProtoMessage()

func (*ListFlowUIRes) Reset added in v1.0.1 

func (m *ListFlowUIRes) Reset()

func (*ListFlowUIRes) String added in v1.0.1 

func (m *ListFlowUIRes) String() string

func (*ListFlowUIRes) XXX_DiscardUnknown added in v1.0.1 

func (m *ListFlowUIRes) XXX_DiscardUnknown()

func (*ListFlowUIRes) XXX_Marshal added in v1.0.1 

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

func (*ListFlowUIRes) XXX_Merge added in v1.0.1 

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

func (*ListFlowUIRes) XXX_Size added in v1.0.1 

func (m *ListFlowUIRes) XXX_Size() int

func (*ListFlowUIRes) XXX_Unmarshal added in v1.0.1 

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

type ListFlowUIRes_UIItem added in v1.0.1 

type ListFlowUIRes_UIItem struct {
	Name                 string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                 FlowUIVariableType `protobuf:"varint,3,opt,name=type,proto3,enum=schema.FlowUIVariableType" json:"type,omitempty"`
	Tags                 []string           `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	Value                *Any               `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Events               []string           `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ListFlowUIRes_UIItem) Descriptor added in v1.0.1 

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

func (*ListFlowUIRes_UIItem) GetEvents added in v1.0.1 

func (m *ListFlowUIRes_UIItem) GetEvents() []string

func (*ListFlowUIRes_UIItem) GetName added in v1.0.1 

func (m *ListFlowUIRes_UIItem) GetName() string

func (*ListFlowUIRes_UIItem) GetTags added in v1.0.1 

func (m *ListFlowUIRes_UIItem) GetTags() []string

func (*ListFlowUIRes_UIItem) GetType added in v1.0.1 

func (m *ListFlowUIRes_UIItem) GetType() FlowUIVariableType

func (*ListFlowUIRes_UIItem) GetValue added in v1.0.1 

func (m *ListFlowUIRes_UIItem) GetValue() *Any

func (*ListFlowUIRes_UIItem) ProtoMessage added in v1.0.1 

func (*ListFlowUIRes_UIItem) ProtoMessage()

func (*ListFlowUIRes_UIItem) Reset added in v1.0.1 

func (m *ListFlowUIRes_UIItem) Reset()

func (*ListFlowUIRes_UIItem) String added in v1.0.1 

func (m *ListFlowUIRes_UIItem) String() string

func (*ListFlowUIRes_UIItem) XXX_DiscardUnknown added in v1.0.1 

func (m *ListFlowUIRes_UIItem) XXX_DiscardUnknown()

func (*ListFlowUIRes_UIItem) XXX_Marshal added in v1.0.1 

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

func (*ListFlowUIRes_UIItem) XXX_Merge added in v1.0.1 

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

func (*ListFlowUIRes_UIItem) XXX_Size added in v1.0.1 

func (m *ListFlowUIRes_UIItem) XXX_Size() int

func (*ListFlowUIRes_UIItem) XXX_Unmarshal added in v1.0.1 

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

type ListPipeDescriptorsReq 

type ListPipeDescriptorsReq struct {
	Filter               *ListPipeDescriptorsReq_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Sort                 *ListPipeDescriptorsReq_Sort   `protobuf:"bytes,4,opt,name=sort,proto3" json:"sort,omitempty"`
	Page                 *Page                          `protobuf:"bytes,5,opt,name=page,proto3" json:"page,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*ListPipeDescriptorsReq) Descriptor 

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

func (*ListPipeDescriptorsReq) GetFilter 

func (m *ListPipeDescriptorsReq) GetFilter() *ListPipeDescriptorsReq_Filter

func (*ListPipeDescriptorsReq) GetPage 

func (m *ListPipeDescriptorsReq) GetPage() *Page

func (*ListPipeDescriptorsReq) GetSort 

func (m *ListPipeDescriptorsReq) GetSort() *ListPipeDescriptorsReq_Sort

func (*ListPipeDescriptorsReq) ProtoMessage 

func (*ListPipeDescriptorsReq) ProtoMessage()

func (*ListPipeDescriptorsReq) Reset 

func (m *ListPipeDescriptorsReq) Reset()

func (*ListPipeDescriptorsReq) String 

func (m *ListPipeDescriptorsReq) String() string

func (*ListPipeDescriptorsReq) XXX_DiscardUnknown 

func (m *ListPipeDescriptorsReq) XXX_DiscardUnknown()

func (*ListPipeDescriptorsReq) XXX_Marshal 

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

func (*ListPipeDescriptorsReq) XXX_Merge 

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

func (*ListPipeDescriptorsReq) XXX_Size 

func (m *ListPipeDescriptorsReq) XXX_Size() int

func (*ListPipeDescriptorsReq) XXX_Unmarshal 

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

type ListPipeDescriptorsReq_Filter 

type ListPipeDescriptorsReq_Filter struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PluginId             string   `protobuf:"bytes,2,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListPipeDescriptorsReq_Filter) Descriptor 

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

func (*ListPipeDescriptorsReq_Filter) GetName 

func (m *ListPipeDescriptorsReq_Filter) GetName() string

func (*ListPipeDescriptorsReq_Filter) GetPluginId 

func (m *ListPipeDescriptorsReq_Filter) GetPluginId() string

func (*ListPipeDescriptorsReq_Filter) ProtoMessage 

func (*ListPipeDescriptorsReq_Filter) ProtoMessage()

func (*ListPipeDescriptorsReq_Filter) Reset 

func (m *ListPipeDescriptorsReq_Filter) Reset()

func (*ListPipeDescriptorsReq_Filter) String 

func (m *ListPipeDescriptorsReq_Filter) String() string

func (*ListPipeDescriptorsReq_Filter) XXX_DiscardUnknown 

func (m *ListPipeDescriptorsReq_Filter) XXX_DiscardUnknown()

func (*ListPipeDescriptorsReq_Filter) XXX_Marshal 

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

func (*ListPipeDescriptorsReq_Filter) XXX_Merge 

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

func (*ListPipeDescriptorsReq_Filter) XXX_Size 

func (m *ListPipeDescriptorsReq_Filter) XXX_Size() int

func (*ListPipeDescriptorsReq_Filter) XXX_Unmarshal 

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

type ListPipeDescriptorsReq_Sort 

type ListPipeDescriptorsReq_Sort struct {
	Name                 SortDirection `protobuf:"varint,2,opt,name=name,proto3,enum=schema.SortDirection" json:"name,omitempty"`
	CreatedAt            SortDirection `protobuf:"varint,1,opt,name=created_at,json=createdAt,proto3,enum=schema.SortDirection" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListPipeDescriptorsReq_Sort) Descriptor 

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

func (*ListPipeDescriptorsReq_Sort) GetCreatedAt 

func (m *ListPipeDescriptorsReq_Sort) GetCreatedAt() SortDirection

func (*ListPipeDescriptorsReq_Sort) GetName 

func (m *ListPipeDescriptorsReq_Sort) GetName() SortDirection

func (*ListPipeDescriptorsReq_Sort) ProtoMessage 

func (*ListPipeDescriptorsReq_Sort) ProtoMessage()

func (*ListPipeDescriptorsReq_Sort) Reset 

func (m *ListPipeDescriptorsReq_Sort) Reset()

func (*ListPipeDescriptorsReq_Sort) String 

func (m *ListPipeDescriptorsReq_Sort) String() string

func (*ListPipeDescriptorsReq_Sort) XXX_DiscardUnknown 

func (m *ListPipeDescriptorsReq_Sort) XXX_DiscardUnknown()

func (*ListPipeDescriptorsReq_Sort) XXX_Marshal 

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

func (*ListPipeDescriptorsReq_Sort) XXX_Merge 

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

func (*ListPipeDescriptorsReq_Sort) XXX_Size 

func (m *ListPipeDescriptorsReq_Sort) XXX_Size() int

func (*ListPipeDescriptorsReq_Sort) XXX_Unmarshal 

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

type ListPipeDescriptorsRes 

type ListPipeDescriptorsRes struct {
	PipeDescriptors      []*PipeDescriptor `protobuf:"bytes,1,rep,name=pipe_descriptors,json=pipeDescriptors,proto3" json:"pipe_descriptors,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListPipeDescriptorsRes) Descriptor 

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

func (*ListPipeDescriptorsRes) GetPipeDescriptors 

func (m *ListPipeDescriptorsRes) GetPipeDescriptors() []*PipeDescriptor

func (*ListPipeDescriptorsRes) ProtoMessage 

func (*ListPipeDescriptorsRes) ProtoMessage()

func (*ListPipeDescriptorsRes) Reset 

func (m *ListPipeDescriptorsRes) Reset()

func (*ListPipeDescriptorsRes) String 

func (m *ListPipeDescriptorsRes) String() string

func (*ListPipeDescriptorsRes) XXX_DiscardUnknown 

func (m *ListPipeDescriptorsRes) XXX_DiscardUnknown()

func (*ListPipeDescriptorsRes) XXX_Marshal 

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

func (*ListPipeDescriptorsRes) XXX_Merge 

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

func (*ListPipeDescriptorsRes) XXX_Size 

func (m *ListPipeDescriptorsRes) XXX_Size() int

func (*ListPipeDescriptorsRes) XXX_Unmarshal 

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

type ListPluginsReq 

type ListPluginsReq struct {
	Filter               *ListPluginsReq_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Sort                 *ListPluginsReq_Sort   `protobuf:"bytes,4,opt,name=sort,proto3" json:"sort,omitempty"`
	Page                 *Page                  `protobuf:"bytes,5,opt,name=page,proto3" json:"page,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ListPluginsReq) Descriptor 

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

func (*ListPluginsReq) GetFilter 

func (m *ListPluginsReq) GetFilter() *ListPluginsReq_Filter

func (*ListPluginsReq) GetPage 

func (m *ListPluginsReq) GetPage() *Page

func (*ListPluginsReq) GetSort 

func (m *ListPluginsReq) GetSort() *ListPluginsReq_Sort

func (*ListPluginsReq) ProtoMessage 

func (*ListPluginsReq) ProtoMessage()

func (*ListPluginsReq) Reset 

func (m *ListPluginsReq) Reset()

func (*ListPluginsReq) String 

func (m *ListPluginsReq) String() string

func (*ListPluginsReq) XXX_DiscardUnknown 

func (m *ListPluginsReq) XXX_DiscardUnknown()

func (*ListPluginsReq) XXX_Marshal 

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

func (*ListPluginsReq) XXX_Merge 

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

func (*ListPluginsReq) XXX_Size 

func (m *ListPluginsReq) XXX_Size() int

func (*ListPluginsReq) XXX_Unmarshal 

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

type ListPluginsReq_Filter 

type ListPluginsReq_Filter struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	UserId               string   `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListPluginsReq_Filter) Descriptor 

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

func (*ListPluginsReq_Filter) GetName 

func (m *ListPluginsReq_Filter) GetName() string

func (*ListPluginsReq_Filter) GetUserId 

func (m *ListPluginsReq_Filter) GetUserId() string

func (*ListPluginsReq_Filter) ProtoMessage 

func (*ListPluginsReq_Filter) ProtoMessage()

func (*ListPluginsReq_Filter) Reset 

func (m *ListPluginsReq_Filter) Reset()

func (*ListPluginsReq_Filter) String 

func (m *ListPluginsReq_Filter) String() string

func (*ListPluginsReq_Filter) XXX_DiscardUnknown 

func (m *ListPluginsReq_Filter) XXX_DiscardUnknown()

func (*ListPluginsReq_Filter) XXX_Marshal 

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

func (*ListPluginsReq_Filter) XXX_Merge 

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

func (*ListPluginsReq_Filter) XXX_Size 

func (m *ListPluginsReq_Filter) XXX_Size() int

func (*ListPluginsReq_Filter) XXX_Unmarshal 

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

type ListPluginsReq_Sort 

type ListPluginsReq_Sort struct {
	Name                 SortDirection `protobuf:"varint,2,opt,name=name,proto3,enum=schema.SortDirection" json:"name,omitempty"`
	CreatedAt            SortDirection `protobuf:"varint,1,opt,name=created_at,json=createdAt,proto3,enum=schema.SortDirection" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListPluginsReq_Sort) Descriptor 

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

func (*ListPluginsReq_Sort) GetCreatedAt 

func (m *ListPluginsReq_Sort) GetCreatedAt() SortDirection

func (*ListPluginsReq_Sort) GetName 

func (m *ListPluginsReq_Sort) GetName() SortDirection

func (*ListPluginsReq_Sort) ProtoMessage 

func (*ListPluginsReq_Sort) ProtoMessage()

func (*ListPluginsReq_Sort) Reset 

func (m *ListPluginsReq_Sort) Reset()

func (*ListPluginsReq_Sort) String 

func (m *ListPluginsReq_Sort) String() string

func (*ListPluginsReq_Sort) XXX_DiscardUnknown 

func (m *ListPluginsReq_Sort) XXX_DiscardUnknown()

func (*ListPluginsReq_Sort) XXX_Marshal 

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

func (*ListPluginsReq_Sort) XXX_Merge 

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

func (*ListPluginsReq_Sort) XXX_Size 

func (m *ListPluginsReq_Sort) XXX_Size() int

func (*ListPluginsReq_Sort) XXX_Unmarshal 

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

type ListPluginsRes 

type ListPluginsRes struct {
	Plugins              []*Plugin `protobuf:"bytes,1,rep,name=plugins,proto3" json:"plugins,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListPluginsRes) Descriptor 

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

func (*ListPluginsRes) GetPlugins 

func (m *ListPluginsRes) GetPlugins() []*Plugin

func (*ListPluginsRes) ProtoMessage 

func (*ListPluginsRes) ProtoMessage()

func (*ListPluginsRes) Reset 

func (m *ListPluginsRes) Reset()

func (*ListPluginsRes) String 

func (m *ListPluginsRes) String() string

func (*ListPluginsRes) XXX_DiscardUnknown 

func (m *ListPluginsRes) XXX_DiscardUnknown()

func (*ListPluginsRes) XXX_Marshal 

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

func (*ListPluginsRes) XXX_Merge 

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

func (*ListPluginsRes) XXX_Size 

func (m *ListPluginsRes) XXX_Size() int

func (*ListPluginsRes) XXX_Unmarshal 

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

type LoginReq 

type LoginReq struct {
	Email                string   `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	Pass                 string   `protobuf:"bytes,2,opt,name=pass,proto3" json:"pass,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoginReq) Descriptor 

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

func (*LoginReq) GetEmail 

func (m *LoginReq) GetEmail() string

func (*LoginReq) GetPass 

func (m *LoginReq) GetPass() string

func (*LoginReq) ProtoMessage 

func (*LoginReq) ProtoMessage()

func (*LoginReq) Reset 

func (m *LoginReq) Reset()

func (*LoginReq) String 

func (m *LoginReq) String() string

func (*LoginReq) XXX_DiscardUnknown 

func (m *LoginReq) XXX_DiscardUnknown()

func (*LoginReq) XXX_Marshal 

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

func (*LoginReq) XXX_Merge 

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

func (*LoginReq) XXX_Size 

func (m *LoginReq) XXX_Size() int

func (*LoginReq) XXX_Unmarshal 

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

type OutputPipe 

type OutputPipe interface {
}

type Page 

type Page struct {
	Skip                 int32    `protobuf:"varint,1,opt,name=skip,proto3" json:"skip,omitempty"`
	Limit                int32    `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Page) Descriptor 

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

func (*Page) GetLimit 

func (m *Page) GetLimit() int32

func (*Page) GetSkip 

func (m *Page) GetSkip() int32

func (*Page) ProtoMessage 

func (*Page) ProtoMessage()

func (*Page) Reset 

func (m *Page) Reset()

func (*Page) String 

func (m *Page) String() string

func (*Page) XXX_DiscardUnknown 

func (m *Page) XXX_DiscardUnknown()

func (*Page) XXX_Marshal 

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

func (*Page) XXX_Merge 

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

func (*Page) XXX_Size 

func (m *Page) XXX_Size() int

func (*Page) XXX_Unmarshal 

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

type Pipe 

type Pipe struct {
	Id                   string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PipeDescriptorId     string          `protobuf:"bytes,2,opt,name=pipe_descriptor_id,json=pipeDescriptorId,proto3" json:"pipe_descriptor_id,omitempty"`
	X                    int32           `protobuf:"varint,7,opt,name=x,proto3" json:"x,omitempty"`
	Y                    int32           `protobuf:"varint,8,opt,name=y,proto3" json:"y,omitempty"`
	Params               map[string]*Any `` /* 153-byte string literal not displayed */
	Inputs               []string        `protobuf:"bytes,5,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs              []string        `protobuf:"bytes,6,rep,name=outputs,proto3" json:"outputs,omitempty"`
	Binds                []*PipeBind     `protobuf:"bytes,4,rep,name=binds,proto3" json:"binds,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Pipe) Descriptor 

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

func (*Pipe) GetBinds 

func (m *Pipe) GetBinds() []*PipeBind

func (*Pipe) GetId 

func (m *Pipe) GetId() string

func (*Pipe) GetInputs 

func (m *Pipe) GetInputs() []string

func (*Pipe) GetOutputs 

func (m *Pipe) GetOutputs() []string

func (*Pipe) GetParams 

func (m *Pipe) GetParams() map[string]*Any

func (*Pipe) GetPipeDescriptorId 

func (m *Pipe) GetPipeDescriptorId() string

func (*Pipe) GetX added in v1.0.1 

func (m *Pipe) GetX() int32

func (*Pipe) GetY added in v1.0.1 

func (m *Pipe) GetY() int32

func (*Pipe) ProtoMessage 

func (*Pipe) ProtoMessage()

func (*Pipe) Reset 

func (m *Pipe) Reset()

func (*Pipe) String 

func (m *Pipe) String() string

func (*Pipe) XXX_DiscardUnknown 

func (m *Pipe) XXX_DiscardUnknown()

func (*Pipe) XXX_Marshal 

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

func (*Pipe) XXX_Merge 

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

func (*Pipe) XXX_Size 

func (m *Pipe) XXX_Size() int

func (*Pipe) XXX_Unmarshal 

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

type PipeBind 

type PipeBind struct {
	FromOutputId         string   `protobuf:"bytes,1,opt,name=from_output_id,json=fromOutputId,proto3" json:"from_output_id,omitempty"`
	ToPipeId             string   `protobuf:"bytes,2,opt,name=to_pipe_id,json=toPipeId,proto3" json:"to_pipe_id,omitempty"`
	ToInputId            string   `protobuf:"bytes,3,opt,name=to_input_id,json=toInputId,proto3" json:"to_input_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PipeBind) Descriptor 

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

func (*PipeBind) GetFromOutputId 

func (m *PipeBind) GetFromOutputId() string

func (*PipeBind) GetToInputId 

func (m *PipeBind) GetToInputId() string

func (*PipeBind) GetToPipeId 

func (m *PipeBind) GetToPipeId() string

func (*PipeBind) ProtoMessage 

func (*PipeBind) ProtoMessage()

func (*PipeBind) Reset 

func (m *PipeBind) Reset()

func (*PipeBind) String 

func (m *PipeBind) String() string

func (*PipeBind) XXX_DiscardUnknown 

func (m *PipeBind) XXX_DiscardUnknown()

func (*PipeBind) XXX_Marshal 

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

func (*PipeBind) XXX_Merge 

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

func (*PipeBind) XXX_Size 

func (m *PipeBind) XXX_Size() int

func (*PipeBind) XXX_Unmarshal 

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

type PipeBindExt 

type PipeBindExt struct {
	FromOutputId         string   `protobuf:"bytes,1,opt,name=from_output_id,json=fromOutputId,proto3" json:"from_output_id,omitempty"`
	ToPipeId             string   `protobuf:"bytes,2,opt,name=to_pipe_id,json=toPipeId,proto3" json:"to_pipe_id,omitempty"`
	ToPipe               *PipeExt `protobuf:"bytes,4,opt,name=to_pipe,json=toPipe,proto3" json:"to_pipe,omitempty"`
	ToInputId            string   `protobuf:"bytes,3,opt,name=to_input_id,json=toInputId,proto3" json:"to_input_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PipeBindExt) Descriptor 

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

func (*PipeBindExt) GetFromOutputId 

func (m *PipeBindExt) GetFromOutputId() string

func (*PipeBindExt) GetToInputId 

func (m *PipeBindExt) GetToInputId() string

func (*PipeBindExt) GetToPipe 

func (m *PipeBindExt) GetToPipe() *PipeExt

func (*PipeBindExt) GetToPipeId 

func (m *PipeBindExt) GetToPipeId() string

func (*PipeBindExt) ProtoMessage 

func (*PipeBindExt) ProtoMessage()

func (*PipeBindExt) Reset 

func (m *PipeBindExt) Reset()

func (*PipeBindExt) String 

func (m *PipeBindExt) String() string

func (*PipeBindExt) XXX_DiscardUnknown 

func (m *PipeBindExt) XXX_DiscardUnknown()

func (*PipeBindExt) XXX_Marshal 

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

func (*PipeBindExt) XXX_Merge 

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

func (*PipeBindExt) XXX_Size 

func (m *PipeBindExt) XXX_Size() int

func (*PipeBindExt) XXX_Unmarshal 

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

type PipeDescriptor 

type PipeDescriptor struct {
	Id                   string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	PluginId             string                 `protobuf:"bytes,3,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	Description          string                 `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Color                string                 `protobuf:"bytes,9,opt,name=color,proto3" json:"color,omitempty"`
	TextAlign            string                 `protobuf:"bytes,10,opt,name=text_align,json=textAlign,proto3" json:"text_align,omitempty"`
	Params               []*PipeDescriptorParam `protobuf:"bytes,5,rep,name=params,proto3" json:"params,omitempty"`
	Inputs               []string               `protobuf:"bytes,6,rep,name=inputs,proto3" json:"inputs,omitempty"`
	InputsExp            string                 `protobuf:"bytes,11,opt,name=inputs_exp,json=inputsExp,proto3" json:"inputs_exp,omitempty"`
	Outputs              []string               `protobuf:"bytes,7,rep,name=outputs,proto3" json:"outputs,omitempty"`
	OutputsExp           string                 `protobuf:"bytes,12,opt,name=outputs_exp,json=outputsExp,proto3" json:"outputs_exp,omitempty"`
	NeedInit             bool                   `protobuf:"varint,8,opt,name=need_init,json=needInit,proto3" json:"need_init,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*PipeDescriptor) Descriptor 

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

func (*PipeDescriptor) GetColor 

func (m *PipeDescriptor) GetColor() string

func (*PipeDescriptor) GetDescription 

func (m *PipeDescriptor) GetDescription() string

func (*PipeDescriptor) GetId 

func (m *PipeDescriptor) GetId() string

func (*PipeDescriptor) GetInputs 

func (m *PipeDescriptor) GetInputs() []string

func (*PipeDescriptor) GetInputsExp 

func (m *PipeDescriptor) GetInputsExp() string

func (*PipeDescriptor) GetName 

func (m *PipeDescriptor) GetName() string

func (*PipeDescriptor) GetNeedInit 

func (m *PipeDescriptor) GetNeedInit() bool

func (*PipeDescriptor) GetOutputs 

func (m *PipeDescriptor) GetOutputs() []string

func (*PipeDescriptor) GetOutputsExp 

func (m *PipeDescriptor) GetOutputsExp() string

func (*PipeDescriptor) GetParams 

func (m *PipeDescriptor) GetParams() []*PipeDescriptorParam

func (*PipeDescriptor) GetPluginId 

func (m *PipeDescriptor) GetPluginId() string

func (*PipeDescriptor) GetTextAlign 

func (m *PipeDescriptor) GetTextAlign() string

func (*PipeDescriptor) ProtoMessage 

func (*PipeDescriptor) ProtoMessage()

func (*PipeDescriptor) Reset 

func (m *PipeDescriptor) Reset()

func (*PipeDescriptor) String 

func (m *PipeDescriptor) String() string

func (*PipeDescriptor) XXX_DiscardUnknown 

func (m *PipeDescriptor) XXX_DiscardUnknown()

func (*PipeDescriptor) XXX_Marshal 

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

func (*PipeDescriptor) XXX_Merge 

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

func (*PipeDescriptor) XXX_Size 

func (m *PipeDescriptor) XXX_Size() int

func (*PipeDescriptor) XXX_Unmarshal 

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

type PipeDescriptorParam 

type PipeDescriptorParam struct {
	Name                 string                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                 PipeDescriptorParam_Type `protobuf:"varint,3,opt,name=type,proto3,enum=schema.PipeDescriptorParam_Type" json:"type,omitempty"`
	DefaultValue         *Any                     `protobuf:"bytes,4,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
	View                 *PipeDescriptorParamView `protobuf:"bytes,5,opt,name=view,proto3" json:"view,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*PipeDescriptorParam) Descriptor 

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

func (*PipeDescriptorParam) GetDefaultValue 

func (m *PipeDescriptorParam) GetDefaultValue() *Any

func (*PipeDescriptorParam) GetName 

func (m *PipeDescriptorParam) GetName() string

func (*PipeDescriptorParam) GetType 

func (m *PipeDescriptorParam) GetType() PipeDescriptorParam_Type

func (*PipeDescriptorParam) GetView 

func (m *PipeDescriptorParam) GetView() *PipeDescriptorParamView

func (*PipeDescriptorParam) ProtoMessage 

func (*PipeDescriptorParam) ProtoMessage()

func (*PipeDescriptorParam) Reset 

func (m *PipeDescriptorParam) Reset()

func (*PipeDescriptorParam) String 

func (m *PipeDescriptorParam) String() string

func (*PipeDescriptorParam) XXX_DiscardUnknown 

func (m *PipeDescriptorParam) XXX_DiscardUnknown()

func (*PipeDescriptorParam) XXX_Marshal 

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

func (*PipeDescriptorParam) XXX_Merge 

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

func (*PipeDescriptorParam) XXX_Size 

func (m *PipeDescriptorParam) XXX_Size() int

func (*PipeDescriptorParam) XXX_Unmarshal 

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

type PipeDescriptorParamView 

type PipeDescriptorParamView struct {
	Title                string                       `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description          string                       `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Type                 PipeDescriptorParamView_Type `protobuf:"varint,3,opt,name=type,proto3,enum=schema.PipeDescriptorParamView_Type" json:"type,omitempty"`
	Min                  int32                        `protobuf:"varint,4,opt,name=min,proto3" json:"min,omitempty"`
	Max                  int32                        `protobuf:"varint,5,opt,name=max,proto3" json:"max,omitempty"`
	Values               []*Any                       `protobuf:"bytes,6,rep,name=values,proto3" json:"values,omitempty"`
	Map                  map[string]*Any              `` /* 147-byte string literal not displayed */
	Input                bool                         `protobuf:"varint,8,opt,name=input,proto3" json:"input,omitempty"`
	Output               bool                         `protobuf:"varint,9,opt,name=output,proto3" json:"output,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*PipeDescriptorParamView) Descriptor 

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

func (*PipeDescriptorParamView) GetDescription 

func (m *PipeDescriptorParamView) GetDescription() string

func (*PipeDescriptorParamView) GetInput 

func (m *PipeDescriptorParamView) GetInput() bool

func (*PipeDescriptorParamView) GetMap 

func (m *PipeDescriptorParamView) GetMap() map[string]*Any

func (*PipeDescriptorParamView) GetMax 

func (m *PipeDescriptorParamView) GetMax() int32

func (*PipeDescriptorParamView) GetMin 

func (m *PipeDescriptorParamView) GetMin() int32

func (*PipeDescriptorParamView) GetOutput 

func (m *PipeDescriptorParamView) GetOutput() bool

func (*PipeDescriptorParamView) GetTitle 

func (m *PipeDescriptorParamView) GetTitle() string

func (*PipeDescriptorParamView) GetType 

func (m *PipeDescriptorParamView) GetType() PipeDescriptorParamView_Type

func (*PipeDescriptorParamView) GetValues 

func (m *PipeDescriptorParamView) GetValues() []*Any

func (*PipeDescriptorParamView) ProtoMessage 

func (*PipeDescriptorParamView) ProtoMessage()

func (*PipeDescriptorParamView) Reset 

func (m *PipeDescriptorParamView) Reset()

func (*PipeDescriptorParamView) String 

func (m *PipeDescriptorParamView) String() string

func (*PipeDescriptorParamView) XXX_DiscardUnknown 

func (m *PipeDescriptorParamView) XXX_DiscardUnknown()

func (*PipeDescriptorParamView) XXX_Marshal 

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

func (*PipeDescriptorParamView) XXX_Merge 

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

func (*PipeDescriptorParamView) XXX_Size 

func (m *PipeDescriptorParamView) XXX_Size() int

func (*PipeDescriptorParamView) XXX_Unmarshal 

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

type PipeDescriptorParamView_Type 

type PipeDescriptorParamView_Type int32
const (
	PipeDescriptorParamView_TextInput   PipeDescriptorParamView_Type = 0
	PipeDescriptorParamView_NumberInput PipeDescriptorParamView_Type = 1
)

func (PipeDescriptorParamView_Type) EnumDescriptor 

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

func (PipeDescriptorParamView_Type) String 

func (x PipeDescriptorParamView_Type) String() string

type PipeDescriptorParam_Type 

type PipeDescriptorParam_Type int32
const (
	PipeDescriptorParam_Unknown PipeDescriptorParam_Type = 0
	PipeDescriptorParam_Int     PipeDescriptorParam_Type = 1
	PipeDescriptorParam_String  PipeDescriptorParam_Type = 2
	PipeDescriptorParam_Bool    PipeDescriptorParam_Type = 3
	PipeDescriptorParam_JSON    PipeDescriptorParam_Type = 4
	PipeDescriptorParam_JS      PipeDescriptorParam_Type = 5
)

func (PipeDescriptorParam_Type) EnumDescriptor 

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

func (PipeDescriptorParam_Type) String 

func (x PipeDescriptorParam_Type) String() string

type PipeDescriptorServiceClient 

type PipeDescriptorServiceClient interface {
	GetPipeDescriptor(ctx context.Context, in *GetPipeDescriptorReq, opts ...grpc.CallOption) (*PipeDescriptor, error)
	AddPipeDescriptor(ctx context.Context, in *AddPipeDescriptorReq, opts ...grpc.CallOption) (*AddPipeDescriptorRes, error)
	// unimplemented
	UpdatePipeDescriptor(ctx context.Context, in *UpdatePipeDescriptorReq, opts ...grpc.CallOption) (*UpdatePipeDescriptorRes, error)
	RemovePipeDescriptor(ctx context.Context, in *RemovePipeDescriptorReq, opts ...grpc.CallOption) (*RemovePipeDescriptorRes, error)
	ListPipeDescriptors(ctx context.Context, in *ListPipeDescriptorsReq, opts ...grpc.CallOption) (*ListPipeDescriptorsRes, error)
}

PipeDescriptorServiceClient is the client API for PipeDescriptorService service.

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

func NewPipeDescriptorServiceClient 

func NewPipeDescriptorServiceClient(cc *grpc.ClientConn) PipeDescriptorServiceClient

type PipeDescriptorServiceServer 

type PipeDescriptorServiceServer interface {
	GetPipeDescriptor(context.Context, *GetPipeDescriptorReq) (*PipeDescriptor, error)
	AddPipeDescriptor(context.Context, *AddPipeDescriptorReq) (*AddPipeDescriptorRes, error)
	// unimplemented
	UpdatePipeDescriptor(context.Context, *UpdatePipeDescriptorReq) (*UpdatePipeDescriptorRes, error)
	RemovePipeDescriptor(context.Context, *RemovePipeDescriptorReq) (*RemovePipeDescriptorRes, error)
	ListPipeDescriptors(context.Context, *ListPipeDescriptorsReq) (*ListPipeDescriptorsRes, error)
}

PipeDescriptorServiceServer is the server API for PipeDescriptorService service.

type PipeExt 

type PipeExt struct {
	Id                   string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PipeDescriptorId     string          `protobuf:"bytes,2,opt,name=pipe_descriptor_id,json=pipeDescriptorId,proto3" json:"pipe_descriptor_id,omitempty"`
	Params               map[string]*Any `` /* 153-byte string literal not displayed */
	Inputs               []string        `protobuf:"bytes,9,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs              []string        `protobuf:"bytes,10,rep,name=outputs,proto3" json:"outputs,omitempty"`
	Binds                []*PipeBindExt  `protobuf:"bytes,5,rep,name=binds,proto3" json:"binds,omitempty"`
	PluginUri            string          `protobuf:"bytes,6,opt,name=plugin_uri,json=pluginUri,proto3" json:"plugin_uri,omitempty"`
	PluginId             string          `protobuf:"bytes,11,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	FlowId               string          `protobuf:"bytes,7,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	PipeDescriptorName   string          `protobuf:"bytes,8,opt,name=pipe_descriptor_name,json=pipeDescriptorName,proto3" json:"pipe_descriptor_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*PipeExt) Descriptor 

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

func (*PipeExt) GetBinds 

func (m *PipeExt) GetBinds() []*PipeBindExt

func (*PipeExt) GetFlowId 

func (m *PipeExt) GetFlowId() string

func (*PipeExt) GetId 

func (m *PipeExt) GetId() string

func (*PipeExt) GetInputs 

func (m *PipeExt) GetInputs() []string

func (*PipeExt) GetOutputs 

func (m *PipeExt) GetOutputs() []string

func (*PipeExt) GetParams 

func (m *PipeExt) GetParams() map[string]*Any

func (*PipeExt) GetPipeDescriptorId 

func (m *PipeExt) GetPipeDescriptorId() string

func (*PipeExt) GetPipeDescriptorName 

func (m *PipeExt) GetPipeDescriptorName() string

func (*PipeExt) GetPluginId added in v1.0.1 

func (m *PipeExt) GetPluginId() string

func (*PipeExt) GetPluginUri 

func (m *PipeExt) GetPluginUri() string

func (*PipeExt) ProtoMessage 

func (*PipeExt) ProtoMessage()

func (*PipeExt) Reset 

func (m *PipeExt) Reset()

func (*PipeExt) String 

func (m *PipeExt) String() string

func (*PipeExt) XXX_DiscardUnknown 

func (m *PipeExt) XXX_DiscardUnknown()

func (*PipeExt) XXX_Marshal 

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

func (*PipeExt) XXX_Merge 

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

func (*PipeExt) XXX_Size 

func (m *PipeExt) XXX_Size() int

func (*PipeExt) XXX_Unmarshal 

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

type Plugin 

type Plugin struct {
	Id                   string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	UserId               string    `protobuf:"bytes,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	PluginUri            string    `protobuf:"bytes,5,opt,name=plugin_uri,json=pluginUri,proto3" json:"plugin_uri,omitempty"`
	Color                string    `protobuf:"bytes,8,opt,name=color,proto3" json:"color,omitempty"`
	CreatedAt            *UnixTime `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            *UnixTime `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Plugin) Descriptor 

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

func (*Plugin) GetColor added in v1.0.1 

func (m *Plugin) GetColor() string

func (*Plugin) GetCreatedAt 

func (m *Plugin) GetCreatedAt() *UnixTime

func (*Plugin) GetId 

func (m *Plugin) GetId() string

func (*Plugin) GetName 

func (m *Plugin) GetName() string

func (*Plugin) GetPluginUri 

func (m *Plugin) GetPluginUri() string

func (*Plugin) GetUpdatedAt 

func (m *Plugin) GetUpdatedAt() *UnixTime

func (*Plugin) GetUserId 

func (m *Plugin) GetUserId() string

func (*Plugin) ProtoMessage 

func (*Plugin) ProtoMessage()

func (*Plugin) Reset 

func (m *Plugin) Reset()

func (*Plugin) String 

func (m *Plugin) String() string

func (*Plugin) XXX_DiscardUnknown 

func (m *Plugin) XXX_DiscardUnknown()

func (*Plugin) XXX_Marshal 

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

func (*Plugin) XXX_Merge 

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

func (*Plugin) XXX_Size 

func (m *Plugin) XXX_Size() int

func (*Plugin) XXX_Unmarshal 

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

type PluginReceiveServiceClient 

type PluginReceiveServiceClient interface {
	InitPipe(ctx context.Context, in *InitPipeReq, opts ...grpc.CallOption) (*InitPipeRes, error)
	DestroyPipe(ctx context.Context, in *DestroyPipeReq, opts ...grpc.CallOption) (*DestroyPipeRes, error)
	ReceiveMsg(ctx context.Context, in *ReceiveMsgReq, opts ...grpc.CallOption) (*ReceiveMsgRes, error)
	ReceiveStreamMsg(ctx context.Context, opts ...grpc.CallOption) (PluginReceiveService_ReceiveStreamMsgClient, error)
}

PluginReceiveServiceClient is the client API for PluginReceiveService service.

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

func NewPluginReceiveServiceClient 

func NewPluginReceiveServiceClient(cc *grpc.ClientConn) PluginReceiveServiceClient

type PluginReceiveServiceServer 

type PluginReceiveServiceServer interface {
	InitPipe(context.Context, *InitPipeReq) (*InitPipeRes, error)
	DestroyPipe(context.Context, *DestroyPipeReq) (*DestroyPipeRes, error)
	ReceiveMsg(context.Context, *ReceiveMsgReq) (*ReceiveMsgRes, error)
	ReceiveStreamMsg(PluginReceiveService_ReceiveStreamMsgServer) error
}

PluginReceiveServiceServer is the server API for PluginReceiveService service.

type PluginReceiveService_ReceiveStreamMsgClient 

type PluginReceiveService_ReceiveStreamMsgClient interface {
	Send(*ReceiveMsgReq) error
	CloseAndRecv() (*ReceiveMsgRes, error)
	grpc.ClientStream
}

type PluginReceiveService_ReceiveStreamMsgServer 

type PluginReceiveService_ReceiveStreamMsgServer interface {
	SendAndClose(*ReceiveMsgRes) error
	Recv() (*ReceiveMsgReq, error)
	grpc.ServerStream
}

type PluginSendServiceClient 

type PluginSendServiceClient interface {
	SendMsg(ctx context.Context, in *SendMsgReq, opts ...grpc.CallOption) (*SendMsgRes, error)
	SendStreamMsg(ctx context.Context, opts ...grpc.CallOption) (PluginSendService_SendStreamMsgClient, error)
}

PluginSendServiceClient is the client API for PluginSendService service.

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

func NewPluginSendServiceClient 

func NewPluginSendServiceClient(cc *grpc.ClientConn) PluginSendServiceClient

type PluginSendServiceServer 

type PluginSendServiceServer interface {
	SendMsg(context.Context, *SendMsgReq) (*SendMsgRes, error)
	SendStreamMsg(PluginSendService_SendStreamMsgServer) error
}

PluginSendServiceServer is the server API for PluginSendService service.

type PluginSendService_SendStreamMsgClient 

type PluginSendService_SendStreamMsgClient interface {
	Send(*SendMsgReq) error
	CloseAndRecv() (*SendMsgRes, error)
	grpc.ClientStream
}

type PluginSendService_SendStreamMsgServer 

type PluginSendService_SendStreamMsgServer interface {
	SendAndClose(*SendMsgRes) error
	Recv() (*SendMsgReq, error)
	grpc.ServerStream
}

type PluginService 

type PluginService struct {
	Port int
	// contains filtered or unexported fields
}

func NewPluginService 

func NewPluginService(port int) (*PluginService, error)

NewPluginServiceWithPort create PluginService on custom port

func NewPluginServiceWithDefaultPort 

func NewPluginServiceWithDefaultPort() (*PluginService, error)

NewPluginService create PluginService on default port 5550

func (*PluginService) RegisterActivePipe 

func (p *PluginService) RegisterActivePipe(pipeDescriptorName string, pipe ActivePipe) bool

func (*PluginService) RegisterInputPipe 

func (p *PluginService) RegisterInputPipe(pipeDescriptorName string, pipe InputPipe) bool

func (*PluginService) UnregisterActivePipe 

func (p *PluginService) UnregisterActivePipe(pipeDescriptorName string) bool

func (*PluginService) UnregisterInputPipe 

func (p *PluginService) UnregisterInputPipe(pipeDescriptorName string) bool

func (*PluginService) WaitForClose 

func (p *PluginService) WaitForClose()

type PluginServiceClient 

type PluginServiceClient interface {
	GetPlugin(ctx context.Context, in *GetPluginReq, opts ...grpc.CallOption) (*Plugin, error)
	AddPlugin(ctx context.Context, in *AddPluginReq, opts ...grpc.CallOption) (*AddPluginRes, error)
	UpdatePlugin(ctx context.Context, in *UpdatePluginReq, opts ...grpc.CallOption) (*UpdatePluginRes, error)
	RemovePlugin(ctx context.Context, in *RemovePluginReq, opts ...grpc.CallOption) (*RemovePluginRes, error)
	ListPlugins(ctx context.Context, in *ListPluginsReq, opts ...grpc.CallOption) (*ListPluginsRes, error)
}

PluginServiceClient is the client API for PluginService service.

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

func NewPluginServiceClient 

func NewPluginServiceClient(cc *grpc.ClientConn) PluginServiceClient

type PluginServiceServer 

type PluginServiceServer interface {
	GetPlugin(context.Context, *GetPluginReq) (*Plugin, error)
	AddPlugin(context.Context, *AddPluginReq) (*AddPluginRes, error)
	UpdatePlugin(context.Context, *UpdatePluginReq) (*UpdatePluginRes, error)
	RemovePlugin(context.Context, *RemovePluginReq) (*RemovePluginRes, error)
	ListPlugins(context.Context, *ListPluginsReq) (*ListPluginsRes, error)
}

PluginServiceServer is the server API for PluginService service.

type ReceiveMsgReq 

type ReceiveMsgReq struct {
	Pipe                 *PipeExt        `protobuf:"bytes,1,opt,name=pipe,proto3" json:"pipe,omitempty"`
	InputId              string          `protobuf:"bytes,2,opt,name=input_id,json=inputId,proto3" json:"input_id,omitempty"`
	Message              map[string]*Any `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ReceiveMsgReq) Descriptor 

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

func (*ReceiveMsgReq) GetInputId 

func (m *ReceiveMsgReq) GetInputId() string

func (*ReceiveMsgReq) GetMessage 

func (m *ReceiveMsgReq) GetMessage() map[string]*Any

func (*ReceiveMsgReq) GetPipe 

func (m *ReceiveMsgReq) GetPipe() *PipeExt

func (*ReceiveMsgReq) ProtoMessage 

func (*ReceiveMsgReq) ProtoMessage()

func (*ReceiveMsgReq) Reset 

func (m *ReceiveMsgReq) Reset()

func (*ReceiveMsgReq) String 

func (m *ReceiveMsgReq) String() string

func (*ReceiveMsgReq) XXX_DiscardUnknown 

func (m *ReceiveMsgReq) XXX_DiscardUnknown()

func (*ReceiveMsgReq) XXX_Marshal 

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

func (*ReceiveMsgReq) XXX_Merge 

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

func (*ReceiveMsgReq) XXX_Size 

func (m *ReceiveMsgReq) XXX_Size() int

func (*ReceiveMsgReq) XXX_Unmarshal 

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

type ReceiveMsgRes 

type ReceiveMsgRes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReceiveMsgRes) Descriptor 

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

func (*ReceiveMsgRes) ProtoMessage 

func (*ReceiveMsgRes) ProtoMessage()

func (*ReceiveMsgRes) Reset 

func (m *ReceiveMsgRes) Reset()

func (*ReceiveMsgRes) String 

func (m *ReceiveMsgRes) String() string

func (*ReceiveMsgRes) XXX_DiscardUnknown 

func (m *ReceiveMsgRes) XXX_DiscardUnknown()

func (*ReceiveMsgRes) XXX_Marshal 

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

func (*ReceiveMsgRes) XXX_Merge 

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

func (*ReceiveMsgRes) XXX_Size 

func (m *ReceiveMsgRes) XXX_Size() int

func (*ReceiveMsgRes) XXX_Unmarshal 

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

type RemoveDeviceReq 

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

func (*RemoveDeviceReq) Descriptor 

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

func (*RemoveDeviceReq) GetId 

func (m *RemoveDeviceReq) GetId() string

func (*RemoveDeviceReq) ProtoMessage 

func (*RemoveDeviceReq) ProtoMessage()

func (*RemoveDeviceReq) Reset 

func (m *RemoveDeviceReq) Reset()

func (*RemoveDeviceReq) String 

func (m *RemoveDeviceReq) String() string

func (*RemoveDeviceReq) XXX_DiscardUnknown 

func (m *RemoveDeviceReq) XXX_DiscardUnknown()

func (*RemoveDeviceReq) XXX_Marshal 

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

func (*RemoveDeviceReq) XXX_Merge 

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

func (*RemoveDeviceReq) XXX_Size 

func (m *RemoveDeviceReq) XXX_Size() int

func (*RemoveDeviceReq) XXX_Unmarshal 

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

type RemoveDeviceRes 

type RemoveDeviceRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveDeviceRes) Descriptor 

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

func (*RemoveDeviceRes) GetOk 

func (m *RemoveDeviceRes) GetOk() bool

func (*RemoveDeviceRes) ProtoMessage 

func (*RemoveDeviceRes) ProtoMessage()

func (*RemoveDeviceRes) Reset 

func (m *RemoveDeviceRes) Reset()

func (*RemoveDeviceRes) String 

func (m *RemoveDeviceRes) String() string

func (*RemoveDeviceRes) XXX_DiscardUnknown 

func (m *RemoveDeviceRes) XXX_DiscardUnknown()

func (*RemoveDeviceRes) XXX_Marshal 

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

func (*RemoveDeviceRes) XXX_Merge 

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

func (*RemoveDeviceRes) XXX_Size 

func (m *RemoveDeviceRes) XXX_Size() int

func (*RemoveDeviceRes) XXX_Unmarshal 

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

type RemoveDeviceTypeReq 

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

func (*RemoveDeviceTypeReq) Descriptor 

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

func (*RemoveDeviceTypeReq) GetId 

func (m *RemoveDeviceTypeReq) GetId() string

func (*RemoveDeviceTypeReq) ProtoMessage 

func (*RemoveDeviceTypeReq) ProtoMessage()

func (*RemoveDeviceTypeReq) Reset 

func (m *RemoveDeviceTypeReq) Reset()

func (*RemoveDeviceTypeReq) String 

func (m *RemoveDeviceTypeReq) String() string

func (*RemoveDeviceTypeReq) XXX_DiscardUnknown 

func (m *RemoveDeviceTypeReq) XXX_DiscardUnknown()

func (*RemoveDeviceTypeReq) XXX_Marshal 

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

func (*RemoveDeviceTypeReq) XXX_Merge 

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

func (*RemoveDeviceTypeReq) XXX_Size 

func (m *RemoveDeviceTypeReq) XXX_Size() int

func (*RemoveDeviceTypeReq) XXX_Unmarshal 

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

type RemoveDeviceTypeRes 

type RemoveDeviceTypeRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveDeviceTypeRes) Descriptor 

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

func (*RemoveDeviceTypeRes) GetOk 

func (m *RemoveDeviceTypeRes) GetOk() bool

func (*RemoveDeviceTypeRes) ProtoMessage 

func (*RemoveDeviceTypeRes) ProtoMessage()

func (*RemoveDeviceTypeRes) Reset 

func (m *RemoveDeviceTypeRes) Reset()

func (*RemoveDeviceTypeRes) String 

func (m *RemoveDeviceTypeRes) String() string

func (*RemoveDeviceTypeRes) XXX_DiscardUnknown 

func (m *RemoveDeviceTypeRes) XXX_DiscardUnknown()

func (*RemoveDeviceTypeRes) XXX_Marshal 

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

func (*RemoveDeviceTypeRes) XXX_Merge 

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

func (*RemoveDeviceTypeRes) XXX_Size 

func (m *RemoveDeviceTypeRes) XXX_Size() int

func (*RemoveDeviceTypeRes) XXX_Unmarshal 

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

type RemoveFlowDescriptorReq 

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

func (*RemoveFlowDescriptorReq) Descriptor 

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

func (*RemoveFlowDescriptorReq) GetId 

func (m *RemoveFlowDescriptorReq) GetId() string

func (*RemoveFlowDescriptorReq) ProtoMessage 

func (*RemoveFlowDescriptorReq) ProtoMessage()

func (*RemoveFlowDescriptorReq) Reset 

func (m *RemoveFlowDescriptorReq) Reset()

func (*RemoveFlowDescriptorReq) String 

func (m *RemoveFlowDescriptorReq) String() string

func (*RemoveFlowDescriptorReq) XXX_DiscardUnknown 

func (m *RemoveFlowDescriptorReq) XXX_DiscardUnknown()

func (*RemoveFlowDescriptorReq) XXX_Marshal 

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

func (*RemoveFlowDescriptorReq) XXX_Merge 

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

func (*RemoveFlowDescriptorReq) XXX_Size 

func (m *RemoveFlowDescriptorReq) XXX_Size() int

func (*RemoveFlowDescriptorReq) XXX_Unmarshal 

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

type RemoveFlowDescriptorRes 

type RemoveFlowDescriptorRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveFlowDescriptorRes) Descriptor 

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

func (*RemoveFlowDescriptorRes) GetOk 

func (m *RemoveFlowDescriptorRes) GetOk() bool

func (*RemoveFlowDescriptorRes) ProtoMessage 

func (*RemoveFlowDescriptorRes) ProtoMessage()

func (*RemoveFlowDescriptorRes) Reset 

func (m *RemoveFlowDescriptorRes) Reset()

func (*RemoveFlowDescriptorRes) String 

func (m *RemoveFlowDescriptorRes) String() string

func (*RemoveFlowDescriptorRes) XXX_DiscardUnknown 

func (m *RemoveFlowDescriptorRes) XXX_DiscardUnknown()

func (*RemoveFlowDescriptorRes) XXX_Marshal 

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

func (*RemoveFlowDescriptorRes) XXX_Merge 

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

func (*RemoveFlowDescriptorRes) XXX_Size 

func (m *RemoveFlowDescriptorRes) XXX_Size() int

func (*RemoveFlowDescriptorRes) XXX_Unmarshal 

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

type RemoveFlowReq 

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

func (*RemoveFlowReq) Descriptor 

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

func (*RemoveFlowReq) GetId 

func (m *RemoveFlowReq) GetId() string

func (*RemoveFlowReq) ProtoMessage 

func (*RemoveFlowReq) ProtoMessage()

func (*RemoveFlowReq) Reset 

func (m *RemoveFlowReq) Reset()

func (*RemoveFlowReq) String 

func (m *RemoveFlowReq) String() string

func (*RemoveFlowReq) XXX_DiscardUnknown 

func (m *RemoveFlowReq) XXX_DiscardUnknown()

func (*RemoveFlowReq) XXX_Marshal 

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

func (*RemoveFlowReq) XXX_Merge 

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

func (*RemoveFlowReq) XXX_Size 

func (m *RemoveFlowReq) XXX_Size() int

func (*RemoveFlowReq) XXX_Unmarshal 

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

type RemoveFlowRes 

type RemoveFlowRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveFlowRes) Descriptor 

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

func (*RemoveFlowRes) GetOk 

func (m *RemoveFlowRes) GetOk() bool

func (*RemoveFlowRes) ProtoMessage 

func (*RemoveFlowRes) ProtoMessage()

func (*RemoveFlowRes) Reset 

func (m *RemoveFlowRes) Reset()

func (*RemoveFlowRes) String 

func (m *RemoveFlowRes) String() string

func (*RemoveFlowRes) XXX_DiscardUnknown 

func (m *RemoveFlowRes) XXX_DiscardUnknown()

func (*RemoveFlowRes) XXX_Marshal 

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

func (*RemoveFlowRes) XXX_Merge 

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

func (*RemoveFlowRes) XXX_Size 

func (m *RemoveFlowRes) XXX_Size() int

func (*RemoveFlowRes) XXX_Unmarshal 

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

type RemovePipeDescriptorReq 

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

func (*RemovePipeDescriptorReq) Descriptor 

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

func (*RemovePipeDescriptorReq) GetId 

func (m *RemovePipeDescriptorReq) GetId() string

func (*RemovePipeDescriptorReq) ProtoMessage 

func (*RemovePipeDescriptorReq) ProtoMessage()

func (*RemovePipeDescriptorReq) Reset 

func (m *RemovePipeDescriptorReq) Reset()

func (*RemovePipeDescriptorReq) String 

func (m *RemovePipeDescriptorReq) String() string

func (*RemovePipeDescriptorReq) XXX_DiscardUnknown 

func (m *RemovePipeDescriptorReq) XXX_DiscardUnknown()

func (*RemovePipeDescriptorReq) XXX_Marshal 

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

func (*RemovePipeDescriptorReq) XXX_Merge 

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

func (*RemovePipeDescriptorReq) XXX_Size 

func (m *RemovePipeDescriptorReq) XXX_Size() int

func (*RemovePipeDescriptorReq) XXX_Unmarshal 

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

type RemovePipeDescriptorRes 

type RemovePipeDescriptorRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemovePipeDescriptorRes) Descriptor 

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

func (*RemovePipeDescriptorRes) GetOk 

func (m *RemovePipeDescriptorRes) GetOk() bool

func (*RemovePipeDescriptorRes) ProtoMessage 

func (*RemovePipeDescriptorRes) ProtoMessage()

func (*RemovePipeDescriptorRes) Reset 

func (m *RemovePipeDescriptorRes) Reset()

func (*RemovePipeDescriptorRes) String 

func (m *RemovePipeDescriptorRes) String() string

func (*RemovePipeDescriptorRes) XXX_DiscardUnknown 

func (m *RemovePipeDescriptorRes) XXX_DiscardUnknown()

func (*RemovePipeDescriptorRes) XXX_Marshal 

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

func (*RemovePipeDescriptorRes) XXX_Merge 

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

func (*RemovePipeDescriptorRes) XXX_Size 

func (m *RemovePipeDescriptorRes) XXX_Size() int

func (*RemovePipeDescriptorRes) XXX_Unmarshal 

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

type RemovePluginReq 

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

func (*RemovePluginReq) Descriptor 

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

func (*RemovePluginReq) GetId 

func (m *RemovePluginReq) GetId() string

func (*RemovePluginReq) ProtoMessage 

func (*RemovePluginReq) ProtoMessage()

func (*RemovePluginReq) Reset 

func (m *RemovePluginReq) Reset()

func (*RemovePluginReq) String 

func (m *RemovePluginReq) String() string

func (*RemovePluginReq) XXX_DiscardUnknown 

func (m *RemovePluginReq) XXX_DiscardUnknown()

func (*RemovePluginReq) XXX_Marshal 

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

func (*RemovePluginReq) XXX_Merge 

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

func (*RemovePluginReq) XXX_Size 

func (m *RemovePluginReq) XXX_Size() int

func (*RemovePluginReq) XXX_Unmarshal 

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

type RemovePluginRes 

type RemovePluginRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemovePluginRes) Descriptor 

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

func (*RemovePluginRes) GetOk 

func (m *RemovePluginRes) GetOk() bool

func (*RemovePluginRes) ProtoMessage 

func (*RemovePluginRes) ProtoMessage()

func (*RemovePluginRes) Reset 

func (m *RemovePluginRes) Reset()

func (*RemovePluginRes) String 

func (m *RemovePluginRes) String() string

func (*RemovePluginRes) XXX_DiscardUnknown 

func (m *RemovePluginRes) XXX_DiscardUnknown()

func (*RemovePluginRes) XXX_Marshal 

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

func (*RemovePluginRes) XXX_Merge 

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

func (*RemovePluginRes) XXX_Size 

func (m *RemovePluginRes) XXX_Size() int

func (*RemovePluginRes) XXX_Unmarshal 

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

type ResetPasswordReq 

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

func (*ResetPasswordReq) Descriptor 

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

func (*ResetPasswordReq) GetNewPass 

func (m *ResetPasswordReq) GetNewPass() string

func (*ResetPasswordReq) GetToken 

func (m *ResetPasswordReq) GetToken() string

func (*ResetPasswordReq) ProtoMessage 

func (*ResetPasswordReq) ProtoMessage()

func (*ResetPasswordReq) Reset 

func (m *ResetPasswordReq) Reset()

func (*ResetPasswordReq) String 

func (m *ResetPasswordReq) String() string

func (*ResetPasswordReq) XXX_DiscardUnknown 

func (m *ResetPasswordReq) XXX_DiscardUnknown()

func (*ResetPasswordReq) XXX_Marshal 

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

func (*ResetPasswordReq) XXX_Merge 

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

func (*ResetPasswordReq) XXX_Size 

func (m *ResetPasswordReq) XXX_Size() int

func (*ResetPasswordReq) XXX_Unmarshal 

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

type ResetPasswordRes 

type ResetPasswordRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResetPasswordRes) Descriptor 

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

func (*ResetPasswordRes) GetOk 

func (m *ResetPasswordRes) GetOk() bool

func (*ResetPasswordRes) ProtoMessage 

func (*ResetPasswordRes) ProtoMessage()

func (*ResetPasswordRes) Reset 

func (m *ResetPasswordRes) Reset()

func (*ResetPasswordRes) String 

func (m *ResetPasswordRes) String() string

func (*ResetPasswordRes) XXX_DiscardUnknown 

func (m *ResetPasswordRes) XXX_DiscardUnknown()

func (*ResetPasswordRes) XXX_Marshal 

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

func (*ResetPasswordRes) XXX_Merge 

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

func (*ResetPasswordRes) XXX_Size 

func (m *ResetPasswordRes) XXX_Size() int

func (*ResetPasswordRes) XXX_Unmarshal 

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

type SendFlowUIReq 

type SendFlowUIReq struct {
	FlowId               string   `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	UiName               string   `protobuf:"bytes,2,opt,name=ui_name,json=uiName,proto3" json:"ui_name,omitempty"`
	Value                *Any     `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendFlowUIReq) Descriptor 

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

func (*SendFlowUIReq) GetFlowId 

func (m *SendFlowUIReq) GetFlowId() string

func (*SendFlowUIReq) GetUiName 

func (m *SendFlowUIReq) GetUiName() string

func (*SendFlowUIReq) GetValue 

func (m *SendFlowUIReq) GetValue() *Any

func (*SendFlowUIReq) ProtoMessage 

func (*SendFlowUIReq) ProtoMessage()

func (*SendFlowUIReq) Reset 

func (m *SendFlowUIReq) Reset()

func (*SendFlowUIReq) String 

func (m *SendFlowUIReq) String() string

func (*SendFlowUIReq) XXX_DiscardUnknown 

func (m *SendFlowUIReq) XXX_DiscardUnknown()

func (*SendFlowUIReq) XXX_Marshal 

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

func (*SendFlowUIReq) XXX_Merge 

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

func (*SendFlowUIReq) XXX_Size 

func (m *SendFlowUIReq) XXX_Size() int

func (*SendFlowUIReq) XXX_Unmarshal 

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

type SendFlowUIRes 

type SendFlowUIRes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendFlowUIRes) Descriptor 

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

func (*SendFlowUIRes) ProtoMessage 

func (*SendFlowUIRes) ProtoMessage()

func (*SendFlowUIRes) Reset 

func (m *SendFlowUIRes) Reset()

func (*SendFlowUIRes) String 

func (m *SendFlowUIRes) String() string

func (*SendFlowUIRes) XXX_DiscardUnknown 

func (m *SendFlowUIRes) XXX_DiscardUnknown()

func (*SendFlowUIRes) XXX_Marshal 

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

func (*SendFlowUIRes) XXX_Merge 

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

func (*SendFlowUIRes) XXX_Size 

func (m *SendFlowUIRes) XXX_Size() int

func (*SendFlowUIRes) XXX_Unmarshal 

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

type SendMsgReq 

type SendMsgReq struct {
	Pipe                 *PipeExt        `protobuf:"bytes,1,opt,name=pipe,proto3" json:"pipe,omitempty"`
	InputId              string          `protobuf:"bytes,2,opt,name=input_id,json=inputId,proto3" json:"input_id,omitempty"`
	Message              map[string]*Any `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*SendMsgReq) Descriptor 

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

func (*SendMsgReq) GetInputId 

func (m *SendMsgReq) GetInputId() string

func (*SendMsgReq) GetMessage 

func (m *SendMsgReq) GetMessage() map[string]*Any

func (*SendMsgReq) GetPipe 

func (m *SendMsgReq) GetPipe() *PipeExt

func (*SendMsgReq) ProtoMessage 

func (*SendMsgReq) ProtoMessage()

func (*SendMsgReq) Reset 

func (m *SendMsgReq) Reset()

func (*SendMsgReq) String 

func (m *SendMsgReq) String() string

func (*SendMsgReq) XXX_DiscardUnknown 

func (m *SendMsgReq) XXX_DiscardUnknown()

func (*SendMsgReq) XXX_Marshal 

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

func (*SendMsgReq) XXX_Merge 

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

func (*SendMsgReq) XXX_Size 

func (m *SendMsgReq) XXX_Size() int

func (*SendMsgReq) XXX_Unmarshal 

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

type SendMsgRes 

type SendMsgRes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendMsgRes) Descriptor 

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

func (*SendMsgRes) ProtoMessage 

func (*SendMsgRes) ProtoMessage()

func (*SendMsgRes) Reset 

func (m *SendMsgRes) Reset()

func (*SendMsgRes) String 

func (m *SendMsgRes) String() string

func (*SendMsgRes) XXX_DiscardUnknown 

func (m *SendMsgRes) XXX_DiscardUnknown()

func (*SendMsgRes) XXX_Marshal 

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

func (*SendMsgRes) XXX_Merge 

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

func (*SendMsgRes) XXX_Size 

func (m *SendMsgRes) XXX_Size() int

func (*SendMsgRes) XXX_Unmarshal 

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

type SendResetPasswordLinkReq 

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

func (*SendResetPasswordLinkReq) Descriptor 

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

func (*SendResetPasswordLinkReq) GetEmail 

func (m *SendResetPasswordLinkReq) GetEmail() string

func (*SendResetPasswordLinkReq) ProtoMessage 

func (*SendResetPasswordLinkReq) ProtoMessage()

func (*SendResetPasswordLinkReq) Reset 

func (m *SendResetPasswordLinkReq) Reset()

func (*SendResetPasswordLinkReq) String 

func (m *SendResetPasswordLinkReq) String() string

func (*SendResetPasswordLinkReq) XXX_DiscardUnknown 

func (m *SendResetPasswordLinkReq) XXX_DiscardUnknown()

func (*SendResetPasswordLinkReq) XXX_Marshal 

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

func (*SendResetPasswordLinkReq) XXX_Merge 

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

func (*SendResetPasswordLinkReq) XXX_Size 

func (m *SendResetPasswordLinkReq) XXX_Size() int

func (*SendResetPasswordLinkReq) XXX_Unmarshal 

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

type SendResetPasswordLinkRes 

type SendResetPasswordLinkRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendResetPasswordLinkRes) Descriptor 

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

func (*SendResetPasswordLinkRes) GetOk 

func (m *SendResetPasswordLinkRes) GetOk() bool

func (*SendResetPasswordLinkRes) ProtoMessage 

func (*SendResetPasswordLinkRes) ProtoMessage()

func (*SendResetPasswordLinkRes) Reset 

func (m *SendResetPasswordLinkRes) Reset()

func (*SendResetPasswordLinkRes) String 

func (m *SendResetPasswordLinkRes) String() string

func (*SendResetPasswordLinkRes) XXX_DiscardUnknown 

func (m *SendResetPasswordLinkRes) XXX_DiscardUnknown()

func (*SendResetPasswordLinkRes) XXX_Marshal 

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

func (*SendResetPasswordLinkRes) XXX_Merge 

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

func (*SendResetPasswordLinkRes) XXX_Size 

func (m *SendResetPasswordLinkRes) XXX_Size() int

func (*SendResetPasswordLinkRes) XXX_Unmarshal 

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

type SetFlowStatusReq 

type SetFlowStatusReq struct {
	FlowId               string     `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	Status               FlowStatus `protobuf:"varint,2,opt,name=status,proto3,enum=schema.FlowStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*SetFlowStatusReq) Descriptor 

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

func (*SetFlowStatusReq) GetFlowId 

func (m *SetFlowStatusReq) GetFlowId() string

func (*SetFlowStatusReq) GetStatus 

func (m *SetFlowStatusReq) GetStatus() FlowStatus

func (*SetFlowStatusReq) ProtoMessage 

func (*SetFlowStatusReq) ProtoMessage()

func (*SetFlowStatusReq) Reset 

func (m *SetFlowStatusReq) Reset()

func (*SetFlowStatusReq) String 

func (m *SetFlowStatusReq) String() string

func (*SetFlowStatusReq) XXX_DiscardUnknown 

func (m *SetFlowStatusReq) XXX_DiscardUnknown()

func (*SetFlowStatusReq) XXX_Marshal 

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

func (*SetFlowStatusReq) XXX_Merge 

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

func (*SetFlowStatusReq) XXX_Size 

func (m *SetFlowStatusReq) XXX_Size() int

func (*SetFlowStatusReq) XXX_Unmarshal 

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

type SetFlowStatusRes 

type SetFlowStatusRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetFlowStatusRes) Descriptor 

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

func (*SetFlowStatusRes) GetOk 

func (m *SetFlowStatusRes) GetOk() bool

func (*SetFlowStatusRes) ProtoMessage 

func (*SetFlowStatusRes) ProtoMessage()

func (*SetFlowStatusRes) Reset 

func (m *SetFlowStatusRes) Reset()

func (*SetFlowStatusRes) String 

func (m *SetFlowStatusRes) String() string

func (*SetFlowStatusRes) XXX_DiscardUnknown 

func (m *SetFlowStatusRes) XXX_DiscardUnknown()

func (*SetFlowStatusRes) XXX_Marshal 

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

func (*SetFlowStatusRes) XXX_Merge 

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

func (*SetFlowStatusRes) XXX_Size 

func (m *SetFlowStatusRes) XXX_Size() int

func (*SetFlowStatusRes) XXX_Unmarshal 

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

type SetFlowVariableReq 

type SetFlowVariableReq struct {
	FlowId               string   `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value                *Any     `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetFlowVariableReq) Descriptor 

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

func (*SetFlowVariableReq) GetFlowId 

func (m *SetFlowVariableReq) GetFlowId() string

func (*SetFlowVariableReq) GetName 

func (m *SetFlowVariableReq) GetName() string

func (*SetFlowVariableReq) GetValue 

func (m *SetFlowVariableReq) GetValue() *Any

func (*SetFlowVariableReq) ProtoMessage 

func (*SetFlowVariableReq) ProtoMessage()

func (*SetFlowVariableReq) Reset 

func (m *SetFlowVariableReq) Reset()

func (*SetFlowVariableReq) String 

func (m *SetFlowVariableReq) String() string

func (*SetFlowVariableReq) XXX_DiscardUnknown 

func (m *SetFlowVariableReq) XXX_DiscardUnknown()

func (*SetFlowVariableReq) XXX_Marshal 

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

func (*SetFlowVariableReq) XXX_Merge 

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

func (*SetFlowVariableReq) XXX_Size 

func (m *SetFlowVariableReq) XXX_Size() int

func (*SetFlowVariableReq) XXX_Unmarshal 

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

type SetFlowVariableRes 

type SetFlowVariableRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetFlowVariableRes) Descriptor 

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

func (*SetFlowVariableRes) GetOk 

func (m *SetFlowVariableRes) GetOk() bool

func (*SetFlowVariableRes) ProtoMessage 

func (*SetFlowVariableRes) ProtoMessage()

func (*SetFlowVariableRes) Reset 

func (m *SetFlowVariableRes) Reset()

func (*SetFlowVariableRes) String 

func (m *SetFlowVariableRes) String() string

func (*SetFlowVariableRes) XXX_DiscardUnknown 

func (m *SetFlowVariableRes) XXX_DiscardUnknown()

func (*SetFlowVariableRes) XXX_Marshal 

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

func (*SetFlowVariableRes) XXX_Merge 

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

func (*SetFlowVariableRes) XXX_Size 

func (m *SetFlowVariableRes) XXX_Size() int

func (*SetFlowVariableRes) XXX_Unmarshal 

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

type Sort 

type Sort struct {
	Order                string   `protobuf:"bytes,1,opt,name=order,proto3" json:"order,omitempty"`
	By                   Sort_By  `protobuf:"varint,2,opt,name=by,proto3,enum=schema.Sort_By" json:"by,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Sort) Descriptor 

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

func (*Sort) GetBy 

func (m *Sort) GetBy() Sort_By

func (*Sort) GetOrder 

func (m *Sort) GetOrder() string

func (*Sort) ProtoMessage 

func (*Sort) ProtoMessage()

func (*Sort) Reset 

func (m *Sort) Reset()

func (*Sort) String 

func (m *Sort) String() string

func (*Sort) XXX_DiscardUnknown 

func (m *Sort) XXX_DiscardUnknown()

func (*Sort) XXX_Marshal 

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

func (*Sort) XXX_Merge 

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

func (*Sort) XXX_Size 

func (m *Sort) XXX_Size() int

func (*Sort) XXX_Unmarshal 

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

type SortDirection 

type SortDirection int32
const (
	SortDirection_NO_SORT SortDirection = 0
	SortDirection_ASC     SortDirection = 1
	SortDirection_DESC    SortDirection = 2
)

func (SortDirection) EnumDescriptor 

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

func (SortDirection) String 

func (x SortDirection) String() string

type Sort_By 

type Sort_By int32
const (
	Sort_ASC  Sort_By = 0
	Sort_DESC Sort_By = 1
)

func (Sort_By) EnumDescriptor 

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

func (Sort_By) String 

func (x Sort_By) String() string

type StartFlowReq 

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

func (*StartFlowReq) Descriptor 

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

func (*StartFlowReq) GetId 

func (m *StartFlowReq) GetId() string

func (*StartFlowReq) ProtoMessage 

func (*StartFlowReq) ProtoMessage()

func (*StartFlowReq) Reset 

func (m *StartFlowReq) Reset()

func (*StartFlowReq) String 

func (m *StartFlowReq) String() string

func (*StartFlowReq) XXX_DiscardUnknown 

func (m *StartFlowReq) XXX_DiscardUnknown()

func (*StartFlowReq) XXX_Marshal 

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

func (*StartFlowReq) XXX_Merge 

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

func (*StartFlowReq) XXX_Size 

func (m *StartFlowReq) XXX_Size() int

func (*StartFlowReq) XXX_Unmarshal 

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

type StartFlowRes 

type StartFlowRes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartFlowRes) Descriptor 

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

func (*StartFlowRes) ProtoMessage 

func (*StartFlowRes) ProtoMessage()

func (*StartFlowRes) Reset 

func (m *StartFlowRes) Reset()

func (*StartFlowRes) String 

func (m *StartFlowRes) String() string

func (*StartFlowRes) XXX_DiscardUnknown 

func (m *StartFlowRes) XXX_DiscardUnknown()

func (*StartFlowRes) XXX_Marshal 

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

func (*StartFlowRes) XXX_Merge 

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

func (*StartFlowRes) XXX_Size 

func (m *StartFlowRes) XXX_Size() int

func (*StartFlowRes) XXX_Unmarshal 

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

type StopFlowReq 

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

func (*StopFlowReq) Descriptor 

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

func (*StopFlowReq) GetId 

func (m *StopFlowReq) GetId() string

func (*StopFlowReq) ProtoMessage 

func (*StopFlowReq) ProtoMessage()

func (*StopFlowReq) Reset 

func (m *StopFlowReq) Reset()

func (*StopFlowReq) String 

func (m *StopFlowReq) String() string

func (*StopFlowReq) XXX_DiscardUnknown 

func (m *StopFlowReq) XXX_DiscardUnknown()

func (*StopFlowReq) XXX_Marshal 

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

func (*StopFlowReq) XXX_Merge 

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

func (*StopFlowReq) XXX_Size 

func (m *StopFlowReq) XXX_Size() int

func (*StopFlowReq) XXX_Unmarshal 

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

type StopFlowRes 

type StopFlowRes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopFlowRes) Descriptor 

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

func (*StopFlowRes) ProtoMessage 

func (*StopFlowRes) ProtoMessage()

func (*StopFlowRes) Reset 

func (m *StopFlowRes) Reset()

func (*StopFlowRes) String 

func (m *StopFlowRes) String() string

func (*StopFlowRes) XXX_DiscardUnknown 

func (m *StopFlowRes) XXX_DiscardUnknown()

func (*StopFlowRes) XXX_Marshal 

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

func (*StopFlowRes) XXX_Merge 

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

func (*StopFlowRes) XXX_Size 

func (m *StopFlowRes) XXX_Size() int

func (*StopFlowRes) XXX_Unmarshal 

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

type Token 

type Token struct {
	Id                   string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Value                string    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	TargetId             string    `protobuf:"bytes,3,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	UserId               string    `protobuf:"bytes,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Type                 string    `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	Permissions          []string  `protobuf:"bytes,6,rep,name=permissions,proto3" json:"permissions,omitempty"`
	CreatedAt            *UnixTime `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ExpiryAt             *UnixTime `protobuf:"bytes,8,opt,name=expiry_at,json=expiryAt,proto3" json:"expiry_at,omitempty"`
	Active               bool      `protobuf:"varint,9,opt,name=active,proto3" json:"active,omitempty"`
	UsedAt               *UnixTime `protobuf:"bytes,10,opt,name=used_at,json=usedAt,proto3" json:"used_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Token) Descriptor 

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

func (*Token) GetActive 

func (m *Token) GetActive() bool

func (*Token) GetCreatedAt 

func (m *Token) GetCreatedAt() *UnixTime

func (*Token) GetExpiryAt 

func (m *Token) GetExpiryAt() *UnixTime

func (*Token) GetId 

func (m *Token) GetId() string

func (*Token) GetPermissions 

func (m *Token) GetPermissions() []string

func (*Token) GetTargetId 

func (m *Token) GetTargetId() string

func (*Token) GetType 

func (m *Token) GetType() string

func (*Token) GetUsedAt 

func (m *Token) GetUsedAt() *UnixTime

func (*Token) GetUserId 

func (m *Token) GetUserId() string

func (*Token) GetValue 

func (m *Token) GetValue() string

func (*Token) ProtoMessage 

func (*Token) ProtoMessage()

func (*Token) Reset 

func (m *Token) Reset()

func (*Token) String 

func (m *Token) String() string

func (*Token) XXX_DiscardUnknown 

func (m *Token) XXX_DiscardUnknown()

func (*Token) XXX_Marshal 

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

func (*Token) XXX_Merge 

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

func (*Token) XXX_Size 

func (m *Token) XXX_Size() int

func (*Token) XXX_Unmarshal 

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

type UnimplementedDeviceServiceServer 

type UnimplementedDeviceServiceServer struct {
}

UnimplementedDeviceServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDeviceServiceServer) AddDevice 

func (*UnimplementedDeviceServiceServer) AddDevice(ctx context.Context, req *AddDeviceReq) (*AddDeviceRes, error)

func (*UnimplementedDeviceServiceServer) GetDevice 

func (*UnimplementedDeviceServiceServer) GetDevice(ctx context.Context, req *GetDeviceReq) (*Device, error)

func (*UnimplementedDeviceServiceServer) ListDevices 

func (*UnimplementedDeviceServiceServer) ListDevices(ctx context.Context, req *ListDevicesReq) (*ListDevicesRes, error)

func (*UnimplementedDeviceServiceServer) RemoveDevice 

func (*UnimplementedDeviceServiceServer) RemoveDevice(ctx context.Context, req *RemoveDeviceReq) (*RemoveDeviceRes, error)

func (*UnimplementedDeviceServiceServer) UpdateDevice 

func (*UnimplementedDeviceServiceServer) UpdateDevice(ctx context.Context, req *UpdateDeviceReq) (*UpdateDeviceRes, error)

type UnimplementedDeviceTypeServiceServer 

type UnimplementedDeviceTypeServiceServer struct {
}

UnimplementedDeviceTypeServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDeviceTypeServiceServer) AddDeviceType 

func (*UnimplementedDeviceTypeServiceServer) AddDeviceType(ctx context.Context, req *AddDeviceTypeReq) (*AddDeviceTypeRes, error)

func (*UnimplementedDeviceTypeServiceServer) GetDeviceType 

func (*UnimplementedDeviceTypeServiceServer) GetDeviceType(ctx context.Context, req *GetDeviceTypeReq) (*DeviceType, error)

func (*UnimplementedDeviceTypeServiceServer) ListDeviceTypes 

func (*UnimplementedDeviceTypeServiceServer) ListDeviceTypes(ctx context.Context, req *ListDeviceTypesReq) (*ListDeviceTypesRes, error)

func (*UnimplementedDeviceTypeServiceServer) RemoveDeviceType 

func (*UnimplementedDeviceTypeServiceServer) RemoveDeviceType(ctx context.Context, req *RemoveDeviceTypeReq) (*RemoveDeviceTypeRes, error)

func (*UnimplementedDeviceTypeServiceServer) UpdateDeviceType 

func (*UnimplementedDeviceTypeServiceServer) UpdateDeviceType(ctx context.Context, req *UpdateDeviceTypeReq) (*UpdateDeviceTypeRes, error)

type UnimplementedFlowDescriptorServiceServer 

type UnimplementedFlowDescriptorServiceServer struct {
}

UnimplementedFlowDescriptorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedFlowDescriptorServiceServer) AddFlowDescriptor 

func (*UnimplementedFlowDescriptorServiceServer) AddFlowDescriptor(ctx context.Context, req *AddFlowDescriptorReq) (*AddFlowDescriptorRes, error)

func (*UnimplementedFlowDescriptorServiceServer) GetFlowDescriptor 

func (*UnimplementedFlowDescriptorServiceServer) GetFlowDescriptor(ctx context.Context, req *GetFlowDescriptorReq) (*FlowDescriptor, error)

func (*UnimplementedFlowDescriptorServiceServer) ListFlowDescriptors 

func (*UnimplementedFlowDescriptorServiceServer) ListFlowDescriptors(ctx context.Context, req *ListFlowDescriptorsReq) (*ListFlowDescriptorsRes, error)

func (*UnimplementedFlowDescriptorServiceServer) RemoveFlowDescriptor 

func (*UnimplementedFlowDescriptorServiceServer) RemoveFlowDescriptor(ctx context.Context, req *RemoveFlowDescriptorReq) (*RemoveFlowDescriptorRes, error)

func (*UnimplementedFlowDescriptorServiceServer) UpdateFlowDescriptor 

func (*UnimplementedFlowDescriptorServiceServer) UpdateFlowDescriptor(ctx context.Context, req *UpdateFlowDescriptorReq) (*UpdateFlowDescriptorRes, error)

type UnimplementedFlowServiceServer 

type UnimplementedFlowServiceServer struct {
}

UnimplementedFlowServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedFlowServiceServer) AddFlow 

func (*UnimplementedFlowServiceServer) AddFlow(ctx context.Context, req *AddFlowReq) (*AddFlowRes, error)

func (*UnimplementedFlowServiceServer) GetFlow 

func (*UnimplementedFlowServiceServer) GetFlow(ctx context.Context, req *GetFlowReq) (*Flow, error)

func (*UnimplementedFlowServiceServer) GetFlowVariable 

func (*UnimplementedFlowServiceServer) GetFlowVariable(ctx context.Context, req *GetFlowVariableReq) (*GetFlowVariableRes, error)

func (*UnimplementedFlowServiceServer) ListFlowUI added in v1.0.1 

func (*UnimplementedFlowServiceServer) ListFlowUI(ctx context.Context, req *ListFlowUIReq) (*ListFlowUIRes, error)

func (*UnimplementedFlowServiceServer) RemoveFlow 

func (*UnimplementedFlowServiceServer) RemoveFlow(ctx context.Context, req *RemoveFlowReq) (*RemoveFlowRes, error)

func (*UnimplementedFlowServiceServer) SendFlowUI 

func (*UnimplementedFlowServiceServer) SendFlowUI(ctx context.Context, req *SendFlowUIReq) (*SendFlowUIRes, error)

func (*UnimplementedFlowServiceServer) SetFlowStatus 

func (*UnimplementedFlowServiceServer) SetFlowStatus(ctx context.Context, req *SetFlowStatusReq) (*SetFlowStatusRes, error)

func (*UnimplementedFlowServiceServer) SetFlowVariable 

func (*UnimplementedFlowServiceServer) SetFlowVariable(ctx context.Context, req *SetFlowVariableReq) (*SetFlowVariableRes, error)

func (*UnimplementedFlowServiceServer) StartFlow 

func (*UnimplementedFlowServiceServer) StartFlow(ctx context.Context, req *StartFlowReq) (*StartFlowRes, error)

func (*UnimplementedFlowServiceServer) StopFlow 

func (*UnimplementedFlowServiceServer) StopFlow(ctx context.Context, req *StopFlowReq) (*StopFlowRes, error)

func (*UnimplementedFlowServiceServer) WatchFlowUI 

func (*UnimplementedFlowServiceServer) WatchFlowUI(req *WatchFlowUIReq, srv FlowService_WatchFlowUIServer) error

func (*UnimplementedFlowServiceServer) WatchFlowVariable 

func (*UnimplementedFlowServiceServer) WatchFlowVariable(req *WatchFlowVariableReq, srv FlowService_WatchFlowVariableServer) error

type UnimplementedPipeDescriptorServiceServer 

type UnimplementedPipeDescriptorServiceServer struct {
}

UnimplementedPipeDescriptorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPipeDescriptorServiceServer) AddPipeDescriptor 

func (*UnimplementedPipeDescriptorServiceServer) AddPipeDescriptor(ctx context.Context, req *AddPipeDescriptorReq) (*AddPipeDescriptorRes, error)

func (*UnimplementedPipeDescriptorServiceServer) GetPipeDescriptor 

func (*UnimplementedPipeDescriptorServiceServer) GetPipeDescriptor(ctx context.Context, req *GetPipeDescriptorReq) (*PipeDescriptor, error)

func (*UnimplementedPipeDescriptorServiceServer) ListPipeDescriptors 

func (*UnimplementedPipeDescriptorServiceServer) ListPipeDescriptors(ctx context.Context, req *ListPipeDescriptorsReq) (*ListPipeDescriptorsRes, error)

func (*UnimplementedPipeDescriptorServiceServer) RemovePipeDescriptor 

func (*UnimplementedPipeDescriptorServiceServer) RemovePipeDescriptor(ctx context.Context, req *RemovePipeDescriptorReq) (*RemovePipeDescriptorRes, error)

func (*UnimplementedPipeDescriptorServiceServer) UpdatePipeDescriptor 

func (*UnimplementedPipeDescriptorServiceServer) UpdatePipeDescriptor(ctx context.Context, req *UpdatePipeDescriptorReq) (*UpdatePipeDescriptorRes, error)

type UnimplementedPluginReceiveServiceServer 

type UnimplementedPluginReceiveServiceServer struct {
}

UnimplementedPluginReceiveServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPluginReceiveServiceServer) DestroyPipe 

func (*UnimplementedPluginReceiveServiceServer) DestroyPipe(ctx context.Context, req *DestroyPipeReq) (*DestroyPipeRes, error)

func (*UnimplementedPluginReceiveServiceServer) InitPipe 

func (*UnimplementedPluginReceiveServiceServer) InitPipe(ctx context.Context, req *InitPipeReq) (*InitPipeRes, error)

func (*UnimplementedPluginReceiveServiceServer) ReceiveMsg 

func (*UnimplementedPluginReceiveServiceServer) ReceiveMsg(ctx context.Context, req *ReceiveMsgReq) (*ReceiveMsgRes, error)

func (*UnimplementedPluginReceiveServiceServer) ReceiveStreamMsg 

func (*UnimplementedPluginReceiveServiceServer) ReceiveStreamMsg(srv PluginReceiveService_ReceiveStreamMsgServer) error

type UnimplementedPluginSendServiceServer 

type UnimplementedPluginSendServiceServer struct {
}

UnimplementedPluginSendServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPluginSendServiceServer) SendMsg 

func (*UnimplementedPluginSendServiceServer) SendMsg(ctx context.Context, req *SendMsgReq) (*SendMsgRes, error)

func (*UnimplementedPluginSendServiceServer) SendStreamMsg 

func (*UnimplementedPluginSendServiceServer) SendStreamMsg(srv PluginSendService_SendStreamMsgServer) error

type UnimplementedPluginServiceServer 

type UnimplementedPluginServiceServer struct {
}

UnimplementedPluginServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPluginServiceServer) AddPlugin 

func (*UnimplementedPluginServiceServer) AddPlugin(ctx context.Context, req *AddPluginReq) (*AddPluginRes, error)

func (*UnimplementedPluginServiceServer) GetPlugin 

func (*UnimplementedPluginServiceServer) GetPlugin(ctx context.Context, req *GetPluginReq) (*Plugin, error)

func (*UnimplementedPluginServiceServer) ListPlugins 

func (*UnimplementedPluginServiceServer) ListPlugins(ctx context.Context, req *ListPluginsReq) (*ListPluginsRes, error)

func (*UnimplementedPluginServiceServer) RemovePlugin 

func (*UnimplementedPluginServiceServer) RemovePlugin(ctx context.Context, req *RemovePluginReq) (*RemovePluginRes, error)

func (*UnimplementedPluginServiceServer) UpdatePlugin 

func (*UnimplementedPluginServiceServer) UpdatePlugin(ctx context.Context, req *UpdatePluginReq) (*UpdatePluginRes, error)

type UnimplementedUserServiceServer 

type UnimplementedUserServiceServer struct {
}

UnimplementedUserServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedUserServiceServer) ChangeUserPassword 

func (*UnimplementedUserServiceServer) ChangeUserPassword(ctx context.Context, req *ChangeUserPasswordReq) (*ChangeUserPasswordRes, error)

func (*UnimplementedUserServiceServer) CreateUser 

func (*UnimplementedUserServiceServer) CreateUser(ctx context.Context, req *CreateUserReq) (*Token, error)

func (*UnimplementedUserServiceServer) GetUser 

func (*UnimplementedUserServiceServer) GetUser(ctx context.Context, req *GetUserReq) (*User, error)

func (*UnimplementedUserServiceServer) GetUserTokens 

func (*UnimplementedUserServiceServer) GetUserTokens(ctx context.Context, req *GetUserTokensReq) (*GetUserTokensRes, error)

func (*UnimplementedUserServiceServer) Login 

func (*UnimplementedUserServiceServer) Login(ctx context.Context, req *LoginReq) (*Token, error)

func (*UnimplementedUserServiceServer) ResetPassword 

func (*UnimplementedUserServiceServer) ResetPassword(ctx context.Context, req *ResetPasswordReq) (*ResetPasswordRes, error)
func (*UnimplementedUserServiceServer) SendResetPasswordLink(ctx context.Context, req *SendResetPasswordLinkReq) (*SendResetPasswordLinkRes, error)

func (*UnimplementedUserServiceServer) UpdateUser 

func (*UnimplementedUserServiceServer) UpdateUser(ctx context.Context, req *UpdateUserReq) (*UpdateUserRes, error)

type UnixTime 

type UnixTime struct {
	Sec                  int64    `protobuf:"varint,1,opt,name=sec,proto3" json:"sec,omitempty"`
	Nsec                 int64    `protobuf:"varint,2,opt,name=nsec,proto3" json:"nsec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewUnixTime 

func NewUnixTime(t time.Time) *UnixTime

func (*UnixTime) Descriptor 

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

func (*UnixTime) GetNsec 

func (m *UnixTime) GetNsec() int64

func (*UnixTime) GetSec 

func (m *UnixTime) GetSec() int64

func (*UnixTime) ProtoMessage 

func (*UnixTime) ProtoMessage()

func (*UnixTime) Reset 

func (m *UnixTime) Reset()

func (*UnixTime) String 

func (m *UnixTime) String() string

func (*UnixTime) Time 

func (ut *UnixTime) Time() time.Time

func (*UnixTime) XXX_DiscardUnknown 

func (m *UnixTime) XXX_DiscardUnknown()

func (*UnixTime) XXX_Marshal 

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

func (*UnixTime) XXX_Merge 

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

func (*UnixTime) XXX_Size 

func (m *UnixTime) XXX_Size() int

func (*UnixTime) XXX_Unmarshal 

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

type UpdateDeviceReq 

type UpdateDeviceReq struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateDeviceReq) Descriptor 

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

func (*UpdateDeviceReq) GetId 

func (m *UpdateDeviceReq) GetId() string

func (*UpdateDeviceReq) GetName 

func (m *UpdateDeviceReq) GetName() string

func (*UpdateDeviceReq) ProtoMessage 

func (*UpdateDeviceReq) ProtoMessage()

func (*UpdateDeviceReq) Reset 

func (m *UpdateDeviceReq) Reset()

func (*UpdateDeviceReq) String 

func (m *UpdateDeviceReq) String() string

func (*UpdateDeviceReq) XXX_DiscardUnknown 

func (m *UpdateDeviceReq) XXX_DiscardUnknown()

func (*UpdateDeviceReq) XXX_Marshal 

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

func (*UpdateDeviceReq) XXX_Merge 

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

func (*UpdateDeviceReq) XXX_Size 

func (m *UpdateDeviceReq) XXX_Size() int

func (*UpdateDeviceReq) XXX_Unmarshal 

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

type UpdateDeviceRes 

type UpdateDeviceRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateDeviceRes) Descriptor 

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

func (*UpdateDeviceRes) GetOk 

func (m *UpdateDeviceRes) GetOk() bool

func (*UpdateDeviceRes) ProtoMessage 

func (*UpdateDeviceRes) ProtoMessage()

func (*UpdateDeviceRes) Reset 

func (m *UpdateDeviceRes) Reset()

func (*UpdateDeviceRes) String 

func (m *UpdateDeviceRes) String() string

func (*UpdateDeviceRes) XXX_DiscardUnknown 

func (m *UpdateDeviceRes) XXX_DiscardUnknown()

func (*UpdateDeviceRes) XXX_Marshal 

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

func (*UpdateDeviceRes) XXX_Merge 

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

func (*UpdateDeviceRes) XXX_Size 

func (m *UpdateDeviceRes) XXX_Size() int

func (*UpdateDeviceRes) XXX_Unmarshal 

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

type UpdateDeviceTypeReq 

type UpdateDeviceTypeReq struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateDeviceTypeReq) Descriptor 

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

func (*UpdateDeviceTypeReq) GetId 

func (m *UpdateDeviceTypeReq) GetId() string

func (*UpdateDeviceTypeReq) GetName 

func (m *UpdateDeviceTypeReq) GetName() string

func (*UpdateDeviceTypeReq) ProtoMessage 

func (*UpdateDeviceTypeReq) ProtoMessage()

func (*UpdateDeviceTypeReq) Reset 

func (m *UpdateDeviceTypeReq) Reset()

func (*UpdateDeviceTypeReq) String 

func (m *UpdateDeviceTypeReq) String() string

func (*UpdateDeviceTypeReq) XXX_DiscardUnknown 

func (m *UpdateDeviceTypeReq) XXX_DiscardUnknown()

func (*UpdateDeviceTypeReq) XXX_Marshal 

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

func (*UpdateDeviceTypeReq) XXX_Merge 

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

func (*UpdateDeviceTypeReq) XXX_Size 

func (m *UpdateDeviceTypeReq) XXX_Size() int

func (*UpdateDeviceTypeReq) XXX_Unmarshal 

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

type UpdateDeviceTypeRes 

type UpdateDeviceTypeRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateDeviceTypeRes) Descriptor 

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

func (*UpdateDeviceTypeRes) GetOk 

func (m *UpdateDeviceTypeRes) GetOk() bool

func (*UpdateDeviceTypeRes) ProtoMessage 

func (*UpdateDeviceTypeRes) ProtoMessage()

func (*UpdateDeviceTypeRes) Reset 

func (m *UpdateDeviceTypeRes) Reset()

func (*UpdateDeviceTypeRes) String 

func (m *UpdateDeviceTypeRes) String() string

func (*UpdateDeviceTypeRes) XXX_DiscardUnknown 

func (m *UpdateDeviceTypeRes) XXX_DiscardUnknown()

func (*UpdateDeviceTypeRes) XXX_Marshal 

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

func (*UpdateDeviceTypeRes) XXX_Merge 

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

func (*UpdateDeviceTypeRes) XXX_Size 

func (m *UpdateDeviceTypeRes) XXX_Size() int

func (*UpdateDeviceTypeRes) XXX_Unmarshal 

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

type UpdateFlowDescriptorReq 

type UpdateFlowDescriptorReq struct {
	Id                   string                    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string                    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Variables            []*FlowVariableDescriptor `protobuf:"bytes,3,rep,name=variables,proto3" json:"variables,omitempty"`
	Pipes                []*Pipe                   `protobuf:"bytes,4,rep,name=pipes,proto3" json:"pipes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*UpdateFlowDescriptorReq) Descriptor 

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

func (*UpdateFlowDescriptorReq) GetId 

func (m *UpdateFlowDescriptorReq) GetId() string

func (*UpdateFlowDescriptorReq) GetName 

func (m *UpdateFlowDescriptorReq) GetName() string

func (*UpdateFlowDescriptorReq) GetPipes 

func (m *UpdateFlowDescriptorReq) GetPipes() []*Pipe

func (*UpdateFlowDescriptorReq) GetVariables 

func (m *UpdateFlowDescriptorReq) GetVariables() []*FlowVariableDescriptor

func (*UpdateFlowDescriptorReq) ProtoMessage 

func (*UpdateFlowDescriptorReq) ProtoMessage()

func (*UpdateFlowDescriptorReq) Reset 

func (m *UpdateFlowDescriptorReq) Reset()

func (*UpdateFlowDescriptorReq) String 

func (m *UpdateFlowDescriptorReq) String() string

func (*UpdateFlowDescriptorReq) XXX_DiscardUnknown 

func (m *UpdateFlowDescriptorReq) XXX_DiscardUnknown()

func (*UpdateFlowDescriptorReq) XXX_Marshal 

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

func (*UpdateFlowDescriptorReq) XXX_Merge 

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

func (*UpdateFlowDescriptorReq) XXX_Size 

func (m *UpdateFlowDescriptorReq) XXX_Size() int

func (*UpdateFlowDescriptorReq) XXX_Unmarshal 

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

type UpdateFlowDescriptorRes 

type UpdateFlowDescriptorRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateFlowDescriptorRes) Descriptor 

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

func (*UpdateFlowDescriptorRes) GetOk 

func (m *UpdateFlowDescriptorRes) GetOk() bool

func (*UpdateFlowDescriptorRes) ProtoMessage 

func (*UpdateFlowDescriptorRes) ProtoMessage()

func (*UpdateFlowDescriptorRes) Reset 

func (m *UpdateFlowDescriptorRes) Reset()

func (*UpdateFlowDescriptorRes) String 

func (m *UpdateFlowDescriptorRes) String() string

func (*UpdateFlowDescriptorRes) XXX_DiscardUnknown 

func (m *UpdateFlowDescriptorRes) XXX_DiscardUnknown()

func (*UpdateFlowDescriptorRes) XXX_Marshal 

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

func (*UpdateFlowDescriptorRes) XXX_Merge 

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

func (*UpdateFlowDescriptorRes) XXX_Size 

func (m *UpdateFlowDescriptorRes) XXX_Size() int

func (*UpdateFlowDescriptorRes) XXX_Unmarshal 

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

type UpdatePipeDescriptorReq 

type UpdatePipeDescriptorReq struct {
	Id                   string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	PluginId             string                 `protobuf:"bytes,3,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	Description          string                 `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Params               []*PipeDescriptorParam `protobuf:"bytes,5,rep,name=params,proto3" json:"params,omitempty"`
	Inputs               []string               `protobuf:"bytes,6,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs              []string               `protobuf:"bytes,7,rep,name=outputs,proto3" json:"outputs,omitempty"`
	NeedInit             bool                   `protobuf:"varint,8,opt,name=need_init,json=needInit,proto3" json:"need_init,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*UpdatePipeDescriptorReq) Descriptor 

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

func (*UpdatePipeDescriptorReq) GetDescription 

func (m *UpdatePipeDescriptorReq) GetDescription() string

func (*UpdatePipeDescriptorReq) GetId 

func (m *UpdatePipeDescriptorReq) GetId() string

func (*UpdatePipeDescriptorReq) GetInputs 

func (m *UpdatePipeDescriptorReq) GetInputs() []string

func (*UpdatePipeDescriptorReq) GetName 

func (m *UpdatePipeDescriptorReq) GetName() string

func (*UpdatePipeDescriptorReq) GetNeedInit 

func (m *UpdatePipeDescriptorReq) GetNeedInit() bool

func (*UpdatePipeDescriptorReq) GetOutputs 

func (m *UpdatePipeDescriptorReq) GetOutputs() []string

func (*UpdatePipeDescriptorReq) GetParams 

func (m *UpdatePipeDescriptorReq) GetParams() []*PipeDescriptorParam

func (*UpdatePipeDescriptorReq) GetPluginId 

func (m *UpdatePipeDescriptorReq) GetPluginId() string

func (*UpdatePipeDescriptorReq) ProtoMessage 

func (*UpdatePipeDescriptorReq) ProtoMessage()

func (*UpdatePipeDescriptorReq) Reset 

func (m *UpdatePipeDescriptorReq) Reset()

func (*UpdatePipeDescriptorReq) String 

func (m *UpdatePipeDescriptorReq) String() string

func (*UpdatePipeDescriptorReq) XXX_DiscardUnknown 

func (m *UpdatePipeDescriptorReq) XXX_DiscardUnknown()

func (*UpdatePipeDescriptorReq) XXX_Marshal 

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

func (*UpdatePipeDescriptorReq) XXX_Merge 

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

func (*UpdatePipeDescriptorReq) XXX_Size 

func (m *UpdatePipeDescriptorReq) XXX_Size() int

func (*UpdatePipeDescriptorReq) XXX_Unmarshal 

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

type UpdatePipeDescriptorRes 

type UpdatePipeDescriptorRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdatePipeDescriptorRes) Descriptor 

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

func (*UpdatePipeDescriptorRes) GetOk 

func (m *UpdatePipeDescriptorRes) GetOk() bool

func (*UpdatePipeDescriptorRes) ProtoMessage 

func (*UpdatePipeDescriptorRes) ProtoMessage()

func (*UpdatePipeDescriptorRes) Reset 

func (m *UpdatePipeDescriptorRes) Reset()

func (*UpdatePipeDescriptorRes) String 

func (m *UpdatePipeDescriptorRes) String() string

func (*UpdatePipeDescriptorRes) XXX_DiscardUnknown 

func (m *UpdatePipeDescriptorRes) XXX_DiscardUnknown()

func (*UpdatePipeDescriptorRes) XXX_Marshal 

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

func (*UpdatePipeDescriptorRes) XXX_Merge 

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

func (*UpdatePipeDescriptorRes) XXX_Size 

func (m *UpdatePipeDescriptorRes) XXX_Size() int

func (*UpdatePipeDescriptorRes) XXX_Unmarshal 

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

type UpdatePluginReq 

type UpdatePluginReq struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	PluginUri            string   `protobuf:"bytes,3,opt,name=plugin_uri,json=pluginUri,proto3" json:"plugin_uri,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdatePluginReq) Descriptor 

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

func (*UpdatePluginReq) GetId 

func (m *UpdatePluginReq) GetId() string

func (*UpdatePluginReq) GetName 

func (m *UpdatePluginReq) GetName() string

func (*UpdatePluginReq) GetPluginUri 

func (m *UpdatePluginReq) GetPluginUri() string

func (*UpdatePluginReq) ProtoMessage 

func (*UpdatePluginReq) ProtoMessage()

func (*UpdatePluginReq) Reset 

func (m *UpdatePluginReq) Reset()

func (*UpdatePluginReq) String 

func (m *UpdatePluginReq) String() string

func (*UpdatePluginReq) XXX_DiscardUnknown 

func (m *UpdatePluginReq) XXX_DiscardUnknown()

func (*UpdatePluginReq) XXX_Marshal 

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

func (*UpdatePluginReq) XXX_Merge 

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

func (*UpdatePluginReq) XXX_Size 

func (m *UpdatePluginReq) XXX_Size() int

func (*UpdatePluginReq) XXX_Unmarshal 

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

type UpdatePluginRes 

type UpdatePluginRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdatePluginRes) Descriptor 

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

func (*UpdatePluginRes) GetOk 

func (m *UpdatePluginRes) GetOk() bool

func (*UpdatePluginRes) ProtoMessage 

func (*UpdatePluginRes) ProtoMessage()

func (*UpdatePluginRes) Reset 

func (m *UpdatePluginRes) Reset()

func (*UpdatePluginRes) String 

func (m *UpdatePluginRes) String() string

func (*UpdatePluginRes) XXX_DiscardUnknown 

func (m *UpdatePluginRes) XXX_DiscardUnknown()

func (*UpdatePluginRes) XXX_Marshal 

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

func (*UpdatePluginRes) XXX_Merge 

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

func (*UpdatePluginRes) XXX_Size 

func (m *UpdatePluginRes) XXX_Size() int

func (*UpdatePluginRes) XXX_Unmarshal 

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

type UpdateUserReq 

type UpdateUserReq struct {
	Email                *wrappers.StringValue  `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	Phone                *wrappers.StringValue  `protobuf:"bytes,2,opt,name=phone,proto3" json:"phone,omitempty"`
	Profile              *UpdateUserReq_Profile `protobuf:"bytes,3,opt,name=profile,proto3" json:"profile,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*UpdateUserReq) Descriptor 

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

func (*UpdateUserReq) GetEmail 

func (m *UpdateUserReq) GetEmail() *wrappers.StringValue

func (*UpdateUserReq) GetPhone 

func (m *UpdateUserReq) GetPhone() *wrappers.StringValue

func (*UpdateUserReq) GetProfile 

func (m *UpdateUserReq) GetProfile() *UpdateUserReq_Profile

func (*UpdateUserReq) ProtoMessage 

func (*UpdateUserReq) ProtoMessage()

func (*UpdateUserReq) Reset 

func (m *UpdateUserReq) Reset()

func (*UpdateUserReq) String 

func (m *UpdateUserReq) String() string

func (*UpdateUserReq) XXX_DiscardUnknown 

func (m *UpdateUserReq) XXX_DiscardUnknown()

func (*UpdateUserReq) XXX_Marshal 

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

func (*UpdateUserReq) XXX_Merge 

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

func (*UpdateUserReq) XXX_Size 

func (m *UpdateUserReq) XXX_Size() int

func (*UpdateUserReq) XXX_Unmarshal 

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

type UpdateUserReq_Profile 

type UpdateUserReq_Profile struct {
	FullName             *wrappers.StringValue `protobuf:"bytes,1,opt,name=full_name,json=fullName,proto3" json:"full_name,omitempty"`
	Address              *wrappers.StringValue `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*UpdateUserReq_Profile) Descriptor 

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

func (*UpdateUserReq_Profile) GetAddress 

func (m *UpdateUserReq_Profile) GetAddress() *wrappers.StringValue

func (*UpdateUserReq_Profile) GetFullName 

func (m *UpdateUserReq_Profile) GetFullName() *wrappers.StringValue

func (*UpdateUserReq_Profile) ProtoMessage 

func (*UpdateUserReq_Profile) ProtoMessage()

func (*UpdateUserReq_Profile) Reset 

func (m *UpdateUserReq_Profile) Reset()

func (*UpdateUserReq_Profile) String 

func (m *UpdateUserReq_Profile) String() string

func (*UpdateUserReq_Profile) XXX_DiscardUnknown 

func (m *UpdateUserReq_Profile) XXX_DiscardUnknown()

func (*UpdateUserReq_Profile) XXX_Marshal 

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

func (*UpdateUserReq_Profile) XXX_Merge 

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

func (*UpdateUserReq_Profile) XXX_Size 

func (m *UpdateUserReq_Profile) XXX_Size() int

func (*UpdateUserReq_Profile) XXX_Unmarshal 

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

type UpdateUserRes 

type UpdateUserRes struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateUserRes) Descriptor 

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

func (*UpdateUserRes) GetOk 

func (m *UpdateUserRes) GetOk() bool

func (*UpdateUserRes) ProtoMessage 

func (*UpdateUserRes) ProtoMessage()

func (*UpdateUserRes) Reset 

func (m *UpdateUserRes) Reset()

func (*UpdateUserRes) String 

func (m *UpdateUserRes) String() string

func (*UpdateUserRes) XXX_DiscardUnknown 

func (m *UpdateUserRes) XXX_DiscardUnknown()

func (*UpdateUserRes) XXX_Marshal 

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

func (*UpdateUserRes) XXX_Merge 

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

func (*UpdateUserRes) XXX_Size 

func (m *UpdateUserRes) XXX_Size() int

func (*UpdateUserRes) XXX_Unmarshal 

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

type User 

type User struct {
	Id                   string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Email                *UserEmail   `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"`
	Phone                string       `protobuf:"bytes,5,opt,name=phone,proto3" json:"phone,omitempty"`
	CreatedAt            *UnixTime    `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Profile              *UserProfile `protobuf:"bytes,4,opt,name=profile,proto3" json:"profile,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*User) Descriptor 

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

func (*User) GetCreatedAt 

func (m *User) GetCreatedAt() *UnixTime

func (*User) GetEmail 

func (m *User) GetEmail() *UserEmail

func (*User) GetId 

func (m *User) GetId() string

func (*User) GetPhone 

func (m *User) GetPhone() string

func (*User) GetProfile 

func (m *User) GetProfile() *UserProfile

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) Reset 

func (m *User) Reset()

func (*User) String 

func (m *User) String() string

func (*User) XXX_DiscardUnknown 

func (m *User) XXX_DiscardUnknown()

func (*User) XXX_Marshal 

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

func (*User) XXX_Merge 

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

func (*User) XXX_Size 

func (m *User) XXX_Size() int

func (*User) XXX_Unmarshal 

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

type UserEmail 

type UserEmail struct {
	Address              string   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Verified             bool     `protobuf:"varint,2,opt,name=verified,proto3" json:"verified,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserEmail) Descriptor 

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

func (*UserEmail) GetAddress 

func (m *UserEmail) GetAddress() string

func (*UserEmail) GetVerified 

func (m *UserEmail) GetVerified() bool

func (*UserEmail) ProtoMessage 

func (*UserEmail) ProtoMessage()

func (*UserEmail) Reset 

func (m *UserEmail) Reset()

func (*UserEmail) String 

func (m *UserEmail) String() string

func (*UserEmail) XXX_DiscardUnknown 

func (m *UserEmail) XXX_DiscardUnknown()

func (*UserEmail) XXX_Marshal 

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

func (*UserEmail) XXX_Merge 

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

func (*UserEmail) XXX_Size 

func (m *UserEmail) XXX_Size() int

func (*UserEmail) XXX_Unmarshal 

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

type UserProfile 

type UserProfile struct {
	FullName             string   `protobuf:"bytes,1,opt,name=full_name,json=fullName,proto3" json:"full_name,omitempty"`
	Address              string   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserProfile) Descriptor 

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

func (*UserProfile) GetAddress 

func (m *UserProfile) GetAddress() string

func (*UserProfile) GetFullName 

func (m *UserProfile) GetFullName() string

func (*UserProfile) ProtoMessage 

func (*UserProfile) ProtoMessage()

func (*UserProfile) Reset 

func (m *UserProfile) Reset()

func (*UserProfile) String 

func (m *UserProfile) String() string

func (*UserProfile) XXX_DiscardUnknown 

func (m *UserProfile) XXX_DiscardUnknown()

func (*UserProfile) XXX_Marshal 

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

func (*UserProfile) XXX_Merge 

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

func (*UserProfile) XXX_Size 

func (m *UserProfile) XXX_Size() int

func (*UserProfile) XXX_Unmarshal 

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

type UserServiceClient 

type UserServiceClient interface {
	GetUser(ctx context.Context, in *GetUserReq, opts ...grpc.CallOption) (*User, error)
	GetUserTokens(ctx context.Context, in *GetUserTokensReq, opts ...grpc.CallOption) (*GetUserTokensRes, error)
	Login(ctx context.Context, in *LoginReq, opts ...grpc.CallOption) (*Token, error)
	CreateUser(ctx context.Context, in *CreateUserReq, opts ...grpc.CallOption) (*Token, error)
	SendResetPasswordLink(ctx context.Context, in *SendResetPasswordLinkReq, opts ...grpc.CallOption) (*SendResetPasswordLinkRes, error)
	ResetPassword(ctx context.Context, in *ResetPasswordReq, opts ...grpc.CallOption) (*ResetPasswordRes, error)
	ChangeUserPassword(ctx context.Context, in *ChangeUserPasswordReq, opts ...grpc.CallOption) (*ChangeUserPasswordRes, error)
	UpdateUser(ctx context.Context, in *UpdateUserReq, opts ...grpc.CallOption) (*UpdateUserRes, error)
}

UserServiceClient is the client API for UserService service.

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

func NewUserServiceClient 

func NewUserServiceClient(cc *grpc.ClientConn) UserServiceClient

type UserServiceServer 

type UserServiceServer interface {
	GetUser(context.Context, *GetUserReq) (*User, error)
	GetUserTokens(context.Context, *GetUserTokensReq) (*GetUserTokensRes, error)
	Login(context.Context, *LoginReq) (*Token, error)
	CreateUser(context.Context, *CreateUserReq) (*Token, error)
	SendResetPasswordLink(context.Context, *SendResetPasswordLinkReq) (*SendResetPasswordLinkRes, error)
	ResetPassword(context.Context, *ResetPasswordReq) (*ResetPasswordRes, error)
	ChangeUserPassword(context.Context, *ChangeUserPasswordReq) (*ChangeUserPasswordRes, error)
	UpdateUser(context.Context, *UpdateUserReq) (*UpdateUserRes, error)
}

UserServiceServer is the server API for UserService service.

type VarType 

type VarType int32
const (
	VarType_INT    VarType = 0
	VarType_BOOL   VarType = 1
	VarType_STRING VarType = 2
)

func (VarType) EnumDescriptor 

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

func (VarType) String 

func (x VarType) String() string

type WatchFlowUIReq 

type WatchFlowUIReq struct {
	FlowId               string   `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	UiName               string   `protobuf:"bytes,2,opt,name=ui_name,json=uiName,proto3" json:"ui_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchFlowUIReq) Descriptor 

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

func (*WatchFlowUIReq) GetFlowId 

func (m *WatchFlowUIReq) GetFlowId() string

func (*WatchFlowUIReq) GetUiName 

func (m *WatchFlowUIReq) GetUiName() string

func (*WatchFlowUIReq) ProtoMessage 

func (*WatchFlowUIReq) ProtoMessage()

func (*WatchFlowUIReq) Reset 

func (m *WatchFlowUIReq) Reset()

func (*WatchFlowUIReq) String 

func (m *WatchFlowUIReq) String() string

func (*WatchFlowUIReq) XXX_DiscardUnknown 

func (m *WatchFlowUIReq) XXX_DiscardUnknown()

func (*WatchFlowUIReq) XXX_Marshal 

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

func (*WatchFlowUIReq) XXX_Merge 

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

func (*WatchFlowUIReq) XXX_Size 

func (m *WatchFlowUIReq) XXX_Size() int

func (*WatchFlowUIReq) XXX_Unmarshal 

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

type WatchFlowUIRes 

type WatchFlowUIRes struct {
	Value                *Any     `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchFlowUIRes) Descriptor 

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

func (*WatchFlowUIRes) GetValue 

func (m *WatchFlowUIRes) GetValue() *Any

func (*WatchFlowUIRes) ProtoMessage 

func (*WatchFlowUIRes) ProtoMessage()

func (*WatchFlowUIRes) Reset 

func (m *WatchFlowUIRes) Reset()

func (*WatchFlowUIRes) String 

func (m *WatchFlowUIRes) String() string

func (*WatchFlowUIRes) XXX_DiscardUnknown 

func (m *WatchFlowUIRes) XXX_DiscardUnknown()

func (*WatchFlowUIRes) XXX_Marshal 

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

func (*WatchFlowUIRes) XXX_Merge 

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

func (*WatchFlowUIRes) XXX_Size 

func (m *WatchFlowUIRes) XXX_Size() int

func (*WatchFlowUIRes) XXX_Unmarshal 

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

type WatchFlowVariableReq 

type WatchFlowVariableReq struct {
	FlowId               string   `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	VarName              string   `protobuf:"bytes,2,opt,name=var_name,json=varName,proto3" json:"var_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchFlowVariableReq) Descriptor 

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

func (*WatchFlowVariableReq) GetFlowId 

func (m *WatchFlowVariableReq) GetFlowId() string

func (*WatchFlowVariableReq) GetVarName 

func (m *WatchFlowVariableReq) GetVarName() string

func (*WatchFlowVariableReq) ProtoMessage 

func (*WatchFlowVariableReq) ProtoMessage()

func (*WatchFlowVariableReq) Reset 

func (m *WatchFlowVariableReq) Reset()

func (*WatchFlowVariableReq) String 

func (m *WatchFlowVariableReq) String() string

func (*WatchFlowVariableReq) XXX_DiscardUnknown 

func (m *WatchFlowVariableReq) XXX_DiscardUnknown()

func (*WatchFlowVariableReq) XXX_Marshal 

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

func (*WatchFlowVariableReq) XXX_Merge 

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

func (*WatchFlowVariableReq) XXX_Size 

func (m *WatchFlowVariableReq) XXX_Size() int

func (*WatchFlowVariableReq) XXX_Unmarshal 

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

type WatchFlowVariableRes 

type WatchFlowVariableRes struct {
	// variable value
	Value                *Any     `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchFlowVariableRes) Descriptor 

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

func (*WatchFlowVariableRes) GetValue 

func (m *WatchFlowVariableRes) GetValue() *Any

func (*WatchFlowVariableRes) ProtoMessage 

func (*WatchFlowVariableRes) ProtoMessage()

func (*WatchFlowVariableRes) Reset 

func (m *WatchFlowVariableRes) Reset()

func (*WatchFlowVariableRes) String 

func (m *WatchFlowVariableRes) String() string

func (*WatchFlowVariableRes) XXX_DiscardUnknown 

func (m *WatchFlowVariableRes) XXX_DiscardUnknown()

func (*WatchFlowVariableRes) XXX_Marshal 

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

func (*WatchFlowVariableRes) XXX_Merge 

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

func (*WatchFlowVariableRes) XXX_Size 

func (m *WatchFlowVariableRes) XXX_Size() int

func (*WatchFlowVariableRes) XXX_Unmarshal 

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