deviced

package
v1.1.27-debug Latest Latest
Warning

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

 Go to latest Published: Jun 11, 2020 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ConnectMessageKind_name = map[int32]string{
	0: "CONNECT_MESSAGE_KIND_UNKNOWN",
	1: "CONNECT_MESSAGE_KIND_SYSTEM",
	2: "CONNECT_MESSAGE_KIND_USER",
}
View Source 
var ConnectMessageKind_value = map[string]int32{
	"CONNECT_MESSAGE_KIND_UNKNOWN": 0,
	"CONNECT_MESSAGE_KIND_SYSTEM":  1,
	"CONNECT_MESSAGE_KIND_USER":    2,
}

Functions

func RegisterDevicedServiceServer 

func RegisterDevicedServiceServer(s *grpc.Server, srv DevicedServiceServer)

Types

type AddConfigsToDeviceRequest added in v1.1.27 

type AddConfigsToDeviceRequest struct {
	Device               *OpDevice   `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Configs              []*OpConfig `protobuf:"bytes,2,rep,name=configs,proto3" json:"configs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*AddConfigsToDeviceRequest) Descriptor added in v1.1.27 

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

func (*AddConfigsToDeviceRequest) GetConfigs added in v1.1.27 

func (m *AddConfigsToDeviceRequest) GetConfigs() []*OpConfig

func (*AddConfigsToDeviceRequest) GetDevice added in v1.1.27 

func (m *AddConfigsToDeviceRequest) GetDevice() *OpDevice

func (*AddConfigsToDeviceRequest) ProtoMessage added in v1.1.27 

func (*AddConfigsToDeviceRequest) ProtoMessage()

func (*AddConfigsToDeviceRequest) Reset added in v1.1.27 

func (m *AddConfigsToDeviceRequest) Reset()

func (*AddConfigsToDeviceRequest) String added in v1.1.27 

func (m *AddConfigsToDeviceRequest) String() string

func (*AddConfigsToDeviceRequest) Validate added in v1.1.27 

func (this *AddConfigsToDeviceRequest) Validate() error

func (*AddConfigsToDeviceRequest) XXX_DiscardUnknown added in v1.1.27 

func (m *AddConfigsToDeviceRequest) XXX_DiscardUnknown()

func (*AddConfigsToDeviceRequest) XXX_Marshal added in v1.1.27 

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

func (*AddConfigsToDeviceRequest) XXX_Merge added in v1.1.27 

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

func (*AddConfigsToDeviceRequest) XXX_Size added in v1.1.27 

func (m *AddConfigsToDeviceRequest) XXX_Size() int

func (*AddConfigsToDeviceRequest) XXX_Unmarshal added in v1.1.27 

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

type AddFlowsToFlowSetRequest added in v1.1.23 

type AddFlowsToFlowSetRequest struct {
	FlowSet              *OpFlowSet  `protobuf:"bytes,1,opt,name=flow_set,json=flowSet,proto3" json:"flow_set,omitempty"`
	Devices              []*OpDevice `protobuf:"bytes,2,rep,name=devices,proto3" json:"devices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*AddFlowsToFlowSetRequest) Descriptor added in v1.1.23 

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

func (*AddFlowsToFlowSetRequest) GetDevices added in v1.1.23 

func (m *AddFlowsToFlowSetRequest) GetDevices() []*OpDevice

func (*AddFlowsToFlowSetRequest) GetFlowSet added in v1.1.23 

func (m *AddFlowsToFlowSetRequest) GetFlowSet() *OpFlowSet

func (*AddFlowsToFlowSetRequest) ProtoMessage added in v1.1.23 

func (*AddFlowsToFlowSetRequest) ProtoMessage()

func (*AddFlowsToFlowSetRequest) Reset added in v1.1.23 

func (m *AddFlowsToFlowSetRequest) Reset()

func (*AddFlowsToFlowSetRequest) String added in v1.1.23 

func (m *AddFlowsToFlowSetRequest) String() string

func (*AddFlowsToFlowSetRequest) Validate added in v1.1.23 

func (this *AddFlowsToFlowSetRequest) Validate() error

func (*AddFlowsToFlowSetRequest) XXX_DiscardUnknown added in v1.1.23 

func (m *AddFlowsToFlowSetRequest) XXX_DiscardUnknown()

func (*AddFlowsToFlowSetRequest) XXX_Marshal added in v1.1.23 

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

func (*AddFlowsToFlowSetRequest) XXX_Merge added in v1.1.23 

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

func (*AddFlowsToFlowSetRequest) XXX_Size added in v1.1.23 

func (m *AddFlowsToFlowSetRequest) XXX_Size() int

func (*AddFlowsToFlowSetRequest) XXX_Unmarshal added in v1.1.23 

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

type Config added in v1.1.27 

type Config struct {
	Id                   string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Alias                string          `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	Body                 *_struct.Struct `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Config) Descriptor added in v1.1.27 

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

func (*Config) GetAlias added in v1.1.27 

func (m *Config) GetAlias() string

func (*Config) GetBody added in v1.1.27 

func (m *Config) GetBody() *_struct.Struct

func (*Config) GetId added in v1.1.27 

func (m *Config) GetId() string

func (*Config) ProtoMessage added in v1.1.27 

func (*Config) ProtoMessage()

func (*Config) Reset added in v1.1.27 

func (m *Config) Reset()

func (*Config) String added in v1.1.27 

func (m *Config) String() string

func (*Config) Validate added in v1.1.27 

func (this *Config) Validate() error

func (*Config) XXX_DiscardUnknown added in v1.1.27 

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal added in v1.1.27 

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

func (*Config) XXX_Merge added in v1.1.27 

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

func (*Config) XXX_Size added in v1.1.27 

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal added in v1.1.27 

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

type ConnectMessageKind 

type ConnectMessageKind int32
const (
	ConnectMessageKind_CONNECT_MESSAGE_KIND_UNKNOWN ConnectMessageKind = 0
	ConnectMessageKind_CONNECT_MESSAGE_KIND_SYSTEM  ConnectMessageKind = 1
	ConnectMessageKind_CONNECT_MESSAGE_KIND_USER    ConnectMessageKind = 2
)

func (ConnectMessageKind) EnumDescriptor 

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

func (ConnectMessageKind) String 

func (x ConnectMessageKind) String() string

type ConnectRequest 

type ConnectRequest struct {
	SessionId *wrappers.Int64Value `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Kind      ConnectMessageKind   `protobuf:"varint,2,opt,name=kind,proto3,enum=ai.metathings.service.deviced.ConnectMessageKind" json:"kind,omitempty"`
	// Types that are valid to be assigned to Union:
	//	*ConnectRequest_UnaryCall
	//	*ConnectRequest_StreamCall
	Union                isConnectRequest_Union `protobuf_oneof:"union"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ConnectRequest) Descriptor 

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

func (*ConnectRequest) GetKind 

func (m *ConnectRequest) GetKind() ConnectMessageKind

func (*ConnectRequest) GetSessionId 

func (m *ConnectRequest) GetSessionId() *wrappers.Int64Value

func (*ConnectRequest) GetStreamCall 

func (m *ConnectRequest) GetStreamCall() *OpStreamCallValue

func (*ConnectRequest) GetUnaryCall 

func (m *ConnectRequest) GetUnaryCall() *OpUnaryCallValue

func (*ConnectRequest) GetUnion 

func (m *ConnectRequest) GetUnion() isConnectRequest_Union

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset 

func (m *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (m *ConnectRequest) String() string

func (*ConnectRequest) Validate 

func (this *ConnectRequest) Validate() error

func (*ConnectRequest) XXX_DiscardUnknown 

func (m *ConnectRequest) XXX_DiscardUnknown()

func (*ConnectRequest) XXX_Marshal 

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

func (*ConnectRequest) XXX_Merge 

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

func (*ConnectRequest) XXX_OneofWrappers added in v1.0.0 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ConnectRequest) XXX_Size 

func (m *ConnectRequest) XXX_Size() int

func (*ConnectRequest) XXX_Unmarshal 

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

type ConnectRequest_StreamCall 

type ConnectRequest_StreamCall struct {
	StreamCall *OpStreamCallValue `protobuf:"bytes,4,opt,name=stream_call,json=streamCall,proto3,oneof"`
}

type ConnectRequest_UnaryCall 

type ConnectRequest_UnaryCall struct {
	UnaryCall *OpUnaryCallValue `protobuf:"bytes,3,opt,name=unary_call,json=unaryCall,proto3,oneof"`
}

type ConnectResponse 

type ConnectResponse struct {
	SessionId int64              `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Kind      ConnectMessageKind `protobuf:"varint,2,opt,name=kind,proto3,enum=ai.metathings.service.deviced.ConnectMessageKind" json:"kind,omitempty"`
	// Types that are valid to be assigned to Union:
	//	*ConnectResponse_UnaryCall
	//	*ConnectResponse_StreamCall
	//	*ConnectResponse_Err
	Union                isConnectResponse_Union `protobuf_oneof:"union"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ConnectResponse) Descriptor 

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

func (*ConnectResponse) GetErr 

func (m *ConnectResponse) GetErr() *ErrorValue

func (*ConnectResponse) GetKind 

func (m *ConnectResponse) GetKind() ConnectMessageKind

func (*ConnectResponse) GetSessionId 

func (m *ConnectResponse) GetSessionId() int64

func (*ConnectResponse) GetStreamCall 

func (m *ConnectResponse) GetStreamCall() *StreamCallValue

func (*ConnectResponse) GetUnaryCall 

func (m *ConnectResponse) GetUnaryCall() *UnaryCallValue

func (*ConnectResponse) GetUnion 

func (m *ConnectResponse) GetUnion() isConnectResponse_Union

func (*ConnectResponse) ProtoMessage 

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) Reset 

func (m *ConnectResponse) Reset()

func (*ConnectResponse) String 

func (m *ConnectResponse) String() string

func (*ConnectResponse) Validate 

func (this *ConnectResponse) Validate() error

func (*ConnectResponse) XXX_DiscardUnknown 

func (m *ConnectResponse) XXX_DiscardUnknown()

func (*ConnectResponse) XXX_Marshal 

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

func (*ConnectResponse) XXX_Merge 

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

func (*ConnectResponse) XXX_OneofWrappers added in v1.0.0 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ConnectResponse) XXX_Size 

func (m *ConnectResponse) XXX_Size() int

func (*ConnectResponse) XXX_Unmarshal 

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

type ConnectResponse_Err 

type ConnectResponse_Err struct {
	Err *ErrorValue `protobuf:"bytes,9,opt,name=err,proto3,oneof"`
}

type ConnectResponse_StreamCall 

type ConnectResponse_StreamCall struct {
	StreamCall *StreamCallValue `protobuf:"bytes,4,opt,name=stream_call,json=streamCall,proto3,oneof"`
}

type ConnectResponse_UnaryCall 

type ConnectResponse_UnaryCall struct {
	UnaryCall *UnaryCallValue `protobuf:"bytes,3,opt,name=unary_call,json=unaryCall,proto3,oneof"`
}

type CreateConfigRequest added in v1.1.27 

type CreateConfigRequest struct {
	Config               *OpConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*CreateConfigRequest) Descriptor added in v1.1.27 

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

func (*CreateConfigRequest) GetConfig added in v1.1.27 

func (m *CreateConfigRequest) GetConfig() *OpConfig

func (*CreateConfigRequest) ProtoMessage added in v1.1.27 

func (*CreateConfigRequest) ProtoMessage()

func (*CreateConfigRequest) Reset added in v1.1.27 

func (m *CreateConfigRequest) Reset()

func (*CreateConfigRequest) String added in v1.1.27 

func (m *CreateConfigRequest) String() string

func (*CreateConfigRequest) Validate added in v1.1.27 

func (this *CreateConfigRequest) Validate() error

func (*CreateConfigRequest) XXX_DiscardUnknown added in v1.1.27 

func (m *CreateConfigRequest) XXX_DiscardUnknown()

func (*CreateConfigRequest) XXX_Marshal added in v1.1.27 

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

func (*CreateConfigRequest) XXX_Merge added in v1.1.27 

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

func (*CreateConfigRequest) XXX_Size added in v1.1.27 

func (m *CreateConfigRequest) XXX_Size() int

func (*CreateConfigRequest) XXX_Unmarshal added in v1.1.27 

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

type CreateConfigResponse added in v1.1.27 

type CreateConfigResponse struct {
	Config               *Config  `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateConfigResponse) Descriptor added in v1.1.27 

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

func (*CreateConfigResponse) GetConfig added in v1.1.27 

func (m *CreateConfigResponse) GetConfig() *Config

func (*CreateConfigResponse) ProtoMessage added in v1.1.27 

func (*CreateConfigResponse) ProtoMessage()

func (*CreateConfigResponse) Reset added in v1.1.27 

func (m *CreateConfigResponse) Reset()

func (*CreateConfigResponse) String added in v1.1.27 

func (m *CreateConfigResponse) String() string

func (*CreateConfigResponse) Validate added in v1.1.27 

func (this *CreateConfigResponse) Validate() error

func (*CreateConfigResponse) XXX_DiscardUnknown added in v1.1.27 

func (m *CreateConfigResponse) XXX_DiscardUnknown()

func (*CreateConfigResponse) XXX_Marshal added in v1.1.27 

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

func (*CreateConfigResponse) XXX_Merge added in v1.1.27 

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

func (*CreateConfigResponse) XXX_Size added in v1.1.27 

func (m *CreateConfigResponse) XXX_Size() int

func (*CreateConfigResponse) XXX_Unmarshal added in v1.1.27 

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

type CreateDeviceRequest 

type CreateDeviceRequest struct {
	Device               *OpDevice `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*CreateDeviceRequest) Descriptor 

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

func (*CreateDeviceRequest) GetDevice 

func (m *CreateDeviceRequest) GetDevice() *OpDevice

func (*CreateDeviceRequest) ProtoMessage 

func (*CreateDeviceRequest) ProtoMessage()

func (*CreateDeviceRequest) Reset 

func (m *CreateDeviceRequest) Reset()

func (*CreateDeviceRequest) String 

func (m *CreateDeviceRequest) String() string

func (*CreateDeviceRequest) Validate 

func (this *CreateDeviceRequest) Validate() error

func (*CreateDeviceRequest) XXX_DiscardUnknown 

func (m *CreateDeviceRequest) XXX_DiscardUnknown()

func (*CreateDeviceRequest) XXX_Marshal 

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

func (*CreateDeviceRequest) XXX_Merge 

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

func (*CreateDeviceRequest) XXX_Size 

func (m *CreateDeviceRequest) XXX_Size() int

func (*CreateDeviceRequest) XXX_Unmarshal 

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

type CreateDeviceResponse 

type CreateDeviceResponse struct {
	Device               *Device  `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateDeviceResponse) Descriptor 

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

func (*CreateDeviceResponse) GetDevice 

func (m *CreateDeviceResponse) GetDevice() *Device

func (*CreateDeviceResponse) ProtoMessage 

func (*CreateDeviceResponse) ProtoMessage()

func (*CreateDeviceResponse) Reset 

func (m *CreateDeviceResponse) Reset()

func (*CreateDeviceResponse) String 

func (m *CreateDeviceResponse) String() string

func (*CreateDeviceResponse) Validate 

func (this *CreateDeviceResponse) Validate() error

func (*CreateDeviceResponse) XXX_DiscardUnknown 

func (m *CreateDeviceResponse) XXX_DiscardUnknown()

func (*CreateDeviceResponse) XXX_Marshal 

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

func (*CreateDeviceResponse) XXX_Merge 

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

func (*CreateDeviceResponse) XXX_Size 

func (m *CreateDeviceResponse) XXX_Size() int

func (*CreateDeviceResponse) XXX_Unmarshal 

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

type CreateFlowSetRequest added in v1.1.23 

type CreateFlowSetRequest struct {
	FlowSet              *OpFlowSet `protobuf:"bytes,1,opt,name=flow_set,json=flowSet,proto3" json:"flow_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*CreateFlowSetRequest) Descriptor added in v1.1.23 

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

func (*CreateFlowSetRequest) GetFlowSet added in v1.1.23 

func (m *CreateFlowSetRequest) GetFlowSet() *OpFlowSet

func (*CreateFlowSetRequest) ProtoMessage added in v1.1.23 

func (*CreateFlowSetRequest) ProtoMessage()

func (*CreateFlowSetRequest) Reset added in v1.1.23 

func (m *CreateFlowSetRequest) Reset()

func (*CreateFlowSetRequest) String added in v1.1.23 

func (m *CreateFlowSetRequest) String() string

func (*CreateFlowSetRequest) Validate added in v1.1.23 

func (this *CreateFlowSetRequest) Validate() error

func (*CreateFlowSetRequest) XXX_DiscardUnknown added in v1.1.23 

func (m *CreateFlowSetRequest) XXX_DiscardUnknown()

func (*CreateFlowSetRequest) XXX_Marshal added in v1.1.23 

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

func (*CreateFlowSetRequest) XXX_Merge added in v1.1.23 

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

func (*CreateFlowSetRequest) XXX_Size added in v1.1.23 

func (m *CreateFlowSetRequest) XXX_Size() int

func (*CreateFlowSetRequest) XXX_Unmarshal added in v1.1.23 

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

type CreateFlowSetResponse added in v1.1.23 

type CreateFlowSetResponse struct {
	FlowSet              *FlowSet `protobuf:"bytes,1,opt,name=flow_set,json=flowSet,proto3" json:"flow_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateFlowSetResponse) Descriptor added in v1.1.23 

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

func (*CreateFlowSetResponse) GetFlowSet added in v1.1.23 

func (m *CreateFlowSetResponse) GetFlowSet() *FlowSet

func (*CreateFlowSetResponse) ProtoMessage added in v1.1.23 

func (*CreateFlowSetResponse) ProtoMessage()

func (*CreateFlowSetResponse) Reset added in v1.1.23 

func (m *CreateFlowSetResponse) Reset()

func (*CreateFlowSetResponse) String added in v1.1.23 

func (m *CreateFlowSetResponse) String() string

func (*CreateFlowSetResponse) Validate added in v1.1.23 

func (this *CreateFlowSetResponse) Validate() error

func (*CreateFlowSetResponse) XXX_DiscardUnknown added in v1.1.23 

func (m *CreateFlowSetResponse) XXX_DiscardUnknown()

func (*CreateFlowSetResponse) XXX_Marshal added in v1.1.23 

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

func (*CreateFlowSetResponse) XXX_Merge added in v1.1.23 

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

func (*CreateFlowSetResponse) XXX_Size added in v1.1.23 

func (m *CreateFlowSetResponse) XXX_Size() int

func (*CreateFlowSetResponse) XXX_Unmarshal added in v1.1.23 

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

type DeleteConfigRequest added in v1.1.27 

type DeleteConfigRequest struct {
	Config               *OpConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DeleteConfigRequest) Descriptor added in v1.1.27 

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

func (*DeleteConfigRequest) GetConfig added in v1.1.27 

func (m *DeleteConfigRequest) GetConfig() *OpConfig

func (*DeleteConfigRequest) ProtoMessage added in v1.1.27 

func (*DeleteConfigRequest) ProtoMessage()

func (*DeleteConfigRequest) Reset added in v1.1.27 

func (m *DeleteConfigRequest) Reset()

func (*DeleteConfigRequest) String added in v1.1.27 

func (m *DeleteConfigRequest) String() string

func (*DeleteConfigRequest) Validate added in v1.1.27 

func (this *DeleteConfigRequest) Validate() error

func (*DeleteConfigRequest) XXX_DiscardUnknown added in v1.1.27 

func (m *DeleteConfigRequest) XXX_DiscardUnknown()

func (*DeleteConfigRequest) XXX_Marshal added in v1.1.27 

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

func (*DeleteConfigRequest) XXX_Merge added in v1.1.27 

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

func (*DeleteConfigRequest) XXX_Size added in v1.1.27 

func (m *DeleteConfigRequest) XXX_Size() int

func (*DeleteConfigRequest) XXX_Unmarshal added in v1.1.27 

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

type DeleteDeviceRequest 

type DeleteDeviceRequest struct {
	Device               *OpDevice `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DeleteDeviceRequest) Descriptor 

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

func (*DeleteDeviceRequest) GetDevice 

func (m *DeleteDeviceRequest) GetDevice() *OpDevice

func (*DeleteDeviceRequest) ProtoMessage 

func (*DeleteDeviceRequest) ProtoMessage()

func (*DeleteDeviceRequest) Reset 

func (m *DeleteDeviceRequest) Reset()

func (*DeleteDeviceRequest) String 

func (m *DeleteDeviceRequest) String() string

func (*DeleteDeviceRequest) Validate 

func (this *DeleteDeviceRequest) Validate() error

func (*DeleteDeviceRequest) XXX_DiscardUnknown 

func (m *DeleteDeviceRequest) XXX_DiscardUnknown()

func (*DeleteDeviceRequest) XXX_Marshal 

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

func (*DeleteDeviceRequest) XXX_Merge 

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

func (*DeleteDeviceRequest) XXX_Size 

func (m *DeleteDeviceRequest) XXX_Size() int

func (*DeleteDeviceRequest) XXX_Unmarshal 

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

type DeleteFlowSetRequest added in v1.1.23 

type DeleteFlowSetRequest struct {
	FlowSet              *OpFlowSet `protobuf:"bytes,1,opt,name=flow_set,json=flowSet,proto3" json:"flow_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*DeleteFlowSetRequest) Descriptor added in v1.1.23 

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

func (*DeleteFlowSetRequest) GetFlowSet added in v1.1.23 

func (m *DeleteFlowSetRequest) GetFlowSet() *OpFlowSet

func (*DeleteFlowSetRequest) ProtoMessage added in v1.1.23 

func (*DeleteFlowSetRequest) ProtoMessage()

func (*DeleteFlowSetRequest) Reset added in v1.1.23 

func (m *DeleteFlowSetRequest) Reset()

func (*DeleteFlowSetRequest) String added in v1.1.23 

func (m *DeleteFlowSetRequest) String() string

func (*DeleteFlowSetRequest) Validate added in v1.1.23 

func (this *DeleteFlowSetRequest) Validate() error

func (*DeleteFlowSetRequest) XXX_DiscardUnknown added in v1.1.23 

func (m *DeleteFlowSetRequest) XXX_DiscardUnknown()

func (*DeleteFlowSetRequest) XXX_Marshal added in v1.1.23 

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

func (*DeleteFlowSetRequest) XXX_Merge added in v1.1.23 

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

func (*DeleteFlowSetRequest) XXX_Size added in v1.1.23 

func (m *DeleteFlowSetRequest) XXX_Size() int

func (*DeleteFlowSetRequest) XXX_Unmarshal added in v1.1.23 

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

type Descriptor added in v1.1.27 

type Descriptor struct {
	Sha1                 string   `protobuf:"bytes,1,opt,name=sha1,proto3" json:"sha1,omitempty"`
	Body                 []byte   `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Descriptor) Descriptor added in v1.1.27 

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

func (*Descriptor) GetBody added in v1.1.27 

func (m *Descriptor) GetBody() []byte

func (*Descriptor) GetSha1 added in v1.1.27 

func (m *Descriptor) GetSha1() string

func (*Descriptor) ProtoMessage added in v1.1.27 

func (*Descriptor) ProtoMessage()

func (*Descriptor) Reset added in v1.1.27 

func (m *Descriptor) Reset()

func (*Descriptor) String added in v1.1.27 

func (m *Descriptor) String() string

func (*Descriptor) Validate added in v1.1.27 

func (this *Descriptor) Validate() error

func (*Descriptor) XXX_DiscardUnknown added in v1.1.27 

func (m *Descriptor) XXX_DiscardUnknown()

func (*Descriptor) XXX_Marshal added in v1.1.27 

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

func (*Descriptor) XXX_Merge added in v1.1.27 

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

func (*Descriptor) XXX_Size added in v1.1.27 

func (m *Descriptor) XXX_Size() int

func (*Descriptor) XXX_Unmarshal added in v1.1.27 

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

type Device 

type Device struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Kind                 kind.DeviceKind      `protobuf:"varint,2,opt,name=kind,proto3,enum=ai.metathings.constant.kind.DeviceKind" json:"kind,omitempty"`
	State                state.DeviceState    `protobuf:"varint,3,opt,name=state,proto3,enum=ai.metathings.constant.state.DeviceState" json:"state,omitempty"`
	Name                 string               `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Alias                string               `protobuf:"bytes,5,opt,name=alias,proto3" json:"alias,omitempty"`
	Extra                map[string]string    `` /* 152-byte string literal not displayed */
	Modules              []*Module            `protobuf:"bytes,6,rep,name=modules,proto3" json:"modules,omitempty"`
	HeartbeatAt          *timestamp.Timestamp `protobuf:"bytes,7,opt,name=heartbeat_at,json=heartbeatAt,proto3" json:"heartbeat_at,omitempty"`
	Flows                []*Flow              `protobuf:"bytes,8,rep,name=flows,proto3" json:"flows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Device) Descriptor 

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

func (*Device) GetAlias 

func (m *Device) GetAlias() string

func (*Device) GetExtra added in v1.1.23 

func (m *Device) GetExtra() map[string]string

func (*Device) GetFlows 

func (m *Device) GetFlows() []*Flow

func (*Device) GetHeartbeatAt 

func (m *Device) GetHeartbeatAt() *timestamp.Timestamp

func (*Device) GetId 

func (m *Device) GetId() string

func (*Device) GetKind 

func (m *Device) GetKind() kind.DeviceKind

func (*Device) GetModules 

func (m *Device) GetModules() []*Module

func (*Device) GetName 

func (m *Device) GetName() string

func (*Device) GetState 

func (m *Device) GetState() state.DeviceState

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) Reset 

func (m *Device) Reset()

func (*Device) String 

func (m *Device) String() string

func (*Device) Validate 

func (this *Device) Validate() error

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 DevicedServiceClient 

type DevicedServiceClient interface {
	CreateDevice(ctx context.Context, in *CreateDeviceRequest, opts ...grpc.CallOption) (*CreateDeviceResponse, error)
	DeleteDevice(ctx context.Context, in *DeleteDeviceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	PatchDevice(ctx context.Context, in *PatchDeviceRequest, opts ...grpc.CallOption) (*PatchDeviceResponse, error)
	GetDevice(ctx context.Context, in *GetDeviceRequest, opts ...grpc.CallOption) (*GetDeviceResponse, error)
	ListDevices(ctx context.Context, in *ListDevicesRequest, opts ...grpc.CallOption) (*ListDevicesResponse, error)
	GetDeviceByModule(ctx context.Context, in *GetDeviceByModuleRequest, opts ...grpc.CallOption) (*GetDeviceByModuleResponse, error)
	// Config
	CreateConfig(ctx context.Context, in *CreateConfigRequest, opts ...grpc.CallOption) (*CreateConfigResponse, error)
	DeleteConfig(ctx context.Context, in *DeleteConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	PatchConfig(ctx context.Context, in *PatchConfigRequest, opts ...grpc.CallOption) (*PatchConfigResponse, error)
	GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
	ListConfigs(ctx context.Context, in *ListConfigsRequest, opts ...grpc.CallOption) (*ListConfigsResponse, error)
	AddConfigsToDevice(ctx context.Context, in *AddConfigsToDeviceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	RemoveConfigsFromDevice(ctx context.Context, in *RemoveConfigsFromDeviceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ListConfigsByDevice(ctx context.Context, in *ListConfigsByDeviceRequest, opts ...grpc.CallOption) (*ListConfigsByDeviceResponse, error)
	// Descriptor
	UploadDescriptor(ctx context.Context, in *UploadDescriptorRequest, opts ...grpc.CallOption) (*UploadDescriptorResponse, error)
	GetDescriptor(ctx context.Context, in *GetDescriptorRequest, opts ...grpc.CallOption) (*GetDescriptorResponse, error)
	// Calling
	UnaryCall(ctx context.Context, in *UnaryCallRequest, opts ...grpc.CallOption) (*UnaryCallResponse, error)
	StreamCall(ctx context.Context, opts ...grpc.CallOption) (DevicedService_StreamCallClient, error)
	// Flow
	PullFrameFromFlow(ctx context.Context, in *PullFrameFromFlowRequest, opts ...grpc.CallOption) (DevicedService_PullFrameFromFlowClient, error)
	PushFrameToFlow(ctx context.Context, opts ...grpc.CallOption) (DevicedService_PushFrameToFlowClient, error)
	QueryFramesFromFlow(ctx context.Context, in *QueryFramesFromFlowRequest, opts ...grpc.CallOption) (*QueryFramesFromFlowResponse, error)
	// Flow Set
	CreateFlowSet(ctx context.Context, in *CreateFlowSetRequest, opts ...grpc.CallOption) (*CreateFlowSetResponse, error)
	DeleteFlowSet(ctx context.Context, in *DeleteFlowSetRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	PatchFlowSet(ctx context.Context, in *PatchFlowSetRequest, opts ...grpc.CallOption) (*PatchFlowSetResponse, error)
	GetFlowSet(ctx context.Context, in *GetFlowSetRequest, opts ...grpc.CallOption) (*GetFlowSetResponse, error)
	ListFlowSets(ctx context.Context, in *ListFlowSetsRequest, opts ...grpc.CallOption) (*ListFlowSetsResponse, error)
	AddFlowsToFlowSet(ctx context.Context, in *AddFlowsToFlowSetRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	RemoveFlowsFromFlowSet(ctx context.Context, in *RemoveFlowsFromFlowSetRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	PullFrameFromFlowSet(ctx context.Context, in *PullFrameFromFlowSetRequest, opts ...grpc.CallOption) (DevicedService_PullFrameFromFlowSetClient, error)
	// Simple Storage
	PutObject(ctx context.Context, in *PutObjectRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	PutObjectStreaming(ctx context.Context, opts ...grpc.CallOption) (DevicedService_PutObjectStreamingClient, error)
	RemoveObject(ctx context.Context, in *RemoveObjectRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	RenameObject(ctx context.Context, in *RenameObjectRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetObject(ctx context.Context, in *GetObjectRequest, opts ...grpc.CallOption) (*GetObjectResponse, error)
	GetObjectContent(ctx context.Context, in *GetObjectContentRequest, opts ...grpc.CallOption) (*GetObjectContentResponse, error)
	GetObjectStreamingContent(ctx context.Context, in *GetObjectStreamingContentRequest, opts ...grpc.CallOption) (DevicedService_GetObjectStreamingContentClient, error)
	ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (*ListObjectsResponse, error)
	// internal device only
	ShowDevice(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ShowDeviceResponse, error)
	Connect(ctx context.Context, opts ...grpc.CallOption) (DevicedService_ConnectClient, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

DevicedServiceClient is the client API for DevicedService service.

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

func NewDevicedServiceClient 

func NewDevicedServiceClient(cc *grpc.ClientConn) DevicedServiceClient

type DevicedServiceServer 

type DevicedServiceServer interface {
	CreateDevice(context.Context, *CreateDeviceRequest) (*CreateDeviceResponse, error)
	DeleteDevice(context.Context, *DeleteDeviceRequest) (*empty.Empty, error)
	PatchDevice(context.Context, *PatchDeviceRequest) (*PatchDeviceResponse, error)
	GetDevice(context.Context, *GetDeviceRequest) (*GetDeviceResponse, error)
	ListDevices(context.Context, *ListDevicesRequest) (*ListDevicesResponse, error)
	GetDeviceByModule(context.Context, *GetDeviceByModuleRequest) (*GetDeviceByModuleResponse, error)
	// Config
	CreateConfig(context.Context, *CreateConfigRequest) (*CreateConfigResponse, error)
	DeleteConfig(context.Context, *DeleteConfigRequest) (*empty.Empty, error)
	PatchConfig(context.Context, *PatchConfigRequest) (*PatchConfigResponse, error)
	GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
	ListConfigs(context.Context, *ListConfigsRequest) (*ListConfigsResponse, error)
	AddConfigsToDevice(context.Context, *AddConfigsToDeviceRequest) (*empty.Empty, error)
	RemoveConfigsFromDevice(context.Context, *RemoveConfigsFromDeviceRequest) (*empty.Empty, error)
	ListConfigsByDevice(context.Context, *ListConfigsByDeviceRequest) (*ListConfigsByDeviceResponse, error)
	// Descriptor
	UploadDescriptor(context.Context, *UploadDescriptorRequest) (*UploadDescriptorResponse, error)
	GetDescriptor(context.Context, *GetDescriptorRequest) (*GetDescriptorResponse, error)
	// Calling
	UnaryCall(context.Context, *UnaryCallRequest) (*UnaryCallResponse, error)
	StreamCall(DevicedService_StreamCallServer) error
	// Flow
	PullFrameFromFlow(*PullFrameFromFlowRequest, DevicedService_PullFrameFromFlowServer) error
	PushFrameToFlow(DevicedService_PushFrameToFlowServer) error
	QueryFramesFromFlow(context.Context, *QueryFramesFromFlowRequest) (*QueryFramesFromFlowResponse, error)
	// Flow Set
	CreateFlowSet(context.Context, *CreateFlowSetRequest) (*CreateFlowSetResponse, error)
	DeleteFlowSet(context.Context, *DeleteFlowSetRequest) (*empty.Empty, error)
	PatchFlowSet(context.Context, *PatchFlowSetRequest) (*PatchFlowSetResponse, error)
	GetFlowSet(context.Context, *GetFlowSetRequest) (*GetFlowSetResponse, error)
	ListFlowSets(context.Context, *ListFlowSetsRequest) (*ListFlowSetsResponse, error)
	AddFlowsToFlowSet(context.Context, *AddFlowsToFlowSetRequest) (*empty.Empty, error)
	RemoveFlowsFromFlowSet(context.Context, *RemoveFlowsFromFlowSetRequest) (*empty.Empty, error)
	PullFrameFromFlowSet(*PullFrameFromFlowSetRequest, DevicedService_PullFrameFromFlowSetServer) error
	// Simple Storage
	PutObject(context.Context, *PutObjectRequest) (*empty.Empty, error)
	PutObjectStreaming(DevicedService_PutObjectStreamingServer) error
	RemoveObject(context.Context, *RemoveObjectRequest) (*empty.Empty, error)
	RenameObject(context.Context, *RenameObjectRequest) (*empty.Empty, error)
	GetObject(context.Context, *GetObjectRequest) (*GetObjectResponse, error)
	GetObjectContent(context.Context, *GetObjectContentRequest) (*GetObjectContentResponse, error)
	GetObjectStreamingContent(*GetObjectStreamingContentRequest, DevicedService_GetObjectStreamingContentServer) error
	ListObjects(context.Context, *ListObjectsRequest) (*ListObjectsResponse, error)
	// internal device only
	ShowDevice(context.Context, *empty.Empty) (*ShowDeviceResponse, error)
	Connect(DevicedService_ConnectServer) error
	Heartbeat(context.Context, *HeartbeatRequest) (*empty.Empty, error)
}

DevicedServiceServer is the server API for DevicedService service.

type DevicedService_ConnectClient 

type DevicedService_ConnectClient interface {
	Send(*ConnectResponse) error
	Recv() (*ConnectRequest, error)
	grpc.ClientStream
}

type DevicedService_ConnectServer 

type DevicedService_ConnectServer interface {
	Send(*ConnectRequest) error
	Recv() (*ConnectResponse, error)
	grpc.ServerStream
}

type DevicedService_GetObjectStreamingContentClient 

type DevicedService_GetObjectStreamingContentClient interface {
	Recv() (*GetObjectStreamingContentResponse, error)
	grpc.ClientStream
}

type DevicedService_GetObjectStreamingContentServer 

type DevicedService_GetObjectStreamingContentServer interface {
	Send(*GetObjectStreamingContentResponse) error
	grpc.ServerStream
}

type DevicedService_PullFrameFromFlowClient 

type DevicedService_PullFrameFromFlowClient interface {
	Recv() (*PullFrameFromFlowResponse, error)
	grpc.ClientStream
}

type DevicedService_PullFrameFromFlowServer 

type DevicedService_PullFrameFromFlowServer interface {
	Send(*PullFrameFromFlowResponse) error
	grpc.ServerStream
}

type DevicedService_PullFrameFromFlowSetClient added in v1.1.23 

type DevicedService_PullFrameFromFlowSetClient interface {
	Recv() (*PullFrameFromFlowSetResponse, error)
	grpc.ClientStream
}

type DevicedService_PullFrameFromFlowSetServer added in v1.1.23 

type DevicedService_PullFrameFromFlowSetServer interface {
	Send(*PullFrameFromFlowSetResponse) error
	grpc.ServerStream
}

type DevicedService_PushFrameToFlowClient 

type DevicedService_PushFrameToFlowClient interface {
	Send(*PushFrameToFlowRequest) error
	Recv() (*PushFrameToFlowResponse, error)
	grpc.ClientStream
}

type DevicedService_PushFrameToFlowServer 

type DevicedService_PushFrameToFlowServer interface {
	Send(*PushFrameToFlowResponse) error
	Recv() (*PushFrameToFlowRequest, error)
	grpc.ServerStream
}

type DevicedService_PutObjectStreamingClient added in v1.1.16 

type DevicedService_PutObjectStreamingClient interface {
	Send(*PutObjectStreamingRequest) error
	Recv() (*PutObjectStreamingResponse, error)
	grpc.ClientStream
}

type DevicedService_PutObjectStreamingServer added in v1.1.16 

type DevicedService_PutObjectStreamingServer interface {
	Send(*PutObjectStreamingResponse) error
	Recv() (*PutObjectStreamingRequest, error)
	grpc.ServerStream
}

type DevicedService_StreamCallClient 

type DevicedService_StreamCallClient interface {
	Send(*StreamCallRequest) error
	Recv() (*StreamCallResponse, error)
	grpc.ClientStream
}

type DevicedService_StreamCallServer 

type DevicedService_StreamCallServer interface {
	Send(*StreamCallResponse) error
	Recv() (*StreamCallRequest, error)
	grpc.ServerStream
}

type ErrorValue 

type ErrorValue struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Component            string   `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	Method               string   `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Code                 uint32   `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"`
	Message              string   `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ErrorValue) Descriptor 

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

func (*ErrorValue) GetCode 

func (m *ErrorValue) GetCode() uint32

func (*ErrorValue) GetComponent 

func (m *ErrorValue) GetComponent() string

func (*ErrorValue) GetMessage 

func (m *ErrorValue) GetMessage() string

func (*ErrorValue) GetMethod 

func (m *ErrorValue) GetMethod() string

func (*ErrorValue) GetName 

func (m *ErrorValue) GetName() string

func (*ErrorValue) ProtoMessage 

func (*ErrorValue) ProtoMessage()

func (*ErrorValue) Reset 

func (m *ErrorValue) Reset()

func (*ErrorValue) String 

func (m *ErrorValue) String() string

func (*ErrorValue) Validate 

func (this *ErrorValue) Validate() error

func (*ErrorValue) XXX_DiscardUnknown 

func (m *ErrorValue) XXX_DiscardUnknown()

func (*ErrorValue) XXX_Marshal 

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

func (*ErrorValue) XXX_Merge 

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

func (*ErrorValue) XXX_Size 

func (m *ErrorValue) XXX_Size() int

func (*ErrorValue) XXX_Unmarshal 

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

type Flow 

type Flow struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DeviceId             string   `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Alias                string   `protobuf:"bytes,4,opt,name=alias,proto3" json:"alias,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Flow) Descriptor 

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

func (*Flow) GetAlias 

func (m *Flow) GetAlias() string

func (*Flow) GetDeviceId 

func (m *Flow) GetDeviceId() string

func (*Flow) GetId 

func (m *Flow) GetId() string

func (*Flow) GetName 

func (m *Flow) GetName() string

func (*Flow) ProtoMessage 

func (*Flow) ProtoMessage()

func (*Flow) Reset 

func (m *Flow) Reset()

func (*Flow) String 

func (m *Flow) String() string

func (*Flow) Validate 

func (this *Flow) Validate() error

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 FlowSet added in v1.1.23 

type FlowSet 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"`
	Alias                string   `protobuf:"bytes,3,opt,name=alias,proto3" json:"alias,omitempty"`
	Flows                []*Flow  `protobuf:"bytes,4,rep,name=flows,proto3" json:"flows,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FlowSet) Descriptor added in v1.1.23 

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

func (*FlowSet) GetAlias added in v1.1.23 

func (m *FlowSet) GetAlias() string

func (*FlowSet) GetFlows added in v1.1.23 

func (m *FlowSet) GetFlows() []*Flow

func (*FlowSet) GetId added in v1.1.23 

func (m *FlowSet) GetId() string

func (*FlowSet) GetName added in v1.1.23 

func (m *FlowSet) GetName() string

func (*FlowSet) ProtoMessage added in v1.1.23 

func (*FlowSet) ProtoMessage()

func (*FlowSet) Reset added in v1.1.23 

func (m *FlowSet) Reset()

func (*FlowSet) String added in v1.1.23 

func (m *FlowSet) String() string

func (*FlowSet) Validate added in v1.1.23 

func (this *FlowSet) Validate() error

func (*FlowSet) XXX_DiscardUnknown added in v1.1.23 

func (m *FlowSet) XXX_DiscardUnknown()

func (*FlowSet) XXX_Marshal added in v1.1.23 

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

func (*FlowSet) XXX_Merge added in v1.1.23 

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

func (*FlowSet) XXX_Size added in v1.1.23 

func (m *FlowSet) XXX_Size() int

func (*FlowSet) XXX_Unmarshal added in v1.1.23 

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

type Frame 

type Frame struct {
	Ts                   *timestamp.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Data                 *_struct.Struct      `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Frame) Descriptor 

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

func (*Frame) GetData 

func (m *Frame) GetData() *_struct.Struct

func (*Frame) GetTs 

func (m *Frame) GetTs() *timestamp.Timestamp

func (*Frame) ProtoMessage 

func (*Frame) ProtoMessage()

func (*Frame) Reset 

func (m *Frame) Reset()

func (*Frame) String 

func (m *Frame) String() string

func (*Frame) Validate 

func (this *Frame) Validate() error

func (*Frame) XXX_DiscardUnknown 

func (m *Frame) XXX_DiscardUnknown()

func (*Frame) XXX_Marshal 

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

func (*Frame) XXX_Merge 

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

func (*Frame) XXX_Size 

func (m *Frame) XXX_Size() int

func (*Frame) XXX_Unmarshal 

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

type GetConfigRequest added in v1.1.27 

type GetConfigRequest struct {
	Config               *OpConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetConfigRequest) Descriptor added in v1.1.27 

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

func (*GetConfigRequest) GetConfig added in v1.1.27 

func (m *GetConfigRequest) GetConfig() *OpConfig

func (*GetConfigRequest) ProtoMessage added in v1.1.27 

func (*GetConfigRequest) ProtoMessage()

func (*GetConfigRequest) Reset added in v1.1.27 

func (m *GetConfigRequest) Reset()

func (*GetConfigRequest) String added in v1.1.27 

func (m *GetConfigRequest) String() string

func (*GetConfigRequest) Validate added in v1.1.27 

func (this *GetConfigRequest) Validate() error

func (*GetConfigRequest) XXX_DiscardUnknown added in v1.1.27 

func (m *GetConfigRequest) XXX_DiscardUnknown()

func (*GetConfigRequest) XXX_Marshal added in v1.1.27 

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

func (*GetConfigRequest) XXX_Merge added in v1.1.27 

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

func (*GetConfigRequest) XXX_Size added in v1.1.27 

func (m *GetConfigRequest) XXX_Size() int

func (*GetConfigRequest) XXX_Unmarshal added in v1.1.27 

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

type GetConfigResponse added in v1.1.27 

type GetConfigResponse struct {
	Config               *Config  `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetConfigResponse) Descriptor added in v1.1.27 

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

func (*GetConfigResponse) GetConfig added in v1.1.27 

func (m *GetConfigResponse) GetConfig() *Config

func (*GetConfigResponse) ProtoMessage added in v1.1.27 

func (*GetConfigResponse) ProtoMessage()

func (*GetConfigResponse) Reset added in v1.1.27 

func (m *GetConfigResponse) Reset()

func (*GetConfigResponse) String added in v1.1.27 

func (m *GetConfigResponse) String() string

func (*GetConfigResponse) Validate added in v1.1.27 

func (this *GetConfigResponse) Validate() error

func (*GetConfigResponse) XXX_DiscardUnknown added in v1.1.27 

func (m *GetConfigResponse) XXX_DiscardUnknown()

func (*GetConfigResponse) XXX_Marshal added in v1.1.27 

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

func (*GetConfigResponse) XXX_Merge added in v1.1.27 

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

func (*GetConfigResponse) XXX_Size added in v1.1.27 

func (m *GetConfigResponse) XXX_Size() int

func (*GetConfigResponse) XXX_Unmarshal added in v1.1.27 

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

type GetDescriptorRequest added in v1.1.27 

type GetDescriptorRequest struct {
	Descriptor_          *OpDescriptor `protobuf:"bytes,1,opt,name=descriptor,proto3" json:"descriptor,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*GetDescriptorRequest) Descriptor added in v1.1.27 

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

func (*GetDescriptorRequest) GetDescriptor_ added in v1.1.27 

func (m *GetDescriptorRequest) GetDescriptor_() *OpDescriptor

func (*GetDescriptorRequest) ProtoMessage added in v1.1.27 

func (*GetDescriptorRequest) ProtoMessage()

func (*GetDescriptorRequest) Reset added in v1.1.27 

func (m *GetDescriptorRequest) Reset()

func (*GetDescriptorRequest) String added in v1.1.27 

func (m *GetDescriptorRequest) String() string

func (*GetDescriptorRequest) Validate added in v1.1.27 

func (this *GetDescriptorRequest) Validate() error

func (*GetDescriptorRequest) XXX_DiscardUnknown added in v1.1.27 

func (m *GetDescriptorRequest) XXX_DiscardUnknown()

func (*GetDescriptorRequest) XXX_Marshal added in v1.1.27 

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

func (*GetDescriptorRequest) XXX_Merge added in v1.1.27 

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

func (*GetDescriptorRequest) XXX_Size added in v1.1.27 

func (m *GetDescriptorRequest) XXX_Size() int

func (*GetDescriptorRequest) XXX_Unmarshal added in v1.1.27 

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

type GetDescriptorResponse added in v1.1.27 

type GetDescriptorResponse struct {
	Descriptor_          *Descriptor `protobuf:"bytes,1,opt,name=descriptor,proto3" json:"descriptor,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*GetDescriptorResponse) Descriptor added in v1.1.27 

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

func (*GetDescriptorResponse) GetDescriptor_ added in v1.1.27 

func (m *GetDescriptorResponse) GetDescriptor_() *Descriptor

func (*GetDescriptorResponse) ProtoMessage added in v1.1.27 

func (*GetDescriptorResponse) ProtoMessage()

func (*GetDescriptorResponse) Reset added in v1.1.27 

func (m *GetDescriptorResponse) Reset()

func (*GetDescriptorResponse) String added in v1.1.27 

func (m *GetDescriptorResponse) String() string

func (*GetDescriptorResponse) Validate added in v1.1.27 

func (this *GetDescriptorResponse) Validate() error

func (*GetDescriptorResponse) XXX_DiscardUnknown added in v1.1.27 

func (m *GetDescriptorResponse) XXX_DiscardUnknown()

func (*GetDescriptorResponse) XXX_Marshal added in v1.1.27 

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

func (*GetDescriptorResponse) XXX_Merge added in v1.1.27 

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

func (*GetDescriptorResponse) XXX_Size added in v1.1.27 

func (m *GetDescriptorResponse) XXX_Size() int

func (*GetDescriptorResponse) XXX_Unmarshal added in v1.1.27 

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

type GetDeviceByModuleRequest added in v0.100.0 

type GetDeviceByModuleRequest struct {
	Module               *OpModule `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetDeviceByModuleRequest) Descriptor added in v0.100.0 

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

func (*GetDeviceByModuleRequest) GetModule added in v0.100.0 

func (m *GetDeviceByModuleRequest) GetModule() *OpModule

func (*GetDeviceByModuleRequest) ProtoMessage added in v0.100.0 

func (*GetDeviceByModuleRequest) ProtoMessage()

func (*GetDeviceByModuleRequest) Reset added in v0.100.0 

func (m *GetDeviceByModuleRequest) Reset()

func (*GetDeviceByModuleRequest) String added in v0.100.0 

func (m *GetDeviceByModuleRequest) String() string

func (*GetDeviceByModuleRequest) Validate added in v0.100.0 

func (this *GetDeviceByModuleRequest) Validate() error

func (*GetDeviceByModuleRequest) XXX_DiscardUnknown added in v0.100.0 

func (m *GetDeviceByModuleRequest) XXX_DiscardUnknown()

func (*GetDeviceByModuleRequest) XXX_Marshal added in v0.100.0 

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

func (*GetDeviceByModuleRequest) XXX_Merge added in v0.100.0 

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

func (*GetDeviceByModuleRequest) XXX_Size added in v0.100.0 

func (m *GetDeviceByModuleRequest) XXX_Size() int

func (*GetDeviceByModuleRequest) XXX_Unmarshal added in v0.100.0 

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

type GetDeviceByModuleResponse added in v0.100.0 

type GetDeviceByModuleResponse struct {
	Device               *Device  `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDeviceByModuleResponse) Descriptor added in v0.100.0 

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

func (*GetDeviceByModuleResponse) GetDevice added in v0.100.0 

func (m *GetDeviceByModuleResponse) GetDevice() *Device

func (*GetDeviceByModuleResponse) ProtoMessage added in v0.100.0 

func (*GetDeviceByModuleResponse) ProtoMessage()

func (*GetDeviceByModuleResponse) Reset added in v0.100.0 

func (m *GetDeviceByModuleResponse) Reset()

func (*GetDeviceByModuleResponse) String added in v0.100.0 

func (m *GetDeviceByModuleResponse) String() string

func (*GetDeviceByModuleResponse) Validate added in v0.100.0 

func (this *GetDeviceByModuleResponse) Validate() error

func (*GetDeviceByModuleResponse) XXX_DiscardUnknown added in v0.100.0 

func (m *GetDeviceByModuleResponse) XXX_DiscardUnknown()

func (*GetDeviceByModuleResponse) XXX_Marshal added in v0.100.0 

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

func (*GetDeviceByModuleResponse) XXX_Merge added in v0.100.0 

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

func (*GetDeviceByModuleResponse) XXX_Size added in v0.100.0 

func (m *GetDeviceByModuleResponse) XXX_Size() int

func (*GetDeviceByModuleResponse) XXX_Unmarshal added in v0.100.0 

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

type GetDeviceRequest 

type GetDeviceRequest struct {
	Device               *OpDevice `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetDeviceRequest) Descriptor 

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

func (*GetDeviceRequest) GetDevice 

func (m *GetDeviceRequest) GetDevice() *OpDevice

func (*GetDeviceRequest) ProtoMessage 

func (*GetDeviceRequest) ProtoMessage()

func (*GetDeviceRequest) Reset 

func (m *GetDeviceRequest) Reset()

func (*GetDeviceRequest) String 

func (m *GetDeviceRequest) String() string

func (*GetDeviceRequest) Validate 

func (this *GetDeviceRequest) Validate() error

func (*GetDeviceRequest) XXX_DiscardUnknown 

func (m *GetDeviceRequest) XXX_DiscardUnknown()

func (*GetDeviceRequest) XXX_Marshal 

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

func (*GetDeviceRequest) XXX_Merge 

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

func (*GetDeviceRequest) XXX_Size 

func (m *GetDeviceRequest) XXX_Size() int

func (*GetDeviceRequest) XXX_Unmarshal 

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

type GetDeviceResponse 

type GetDeviceResponse struct {
	Device               *Device  `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDeviceResponse) Descriptor 

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

func (*GetDeviceResponse) GetDevice 

func (m *GetDeviceResponse) GetDevice() *Device

func (*GetDeviceResponse) ProtoMessage 

func (*GetDeviceResponse) ProtoMessage()

func (*GetDeviceResponse) Reset 

func (m *GetDeviceResponse) Reset()

func (*GetDeviceResponse) String 

func (m *GetDeviceResponse) String() string

func (*GetDeviceResponse) Validate 

func (this *GetDeviceResponse) Validate() error

func (*GetDeviceResponse) XXX_DiscardUnknown 

func (m *GetDeviceResponse) XXX_DiscardUnknown()

func (*GetDeviceResponse) XXX_Marshal 

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

func (*GetDeviceResponse) XXX_Merge 

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

func (*GetDeviceResponse) XXX_Size 

func (m *GetDeviceResponse) XXX_Size() int

func (*GetDeviceResponse) XXX_Unmarshal 

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

type GetFlowSetRequest added in v1.1.23 

type GetFlowSetRequest struct {
	FlowSet              *OpFlowSet `protobuf:"bytes,1,opt,name=flow_set,json=flowSet,proto3" json:"flow_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetFlowSetRequest) Descriptor added in v1.1.23 

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

func (*GetFlowSetRequest) GetFlowSet added in v1.1.23 

func (m *GetFlowSetRequest) GetFlowSet() *OpFlowSet

func (*GetFlowSetRequest) ProtoMessage added in v1.1.23 

func (*GetFlowSetRequest) ProtoMessage()

func (*GetFlowSetRequest) Reset added in v1.1.23 

func (m *GetFlowSetRequest) Reset()

func (*GetFlowSetRequest) String added in v1.1.23 

func (m *GetFlowSetRequest) String() string

func (*GetFlowSetRequest) Validate added in v1.1.23 

func (this *GetFlowSetRequest) Validate() error

func (*GetFlowSetRequest) XXX_DiscardUnknown added in v1.1.23 

func (m *GetFlowSetRequest) XXX_DiscardUnknown()

func (*GetFlowSetRequest) XXX_Marshal added in v1.1.23 

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

func (*GetFlowSetRequest) XXX_Merge added in v1.1.23 

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

func (*GetFlowSetRequest) XXX_Size added in v1.1.23 

func (m *GetFlowSetRequest) XXX_Size() int

func (*GetFlowSetRequest) XXX_Unmarshal added in v1.1.23 

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

type GetFlowSetResponse added in v1.1.23 

type GetFlowSetResponse struct {
	FlowSet              *FlowSet `protobuf:"bytes,1,opt,name=flow_set,json=flowSet,proto3" json:"flow_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetFlowSetResponse) Descriptor added in v1.1.23 

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

func (*GetFlowSetResponse) GetFlowSet added in v1.1.23 

func (m *GetFlowSetResponse) GetFlowSet() *FlowSet

func (*GetFlowSetResponse) ProtoMessage added in v1.1.23 

func (*GetFlowSetResponse) ProtoMessage()

func (*GetFlowSetResponse) Reset added in v1.1.23 

func (m *GetFlowSetResponse) Reset()

func (*GetFlowSetResponse) String added in v1.1.23 

func (m *GetFlowSetResponse) String() string

func (*GetFlowSetResponse) Validate added in v1.1.23 

func (this *GetFlowSetResponse) Validate() error

func (*GetFlowSetResponse) XXX_DiscardUnknown added in v1.1.23 

func (m *GetFlowSetResponse) XXX_DiscardUnknown()

func (*GetFlowSetResponse) XXX_Marshal added in v1.1.23 

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

func (*GetFlowSetResponse) XXX_Merge added in v1.1.23 

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

func (*GetFlowSetResponse) XXX_Size added in v1.1.23 

func (m *GetFlowSetResponse) XXX_Size() int

func (*GetFlowSetResponse) XXX_Unmarshal added in v1.1.23 

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

type GetObjectContentRequest 

type GetObjectContentRequest struct {
	Object               *OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetObjectContentRequest) Descriptor 

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

func (*GetObjectContentRequest) GetObject 

func (m *GetObjectContentRequest) GetObject() *OpObject

func (*GetObjectContentRequest) ProtoMessage 

func (*GetObjectContentRequest) ProtoMessage()

func (*GetObjectContentRequest) Reset 

func (m *GetObjectContentRequest) Reset()

func (*GetObjectContentRequest) String 

func (m *GetObjectContentRequest) String() string

func (*GetObjectContentRequest) Validate 

func (this *GetObjectContentRequest) Validate() error

func (*GetObjectContentRequest) XXX_DiscardUnknown 

func (m *GetObjectContentRequest) XXX_DiscardUnknown()

func (*GetObjectContentRequest) XXX_Marshal 

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

func (*GetObjectContentRequest) XXX_Merge 

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

func (*GetObjectContentRequest) XXX_Size 

func (m *GetObjectContentRequest) XXX_Size() int

func (*GetObjectContentRequest) XXX_Unmarshal 

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

type GetObjectContentResponse 

type GetObjectContentResponse struct {
	Content              []byte   `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetObjectContentResponse) Descriptor 

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

func (*GetObjectContentResponse) GetContent 

func (m *GetObjectContentResponse) GetContent() []byte

func (*GetObjectContentResponse) ProtoMessage 

func (*GetObjectContentResponse) ProtoMessage()

func (*GetObjectContentResponse) Reset 

func (m *GetObjectContentResponse) Reset()

func (*GetObjectContentResponse) String 

func (m *GetObjectContentResponse) String() string

func (*GetObjectContentResponse) Validate 

func (this *GetObjectContentResponse) Validate() error

func (*GetObjectContentResponse) XXX_DiscardUnknown 

func (m *GetObjectContentResponse) XXX_DiscardUnknown()

func (*GetObjectContentResponse) XXX_Marshal 

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

func (*GetObjectContentResponse) XXX_Merge 

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

func (*GetObjectContentResponse) XXX_Size 

func (m *GetObjectContentResponse) XXX_Size() int

func (*GetObjectContentResponse) XXX_Unmarshal 

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

type GetObjectRequest 

type GetObjectRequest struct {
	Object               *OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetObjectRequest) Descriptor 

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

func (*GetObjectRequest) GetObject 

func (m *GetObjectRequest) GetObject() *OpObject

func (*GetObjectRequest) ProtoMessage 

func (*GetObjectRequest) ProtoMessage()

func (*GetObjectRequest) Reset 

func (m *GetObjectRequest) Reset()

func (*GetObjectRequest) String 

func (m *GetObjectRequest) String() string

func (*GetObjectRequest) Validate 

func (this *GetObjectRequest) Validate() error

func (*GetObjectRequest) XXX_DiscardUnknown 

func (m *GetObjectRequest) XXX_DiscardUnknown()

func (*GetObjectRequest) XXX_Marshal 

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

func (*GetObjectRequest) XXX_Merge 

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

func (*GetObjectRequest) XXX_Size 

func (m *GetObjectRequest) XXX_Size() int

func (*GetObjectRequest) XXX_Unmarshal 

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

type GetObjectResponse 

type GetObjectResponse struct {
	Object               *Object  `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetObjectResponse) Descriptor 

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

func (*GetObjectResponse) GetObject 

func (m *GetObjectResponse) GetObject() *Object

func (*GetObjectResponse) ProtoMessage 

func (*GetObjectResponse) ProtoMessage()

func (*GetObjectResponse) Reset 

func (m *GetObjectResponse) Reset()

func (*GetObjectResponse) String 

func (m *GetObjectResponse) String() string

func (*GetObjectResponse) Validate 

func (this *GetObjectResponse) Validate() error

func (*GetObjectResponse) XXX_DiscardUnknown 

func (m *GetObjectResponse) XXX_DiscardUnknown()

func (*GetObjectResponse) XXX_Marshal 

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

func (*GetObjectResponse) XXX_Merge 

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

func (*GetObjectResponse) XXX_Size 

func (m *GetObjectResponse) XXX_Size() int

func (*GetObjectResponse) XXX_Unmarshal 

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

type GetObjectStreamingContentRequest 

type GetObjectStreamingContentRequest struct {
	Object               *OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetObjectStreamingContentRequest) Descriptor 

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

func (*GetObjectStreamingContentRequest) GetObject 

func (m *GetObjectStreamingContentRequest) GetObject() *OpObject

func (*GetObjectStreamingContentRequest) ProtoMessage 

func (*GetObjectStreamingContentRequest) ProtoMessage()

func (*GetObjectStreamingContentRequest) Reset 

func (m *GetObjectStreamingContentRequest) Reset()

func (*GetObjectStreamingContentRequest) String 

func (m *GetObjectStreamingContentRequest) String() string

func (*GetObjectStreamingContentRequest) Validate 

func (this *GetObjectStreamingContentRequest) Validate() error

func (*GetObjectStreamingContentRequest) XXX_DiscardUnknown 

func (m *GetObjectStreamingContentRequest) XXX_DiscardUnknown()

func (*GetObjectStreamingContentRequest) XXX_Marshal 

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

func (*GetObjectStreamingContentRequest) XXX_Merge 

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

func (*GetObjectStreamingContentRequest) XXX_Size 

func (m *GetObjectStreamingContentRequest) XXX_Size() int

func (*GetObjectStreamingContentRequest) XXX_Unmarshal 

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

type GetObjectStreamingContentResponse 

type GetObjectStreamingContentResponse struct {
	Content              []byte   `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetObjectStreamingContentResponse) Descriptor 

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

func (*GetObjectStreamingContentResponse) GetContent 

func (m *GetObjectStreamingContentResponse) GetContent() []byte

func (*GetObjectStreamingContentResponse) ProtoMessage 

func (*GetObjectStreamingContentResponse) ProtoMessage()

func (*GetObjectStreamingContentResponse) Reset 

func (m *GetObjectStreamingContentResponse) Reset()

func (*GetObjectStreamingContentResponse) String 

func (m *GetObjectStreamingContentResponse) String() string

func (*GetObjectStreamingContentResponse) Validate 

func (this *GetObjectStreamingContentResponse) Validate() error

func (*GetObjectStreamingContentResponse) XXX_DiscardUnknown 

func (m *GetObjectStreamingContentResponse) XXX_DiscardUnknown()

func (*GetObjectStreamingContentResponse) XXX_Marshal 

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

func (*GetObjectStreamingContentResponse) XXX_Merge 

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

func (*GetObjectStreamingContentResponse) XXX_Size 

func (m *GetObjectStreamingContentResponse) XXX_Size() int

func (*GetObjectStreamingContentResponse) XXX_Unmarshal 

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

type HeartbeatRequest 

type HeartbeatRequest struct {
	Device               *OpDevice            `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	StartupSession       *wrappers.Int32Value `protobuf:"bytes,2,opt,name=startup_session,json=startupSession,proto3" json:"startup_session,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*HeartbeatRequest) Descriptor 

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

func (*HeartbeatRequest) GetDevice 

func (m *HeartbeatRequest) GetDevice() *OpDevice

func (*HeartbeatRequest) GetStartupSession 

func (m *HeartbeatRequest) GetStartupSession() *wrappers.Int32Value

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) Reset 

func (m *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (m *HeartbeatRequest) String() string

func (*HeartbeatRequest) Validate 

func (this *HeartbeatRequest) Validate() error

func (*HeartbeatRequest) XXX_DiscardUnknown 

func (m *HeartbeatRequest) XXX_DiscardUnknown()

func (*HeartbeatRequest) XXX_Marshal 

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

func (*HeartbeatRequest) XXX_Merge 

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

func (*HeartbeatRequest) XXX_Size 

func (m *HeartbeatRequest) XXX_Size() int

func (*HeartbeatRequest) XXX_Unmarshal 

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

type ListConfigsByDeviceRequest added in v1.1.27 

type ListConfigsByDeviceRequest struct {
	Device               *OpDevice `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListConfigsByDeviceRequest) Descriptor added in v1.1.27 

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

func (*ListConfigsByDeviceRequest) GetDevice added in v1.1.27 

func (m *ListConfigsByDeviceRequest) GetDevice() *OpDevice

func (*ListConfigsByDeviceRequest) ProtoMessage added in v1.1.27 

func (*ListConfigsByDeviceRequest) ProtoMessage()

func (*ListConfigsByDeviceRequest) Reset added in v1.1.27 

func (m *ListConfigsByDeviceRequest) Reset()

func (*ListConfigsByDeviceRequest) String added in v1.1.27 

func (m *ListConfigsByDeviceRequest) String() string

func (*ListConfigsByDeviceRequest) Validate added in v1.1.27 

func (this *ListConfigsByDeviceRequest) Validate() error

func (*ListConfigsByDeviceRequest) XXX_DiscardUnknown added in v1.1.27 

func (m *ListConfigsByDeviceRequest) XXX_DiscardUnknown()

func (*ListConfigsByDeviceRequest) XXX_Marshal added in v1.1.27 

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

func (*ListConfigsByDeviceRequest) XXX_Merge added in v1.1.27 

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

func (*ListConfigsByDeviceRequest) XXX_Size added in v1.1.27 

func (m *ListConfigsByDeviceRequest) XXX_Size() int

func (*ListConfigsByDeviceRequest) XXX_Unmarshal added in v1.1.27 

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

type ListConfigsByDeviceResponse added in v1.1.27 

type ListConfigsByDeviceResponse struct {
	Configs              []*Config `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListConfigsByDeviceResponse) Descriptor added in v1.1.27 

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

func (*ListConfigsByDeviceResponse) GetConfigs added in v1.1.27 

func (m *ListConfigsByDeviceResponse) GetConfigs() []*Config

func (*ListConfigsByDeviceResponse) ProtoMessage added in v1.1.27 

func (*ListConfigsByDeviceResponse) ProtoMessage()

func (*ListConfigsByDeviceResponse) Reset added in v1.1.27 

func (m *ListConfigsByDeviceResponse) Reset()

func (*ListConfigsByDeviceResponse) String added in v1.1.27 

func (m *ListConfigsByDeviceResponse) String() string

func (*ListConfigsByDeviceResponse) Validate added in v1.1.27 

func (this *ListConfigsByDeviceResponse) Validate() error

func (*ListConfigsByDeviceResponse) XXX_DiscardUnknown added in v1.1.27 

func (m *ListConfigsByDeviceResponse) XXX_DiscardUnknown()

func (*ListConfigsByDeviceResponse) XXX_Marshal added in v1.1.27 

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

func (*ListConfigsByDeviceResponse) XXX_Merge added in v1.1.27 

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

func (*ListConfigsByDeviceResponse) XXX_Size added in v1.1.27 

func (m *ListConfigsByDeviceResponse) XXX_Size() int

func (*ListConfigsByDeviceResponse) XXX_Unmarshal added in v1.1.27 

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

type ListConfigsRequest added in v1.1.27 

type ListConfigsRequest struct {
	Config               *OpConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListConfigsRequest) Descriptor added in v1.1.27 

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

func (*ListConfigsRequest) GetConfig added in v1.1.27 

func (m *ListConfigsRequest) GetConfig() *OpConfig

func (*ListConfigsRequest) ProtoMessage added in v1.1.27 

func (*ListConfigsRequest) ProtoMessage()

func (*ListConfigsRequest) Reset added in v1.1.27 

func (m *ListConfigsRequest) Reset()

func (*ListConfigsRequest) String added in v1.1.27 

func (m *ListConfigsRequest) String() string

func (*ListConfigsRequest) Validate added in v1.1.27 

func (this *ListConfigsRequest) Validate() error

func (*ListConfigsRequest) XXX_DiscardUnknown added in v1.1.27 

func (m *ListConfigsRequest) XXX_DiscardUnknown()

func (*ListConfigsRequest) XXX_Marshal added in v1.1.27 

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

func (*ListConfigsRequest) XXX_Merge added in v1.1.27 

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

func (*ListConfigsRequest) XXX_Size added in v1.1.27 

func (m *ListConfigsRequest) XXX_Size() int

func (*ListConfigsRequest) XXX_Unmarshal added in v1.1.27 

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

type ListConfigsResponse added in v1.1.27 

type ListConfigsResponse struct {
	Configs              []*Config `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListConfigsResponse) Descriptor added in v1.1.27 

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

func (*ListConfigsResponse) GetConfigs added in v1.1.27 

func (m *ListConfigsResponse) GetConfigs() []*Config

func (*ListConfigsResponse) ProtoMessage added in v1.1.27 

func (*ListConfigsResponse) ProtoMessage()

func (*ListConfigsResponse) Reset added in v1.1.27 

func (m *ListConfigsResponse) Reset()

func (*ListConfigsResponse) String added in v1.1.27 

func (m *ListConfigsResponse) String() string

func (*ListConfigsResponse) Validate added in v1.1.27 

func (this *ListConfigsResponse) Validate() error

func (*ListConfigsResponse) XXX_DiscardUnknown added in v1.1.27 

func (m *ListConfigsResponse) XXX_DiscardUnknown()

func (*ListConfigsResponse) XXX_Marshal added in v1.1.27 

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

func (*ListConfigsResponse) XXX_Merge added in v1.1.27 

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

func (*ListConfigsResponse) XXX_Size added in v1.1.27 

func (m *ListConfigsResponse) XXX_Size() int

func (*ListConfigsResponse) XXX_Unmarshal added in v1.1.27 

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

type ListDevicesRequest 

type ListDevicesRequest struct {
	Device               *OpDevice `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListDevicesRequest) Descriptor 

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

func (*ListDevicesRequest) GetDevice 

func (m *ListDevicesRequest) GetDevice() *OpDevice

func (*ListDevicesRequest) ProtoMessage 

func (*ListDevicesRequest) ProtoMessage()

func (*ListDevicesRequest) Reset 

func (m *ListDevicesRequest) Reset()

func (*ListDevicesRequest) String 

func (m *ListDevicesRequest) String() string

func (*ListDevicesRequest) Validate 

func (this *ListDevicesRequest) Validate() error

func (*ListDevicesRequest) XXX_DiscardUnknown 

func (m *ListDevicesRequest) XXX_DiscardUnknown()

func (*ListDevicesRequest) XXX_Marshal 

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

func (*ListDevicesRequest) XXX_Merge 

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

func (*ListDevicesRequest) XXX_Size 

func (m *ListDevicesRequest) XXX_Size() int

func (*ListDevicesRequest) XXX_Unmarshal 

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

type ListDevicesResponse 

type ListDevicesResponse 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 (*ListDevicesResponse) Descriptor 

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

func (*ListDevicesResponse) GetDevices 

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

func (*ListDevicesResponse) ProtoMessage 

func (*ListDevicesResponse) ProtoMessage()

func (*ListDevicesResponse) Reset 

func (m *ListDevicesResponse) Reset()

func (*ListDevicesResponse) String 

func (m *ListDevicesResponse) String() string

func (*ListDevicesResponse) Validate 

func (this *ListDevicesResponse) Validate() error

func (*ListDevicesResponse) XXX_DiscardUnknown 

func (m *ListDevicesResponse) XXX_DiscardUnknown()

func (*ListDevicesResponse) XXX_Marshal 

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

func (*ListDevicesResponse) XXX_Merge 

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

func (*ListDevicesResponse) XXX_Size 

func (m *ListDevicesResponse) XXX_Size() int

func (*ListDevicesResponse) XXX_Unmarshal 

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

type ListFlowSetsRequest added in v1.1.23 

type ListFlowSetsRequest struct {
	FlowSet              *OpFlowSet `protobuf:"bytes,1,opt,name=flow_set,json=flowSet,proto3" json:"flow_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ListFlowSetsRequest) Descriptor added in v1.1.23 

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

func (*ListFlowSetsRequest) GetFlowSet added in v1.1.23 

func (m *ListFlowSetsRequest) GetFlowSet() *OpFlowSet

func (*ListFlowSetsRequest) ProtoMessage added in v1.1.23 

func (*ListFlowSetsRequest) ProtoMessage()

func (*ListFlowSetsRequest) Reset added in v1.1.23 

func (m *ListFlowSetsRequest) Reset()

func (*ListFlowSetsRequest) String added in v1.1.23 

func (m *ListFlowSetsRequest) String() string

func (*ListFlowSetsRequest) Validate added in v1.1.23 

func (this *ListFlowSetsRequest) Validate() error

func (*ListFlowSetsRequest) XXX_DiscardUnknown added in v1.1.23 

func (m *ListFlowSetsRequest) XXX_DiscardUnknown()

func (*ListFlowSetsRequest) XXX_Marshal added in v1.1.23 

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

func (*ListFlowSetsRequest) XXX_Merge added in v1.1.23 

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

func (*ListFlowSetsRequest) XXX_Size added in v1.1.23 

func (m *ListFlowSetsRequest) XXX_Size() int

func (*ListFlowSetsRequest) XXX_Unmarshal added in v1.1.23 

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

type ListFlowSetsResponse added in v1.1.23 

type ListFlowSetsResponse struct {
	FlowSets             []*FlowSet `protobuf:"bytes,1,rep,name=flow_sets,json=flowSets,proto3" json:"flow_sets,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ListFlowSetsResponse) Descriptor added in v1.1.23 

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

func (*ListFlowSetsResponse) GetFlowSets added in v1.1.23 

func (m *ListFlowSetsResponse) GetFlowSets() []*FlowSet

func (*ListFlowSetsResponse) ProtoMessage added in v1.1.23 

func (*ListFlowSetsResponse) ProtoMessage()

func (*ListFlowSetsResponse) Reset added in v1.1.23 

func (m *ListFlowSetsResponse) Reset()

func (*ListFlowSetsResponse) String added in v1.1.23 

func (m *ListFlowSetsResponse) String() string

func (*ListFlowSetsResponse) Validate added in v1.1.23 

func (this *ListFlowSetsResponse) Validate() error

func (*ListFlowSetsResponse) XXX_DiscardUnknown added in v1.1.23 

func (m *ListFlowSetsResponse) XXX_DiscardUnknown()

func (*ListFlowSetsResponse) XXX_Marshal added in v1.1.23 

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

func (*ListFlowSetsResponse) XXX_Merge added in v1.1.23 

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

func (*ListFlowSetsResponse) XXX_Size added in v1.1.23 

func (m *ListFlowSetsResponse) XXX_Size() int

func (*ListFlowSetsResponse) XXX_Unmarshal added in v1.1.23 

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

type ListObjectsRequest 

type ListObjectsRequest struct {
	Object               *OpObject            `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Recursive            *wrappers.BoolValue  `protobuf:"bytes,2,opt,name=recursive,proto3" json:"recursive,omitempty"`
	Depth                *wrappers.Int32Value `protobuf:"bytes,3,opt,name=depth,proto3" json:"depth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ListObjectsRequest) Descriptor 

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

func (*ListObjectsRequest) GetDepth added in v1.1.16 

func (m *ListObjectsRequest) GetDepth() *wrappers.Int32Value

func (*ListObjectsRequest) GetObject 

func (m *ListObjectsRequest) GetObject() *OpObject

func (*ListObjectsRequest) GetRecursive added in v1.1.16 

func (m *ListObjectsRequest) GetRecursive() *wrappers.BoolValue

func (*ListObjectsRequest) ProtoMessage 

func (*ListObjectsRequest) ProtoMessage()

func (*ListObjectsRequest) Reset 

func (m *ListObjectsRequest) Reset()

func (*ListObjectsRequest) String 

func (m *ListObjectsRequest) String() string

func (*ListObjectsRequest) Validate 

func (this *ListObjectsRequest) Validate() error

func (*ListObjectsRequest) XXX_DiscardUnknown 

func (m *ListObjectsRequest) XXX_DiscardUnknown()

func (*ListObjectsRequest) XXX_Marshal 

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

func (*ListObjectsRequest) XXX_Merge 

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

func (*ListObjectsRequest) XXX_Size 

func (m *ListObjectsRequest) XXX_Size() int

func (*ListObjectsRequest) XXX_Unmarshal 

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

type ListObjectsResponse 

type ListObjectsResponse struct {
	Objects              []*Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListObjectsResponse) Descriptor 

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

func (*ListObjectsResponse) GetObjects 

func (m *ListObjectsResponse) GetObjects() []*Object

func (*ListObjectsResponse) ProtoMessage 

func (*ListObjectsResponse) ProtoMessage()

func (*ListObjectsResponse) Reset 

func (m *ListObjectsResponse) Reset()

func (*ListObjectsResponse) String 

func (m *ListObjectsResponse) String() string

func (*ListObjectsResponse) Validate 

func (this *ListObjectsResponse) Validate() error

func (*ListObjectsResponse) XXX_DiscardUnknown 

func (m *ListObjectsResponse) XXX_DiscardUnknown()

func (*ListObjectsResponse) XXX_Marshal 

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

func (*ListObjectsResponse) XXX_Merge 

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

func (*ListObjectsResponse) XXX_Size 

func (m *ListObjectsResponse) XXX_Size() int

func (*ListObjectsResponse) XXX_Unmarshal 

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

type Module 

type Module struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State                state.ModuleState    `protobuf:"varint,2,opt,name=state,proto3,enum=ai.metathings.constant.state.ModuleState" json:"state,omitempty"`
	DeviceId             string               `protobuf:"bytes,3,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Endpoint             string               `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Component            string               `protobuf:"bytes,5,opt,name=component,proto3" json:"component,omitempty"`
	Name                 string               `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	Alias                string               `protobuf:"bytes,7,opt,name=alias,proto3" json:"alias,omitempty"`
	HeartbeatAt          *timestamp.Timestamp `protobuf:"bytes,8,opt,name=heartbeat_at,json=heartbeatAt,proto3" json:"heartbeat_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Module) Descriptor 

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

func (*Module) GetAlias 

func (m *Module) GetAlias() string

func (*Module) GetComponent 

func (m *Module) GetComponent() string

func (*Module) GetDeviceId 

func (m *Module) GetDeviceId() string

func (*Module) GetEndpoint 

func (m *Module) GetEndpoint() string

func (*Module) GetHeartbeatAt 

func (m *Module) GetHeartbeatAt() *timestamp.Timestamp

func (*Module) GetId 

func (m *Module) GetId() string

func (*Module) GetName 

func (m *Module) GetName() string

func (*Module) GetState 

func (m *Module) GetState() state.ModuleState

func (*Module) ProtoMessage 

func (*Module) ProtoMessage()

func (*Module) Reset 

func (m *Module) Reset()

func (*Module) String 

func (m *Module) String() string

func (*Module) Validate 

func (this *Module) Validate() error

func (*Module) XXX_DiscardUnknown 

func (m *Module) XXX_DiscardUnknown()

func (*Module) XXX_Marshal 

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

func (*Module) XXX_Merge 

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

func (*Module) XXX_Size 

func (m *Module) XXX_Size() int

func (*Module) XXX_Unmarshal 

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

type Object 

type Object struct {
	Device               *Device              `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Prefix               string               `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Name                 string               `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Length               int64                `protobuf:"varint,4,opt,name=length,proto3" json:"length,omitempty"`
	Etag                 string               `protobuf:"bytes,5,opt,name=etag,proto3" json:"etag,omitempty"`
	LastModified         *timestamp.Timestamp `protobuf:"bytes,6,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Object) Descriptor 

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

func (*Object) GetDevice 

func (m *Object) GetDevice() *Device

func (*Object) GetEtag 

func (m *Object) GetEtag() string

func (*Object) GetLastModified 

func (m *Object) GetLastModified() *timestamp.Timestamp

func (*Object) GetLength 

func (m *Object) GetLength() int64

func (*Object) GetName 

func (m *Object) GetName() string

func (*Object) GetPrefix 

func (m *Object) GetPrefix() string

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) Reset 

func (m *Object) Reset()

func (*Object) String 

func (m *Object) String() string

func (*Object) Validate 

func (this *Object) Validate() error

func (*Object) XXX_DiscardUnknown 

func (m *Object) XXX_DiscardUnknown()

func (*Object) XXX_Marshal 

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

func (*Object) XXX_Merge 

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

func (*Object) XXX_Size 

func (m *Object) XXX_Size() int

func (*Object) XXX_Unmarshal 

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

type ObjectChunk added in v1.1.16 

type ObjectChunk struct {
	Offset               int64    `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Length               int64    `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ObjectChunk) Descriptor added in v1.1.16 

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

func (*ObjectChunk) GetData added in v1.1.16 

func (m *ObjectChunk) GetData() []byte

func (*ObjectChunk) GetLength added in v1.1.16 

func (m *ObjectChunk) GetLength() int64

func (*ObjectChunk) GetOffset added in v1.1.16 

func (m *ObjectChunk) GetOffset() int64

func (*ObjectChunk) ProtoMessage added in v1.1.16 

func (*ObjectChunk) ProtoMessage()

func (*ObjectChunk) Reset added in v1.1.16 

func (m *ObjectChunk) Reset()

func (*ObjectChunk) String added in v1.1.16 

func (m *ObjectChunk) String() string

func (*ObjectChunk) Validate added in v1.1.16 

func (this *ObjectChunk) Validate() error

func (*ObjectChunk) XXX_DiscardUnknown added in v1.1.16 

func (m *ObjectChunk) XXX_DiscardUnknown()

func (*ObjectChunk) XXX_Marshal added in v1.1.16 

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

func (*ObjectChunk) XXX_Merge added in v1.1.16 

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

func (*ObjectChunk) XXX_Size added in v1.1.16 

func (m *ObjectChunk) XXX_Size() int

func (*ObjectChunk) XXX_Unmarshal added in v1.1.16 

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

type ObjectChunks added in v1.1.16 

type ObjectChunks struct {
	Chunks               []*ObjectChunk `protobuf:"bytes,1,rep,name=chunks,proto3" json:"chunks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ObjectChunks) Descriptor added in v1.1.16 

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

func (*ObjectChunks) GetChunks added in v1.1.16 

func (m *ObjectChunks) GetChunks() []*ObjectChunk

func (*ObjectChunks) ProtoMessage added in v1.1.16 

func (*ObjectChunks) ProtoMessage()

func (*ObjectChunks) Reset added in v1.1.16 

func (m *ObjectChunks) Reset()

func (*ObjectChunks) String added in v1.1.16 

func (m *ObjectChunks) String() string

func (*ObjectChunks) Validate added in v1.1.16 

func (this *ObjectChunks) Validate() error

func (*ObjectChunks) XXX_DiscardUnknown added in v1.1.16 

func (m *ObjectChunks) XXX_DiscardUnknown()

func (*ObjectChunks) XXX_Marshal added in v1.1.16 

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

func (*ObjectChunks) XXX_Merge added in v1.1.16 

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

func (*ObjectChunks) XXX_Size added in v1.1.16 

func (m *ObjectChunks) XXX_Size() int

func (*ObjectChunks) XXX_Unmarshal added in v1.1.16 

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

type OpConfig added in v1.1.27 

type OpConfig struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Alias                *wrappers.StringValue `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	Body                 *_struct.Struct       `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpConfig) Descriptor added in v1.1.27 

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

func (*OpConfig) GetAlias added in v1.1.27 

func (m *OpConfig) GetAlias() *wrappers.StringValue

func (*OpConfig) GetBody added in v1.1.27 

func (m *OpConfig) GetBody() *_struct.Struct

func (*OpConfig) GetId added in v1.1.27 

func (m *OpConfig) GetId() *wrappers.StringValue

func (*OpConfig) ProtoMessage added in v1.1.27 

func (*OpConfig) ProtoMessage()

func (*OpConfig) Reset added in v1.1.27 

func (m *OpConfig) Reset()

func (*OpConfig) String added in v1.1.27 

func (m *OpConfig) String() string

func (*OpConfig) Validate added in v1.1.27 

func (this *OpConfig) Validate() error

func (*OpConfig) XXX_DiscardUnknown added in v1.1.27 

func (m *OpConfig) XXX_DiscardUnknown()

func (*OpConfig) XXX_Marshal added in v1.1.27 

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

func (*OpConfig) XXX_Merge added in v1.1.27 

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

func (*OpConfig) XXX_Size added in v1.1.27 

func (m *OpConfig) XXX_Size() int

func (*OpConfig) XXX_Unmarshal added in v1.1.27 

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

type OpDescriptor added in v1.1.27 

type OpDescriptor struct {
	Sha1                 *wrappers.StringValue `protobuf:"bytes,1,opt,name=sha1,proto3" json:"sha1,omitempty"`
	Body                 *wrappers.BytesValue  `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpDescriptor) Descriptor added in v1.1.27 

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

func (*OpDescriptor) GetBody added in v1.1.27 

func (m *OpDescriptor) GetBody() *wrappers.BytesValue

func (*OpDescriptor) GetSha1 added in v1.1.27 

func (m *OpDescriptor) GetSha1() *wrappers.StringValue

func (*OpDescriptor) ProtoMessage added in v1.1.27 

func (*OpDescriptor) ProtoMessage()

func (*OpDescriptor) Reset added in v1.1.27 

func (m *OpDescriptor) Reset()

func (*OpDescriptor) String added in v1.1.27 

func (m *OpDescriptor) String() string

func (*OpDescriptor) Validate added in v1.1.27 

func (this *OpDescriptor) Validate() error

func (*OpDescriptor) XXX_DiscardUnknown added in v1.1.27 

func (m *OpDescriptor) XXX_DiscardUnknown()

func (*OpDescriptor) XXX_Marshal added in v1.1.27 

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

func (*OpDescriptor) XXX_Merge added in v1.1.27 

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

func (*OpDescriptor) XXX_Size added in v1.1.27 

func (m *OpDescriptor) XXX_Size() int

func (*OpDescriptor) XXX_Unmarshal added in v1.1.27 

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

type OpDevice 

type OpDevice struct {
	Id                   *wrappers.StringValue            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Kind                 kind.DeviceKind                  `protobuf:"varint,2,opt,name=kind,proto3,enum=ai.metathings.constant.kind.DeviceKind" json:"kind,omitempty"`
	State                state.DeviceState                `protobuf:"varint,3,opt,name=state,proto3,enum=ai.metathings.constant.state.DeviceState" json:"state,omitempty"`
	Name                 *wrappers.StringValue            `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Alias                *wrappers.StringValue            `protobuf:"bytes,5,opt,name=alias,proto3" json:"alias,omitempty"`
	Extra                map[string]*wrappers.StringValue `` /* 152-byte string literal not displayed */
	Modules              []*OpModule                      `protobuf:"bytes,6,rep,name=modules,proto3" json:"modules,omitempty"`
	HeartbeatAt          *timestamp.Timestamp             `protobuf:"bytes,7,opt,name=heartbeat_at,json=heartbeatAt,proto3" json:"heartbeat_at,omitempty"`
	Flows                []*OpFlow                        `protobuf:"bytes,8,rep,name=flows,proto3" json:"flows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*OpDevice) Descriptor 

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

func (*OpDevice) GetAlias 

func (m *OpDevice) GetAlias() *wrappers.StringValue

func (*OpDevice) GetExtra added in v1.1.23 

func (m *OpDevice) GetExtra() map[string]*wrappers.StringValue

func (*OpDevice) GetFlows 

func (m *OpDevice) GetFlows() []*OpFlow

func (*OpDevice) GetHeartbeatAt 

func (m *OpDevice) GetHeartbeatAt() *timestamp.Timestamp

func (*OpDevice) GetId 

func (m *OpDevice) GetId() *wrappers.StringValue

func (*OpDevice) GetKind 

func (m *OpDevice) GetKind() kind.DeviceKind

func (*OpDevice) GetModules 

func (m *OpDevice) GetModules() []*OpModule

func (*OpDevice) GetName 

func (m *OpDevice) GetName() *wrappers.StringValue

func (*OpDevice) GetState 

func (m *OpDevice) GetState() state.DeviceState

func (*OpDevice) ProtoMessage 

func (*OpDevice) ProtoMessage()

func (*OpDevice) Reset 

func (m *OpDevice) Reset()

func (*OpDevice) String 

func (m *OpDevice) String() string

func (*OpDevice) Validate 

func (this *OpDevice) Validate() error

func (*OpDevice) XXX_DiscardUnknown 

func (m *OpDevice) XXX_DiscardUnknown()

func (*OpDevice) XXX_Marshal 

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

func (*OpDevice) XXX_Merge 

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

func (*OpDevice) XXX_Size 

func (m *OpDevice) XXX_Size() int

func (*OpDevice) XXX_Unmarshal 

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

type OpFlow 

type OpFlow struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DeviceId             *wrappers.StringValue `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Alias                *wrappers.StringValue `protobuf:"bytes,4,opt,name=alias,proto3" json:"alias,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpFlow) Descriptor 

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

func (*OpFlow) GetAlias 

func (m *OpFlow) GetAlias() *wrappers.StringValue

func (*OpFlow) GetDeviceId 

func (m *OpFlow) GetDeviceId() *wrappers.StringValue

func (*OpFlow) GetId 

func (m *OpFlow) GetId() *wrappers.StringValue

func (*OpFlow) GetName 

func (m *OpFlow) GetName() *wrappers.StringValue

func (*OpFlow) ProtoMessage 

func (*OpFlow) ProtoMessage()

func (*OpFlow) Reset 

func (m *OpFlow) Reset()

func (*OpFlow) String 

func (m *OpFlow) String() string

func (*OpFlow) Validate 

func (this *OpFlow) Validate() error

func (*OpFlow) XXX_DiscardUnknown 

func (m *OpFlow) XXX_DiscardUnknown()

func (*OpFlow) XXX_Marshal 

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

func (*OpFlow) XXX_Merge 

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

func (*OpFlow) XXX_Size 

func (m *OpFlow) XXX_Size() int

func (*OpFlow) XXX_Unmarshal 

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

type OpFlowSet added in v1.1.23 

type OpFlowSet struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Alias                *wrappers.StringValue `protobuf:"bytes,3,opt,name=alias,proto3" json:"alias,omitempty"`
	Flows                []*OpFlow             `protobuf:"bytes,4,rep,name=flows,proto3" json:"flows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpFlowSet) Descriptor added in v1.1.23 

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

func (*OpFlowSet) GetAlias added in v1.1.23 

func (m *OpFlowSet) GetAlias() *wrappers.StringValue

func (*OpFlowSet) GetFlows added in v1.1.23 

func (m *OpFlowSet) GetFlows() []*OpFlow

func (*OpFlowSet) GetId added in v1.1.23 

func (m *OpFlowSet) GetId() *wrappers.StringValue

func (*OpFlowSet) GetName added in v1.1.23 

func (m *OpFlowSet) GetName() *wrappers.StringValue

func (*OpFlowSet) ProtoMessage added in v1.1.23 

func (*OpFlowSet) ProtoMessage()

func (*OpFlowSet) Reset added in v1.1.23 

func (m *OpFlowSet) Reset()

func (*OpFlowSet) String added in v1.1.23 

func (m *OpFlowSet) String() string

func (*OpFlowSet) Validate added in v1.1.23 

func (this *OpFlowSet) Validate() error

func (*OpFlowSet) XXX_DiscardUnknown added in v1.1.23 

func (m *OpFlowSet) XXX_DiscardUnknown()

func (*OpFlowSet) XXX_Marshal added in v1.1.23 

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

func (*OpFlowSet) XXX_Merge added in v1.1.23 

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

func (*OpFlowSet) XXX_Size added in v1.1.23 

func (m *OpFlowSet) XXX_Size() int

func (*OpFlowSet) XXX_Unmarshal added in v1.1.23 

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

type OpFrame 

type OpFrame struct {
	Ts                   *timestamp.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Data                 *_struct.Struct      `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*OpFrame) Descriptor 

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

func (*OpFrame) GetData 

func (m *OpFrame) GetData() *_struct.Struct

func (*OpFrame) GetTs 

func (m *OpFrame) GetTs() *timestamp.Timestamp

func (*OpFrame) ProtoMessage 

func (*OpFrame) ProtoMessage()

func (*OpFrame) Reset 

func (m *OpFrame) Reset()

func (*OpFrame) String 

func (m *OpFrame) String() string

func (*OpFrame) Validate 

func (this *OpFrame) Validate() error

func (*OpFrame) XXX_DiscardUnknown 

func (m *OpFrame) XXX_DiscardUnknown()

func (*OpFrame) XXX_Marshal 

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

func (*OpFrame) XXX_Merge 

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

func (*OpFrame) XXX_Size 

func (m *OpFrame) XXX_Size() int

func (*OpFrame) XXX_Unmarshal 

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

type OpModule 

type OpModule struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State                state.ModuleState     `protobuf:"varint,2,opt,name=state,proto3,enum=ai.metathings.constant.state.ModuleState" json:"state,omitempty"`
	DeviceId             *wrappers.StringValue `protobuf:"bytes,3,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Endpoint             *wrappers.StringValue `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Component            *wrappers.StringValue `protobuf:"bytes,5,opt,name=component,proto3" json:"component,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	Alias                *wrappers.StringValue `protobuf:"bytes,7,opt,name=alias,proto3" json:"alias,omitempty"`
	HeartbeatAt          *timestamp.Timestamp  `protobuf:"bytes,8,opt,name=heartbeat_at,json=heartbeatAt,proto3" json:"heartbeat_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpModule) Descriptor 

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

func (*OpModule) GetAlias 

func (m *OpModule) GetAlias() *wrappers.StringValue

func (*OpModule) GetComponent 

func (m *OpModule) GetComponent() *wrappers.StringValue

func (*OpModule) GetDeviceId 

func (m *OpModule) GetDeviceId() *wrappers.StringValue

func (*OpModule) GetEndpoint 

func (m *OpModule) GetEndpoint() *wrappers.StringValue

func (*OpModule) GetHeartbeatAt 

func (m *OpModule) GetHeartbeatAt() *timestamp.Timestamp

func (*OpModule) GetId 

func (m *OpModule) GetId() *wrappers.StringValue

func (*OpModule) GetName 

func (m *OpModule) GetName() *wrappers.StringValue

func (*OpModule) GetState 

func (m *OpModule) GetState() state.ModuleState

func (*OpModule) ProtoMessage 

func (*OpModule) ProtoMessage()

func (*OpModule) Reset 

func (m *OpModule) Reset()

func (*OpModule) String 

func (m *OpModule) String() string

func (*OpModule) Validate 

func (this *OpModule) Validate() error

func (*OpModule) XXX_DiscardUnknown 

func (m *OpModule) XXX_DiscardUnknown()

func (*OpModule) XXX_Marshal 

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

func (*OpModule) XXX_Merge 

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

func (*OpModule) XXX_Size 

func (m *OpModule) XXX_Size() int

func (*OpModule) XXX_Unmarshal 

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

type OpObject 

type OpObject struct {
	Device               *OpDevice             `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Prefix               *wrappers.StringValue `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Length               *wrappers.Int64Value  `protobuf:"bytes,4,opt,name=length,proto3" json:"length,omitempty"`
	Etag                 *wrappers.StringValue `protobuf:"bytes,5,opt,name=etag,proto3" json:"etag,omitempty"`
	LastModified         *timestamp.Timestamp  `protobuf:"bytes,6,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpObject) Descriptor 

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

func (*OpObject) GetDevice 

func (m *OpObject) GetDevice() *OpDevice

func (*OpObject) GetEtag 

func (m *OpObject) GetEtag() *wrappers.StringValue

func (*OpObject) GetLastModified added in v1.0.0 

func (m *OpObject) GetLastModified() *timestamp.Timestamp

func (*OpObject) GetLength 

func (m *OpObject) GetLength() *wrappers.Int64Value

func (*OpObject) GetName 

func (m *OpObject) GetName() *wrappers.StringValue

func (*OpObject) GetPrefix 

func (m *OpObject) GetPrefix() *wrappers.StringValue

func (*OpObject) ProtoMessage 

func (*OpObject) ProtoMessage()

func (*OpObject) Reset 

func (m *OpObject) Reset()

func (*OpObject) String 

func (m *OpObject) String() string

func (*OpObject) Validate 

func (this *OpObject) Validate() error

func (*OpObject) XXX_DiscardUnknown 

func (m *OpObject) XXX_DiscardUnknown()

func (*OpObject) XXX_Marshal 

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

func (*OpObject) XXX_Merge 

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

func (*OpObject) XXX_Size 

func (m *OpObject) XXX_Size() int

func (*OpObject) XXX_Unmarshal 

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

type OpObjectChunk added in v1.1.16 

type OpObjectChunk struct {
	Offset               *wrappers.Int64Value `protobuf:"bytes,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Data                 *wrappers.BytesValue `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Length               *wrappers.Int64Value `protobuf:"bytes,3,opt,name=length,proto3" json:"length,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*OpObjectChunk) Descriptor added in v1.1.16 

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

func (*OpObjectChunk) GetData added in v1.1.16 

func (m *OpObjectChunk) GetData() *wrappers.BytesValue

func (*OpObjectChunk) GetLength added in v1.1.16 

func (m *OpObjectChunk) GetLength() *wrappers.Int64Value

func (*OpObjectChunk) GetOffset added in v1.1.16 

func (m *OpObjectChunk) GetOffset() *wrappers.Int64Value

func (*OpObjectChunk) ProtoMessage added in v1.1.16 

func (*OpObjectChunk) ProtoMessage()

func (*OpObjectChunk) Reset added in v1.1.16 

func (m *OpObjectChunk) Reset()

func (*OpObjectChunk) String added in v1.1.16 

func (m *OpObjectChunk) String() string

func (*OpObjectChunk) Validate added in v1.1.16 

func (this *OpObjectChunk) Validate() error

func (*OpObjectChunk) XXX_DiscardUnknown added in v1.1.16 

func (m *OpObjectChunk) XXX_DiscardUnknown()

func (*OpObjectChunk) XXX_Marshal added in v1.1.16 

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

func (*OpObjectChunk) XXX_Merge added in v1.1.16 

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

func (*OpObjectChunk) XXX_Size added in v1.1.16 

func (m *OpObjectChunk) XXX_Size() int

func (*OpObjectChunk) XXX_Unmarshal added in v1.1.16 

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

type OpObjectChunks added in v1.1.16 

type OpObjectChunks struct {
	Chunks               []*OpObjectChunk `protobuf:"bytes,1,rep,name=chunks,proto3" json:"chunks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*OpObjectChunks) Descriptor added in v1.1.16 

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

func (*OpObjectChunks) GetChunks added in v1.1.16 

func (m *OpObjectChunks) GetChunks() []*OpObjectChunk

func (*OpObjectChunks) ProtoMessage added in v1.1.16 

func (*OpObjectChunks) ProtoMessage()

func (*OpObjectChunks) Reset added in v1.1.16 

func (m *OpObjectChunks) Reset()

func (*OpObjectChunks) String added in v1.1.16 

func (m *OpObjectChunks) String() string

func (*OpObjectChunks) Validate added in v1.1.16 

func (this *OpObjectChunks) Validate() error

func (*OpObjectChunks) XXX_DiscardUnknown added in v1.1.16 

func (m *OpObjectChunks) XXX_DiscardUnknown()

func (*OpObjectChunks) XXX_Marshal added in v1.1.16 

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

func (*OpObjectChunks) XXX_Merge added in v1.1.16 

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

func (*OpObjectChunks) XXX_Size added in v1.1.16 

func (m *OpObjectChunks) XXX_Size() int

func (*OpObjectChunks) XXX_Unmarshal added in v1.1.16 

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

type OpStreamCallConfig 

type OpStreamCallConfig struct {
	Name                 *wrappers.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Component            *wrappers.StringValue `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	Method               *wrappers.StringValue `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpStreamCallConfig) Descriptor 

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

func (*OpStreamCallConfig) GetComponent 

func (m *OpStreamCallConfig) GetComponent() *wrappers.StringValue

func (*OpStreamCallConfig) GetMethod 

func (m *OpStreamCallConfig) GetMethod() *wrappers.StringValue

func (*OpStreamCallConfig) GetName 

func (m *OpStreamCallConfig) GetName() *wrappers.StringValue

func (*OpStreamCallConfig) ProtoMessage 

func (*OpStreamCallConfig) ProtoMessage()

func (*OpStreamCallConfig) Reset 

func (m *OpStreamCallConfig) Reset()

func (*OpStreamCallConfig) String 

func (m *OpStreamCallConfig) String() string

func (*OpStreamCallConfig) Validate 

func (this *OpStreamCallConfig) Validate() error

func (*OpStreamCallConfig) XXX_DiscardUnknown 

func (m *OpStreamCallConfig) XXX_DiscardUnknown()

func (*OpStreamCallConfig) XXX_Marshal 

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

func (*OpStreamCallConfig) XXX_Merge 

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

func (*OpStreamCallConfig) XXX_Size 

func (m *OpStreamCallConfig) XXX_Size() int

func (*OpStreamCallConfig) XXX_Unmarshal 

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

type OpStreamCallConfigAck 

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

func (*OpStreamCallConfigAck) Descriptor 

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

func (*OpStreamCallConfigAck) ProtoMessage 

func (*OpStreamCallConfigAck) ProtoMessage()

func (*OpStreamCallConfigAck) Reset 

func (m *OpStreamCallConfigAck) Reset()

func (*OpStreamCallConfigAck) String 

func (m *OpStreamCallConfigAck) String() string

func (*OpStreamCallConfigAck) Validate 

func (this *OpStreamCallConfigAck) Validate() error

func (*OpStreamCallConfigAck) XXX_DiscardUnknown 

func (m *OpStreamCallConfigAck) XXX_DiscardUnknown()

func (*OpStreamCallConfigAck) XXX_Marshal 

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

func (*OpStreamCallConfigAck) XXX_Merge 

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

func (*OpStreamCallConfigAck) XXX_Size 

func (m *OpStreamCallConfigAck) XXX_Size() int

func (*OpStreamCallConfigAck) XXX_Unmarshal 

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

type OpStreamCallExit 

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

func (*OpStreamCallExit) Descriptor 

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

func (*OpStreamCallExit) ProtoMessage 

func (*OpStreamCallExit) ProtoMessage()

func (*OpStreamCallExit) Reset 

func (m *OpStreamCallExit) Reset()

func (*OpStreamCallExit) String 

func (m *OpStreamCallExit) String() string

func (*OpStreamCallExit) Validate 

func (this *OpStreamCallExit) Validate() error

func (*OpStreamCallExit) XXX_DiscardUnknown 

func (m *OpStreamCallExit) XXX_DiscardUnknown()

func (*OpStreamCallExit) XXX_Marshal 

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

func (*OpStreamCallExit) XXX_Merge 

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

func (*OpStreamCallExit) XXX_Size 

func (m *OpStreamCallExit) XXX_Size() int

func (*OpStreamCallExit) XXX_Unmarshal 

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

type OpStreamCallValue 

type OpStreamCallValue struct {
	// Types that are valid to be assigned to Union:
	//	*OpStreamCallValue_Value
	//	*OpStreamCallValue_Config
	//	*OpStreamCallValue_ConfigAck
	//	*OpStreamCallValue_Exit
	Union                isOpStreamCallValue_Union `protobuf_oneof:"union"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*OpStreamCallValue) Descriptor 

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

func (*OpStreamCallValue) GetConfig 

func (m *OpStreamCallValue) GetConfig() *OpStreamCallConfig

func (*OpStreamCallValue) GetConfigAck 

func (m *OpStreamCallValue) GetConfigAck() *OpStreamCallConfigAck

func (*OpStreamCallValue) GetExit 

func (m *OpStreamCallValue) GetExit() *OpStreamCallExit

func (*OpStreamCallValue) GetUnion 

func (m *OpStreamCallValue) GetUnion() isOpStreamCallValue_Union

func (*OpStreamCallValue) GetValue 

func (m *OpStreamCallValue) GetValue() *any.Any

func (*OpStreamCallValue) ProtoMessage 

func (*OpStreamCallValue) ProtoMessage()

func (*OpStreamCallValue) Reset 

func (m *OpStreamCallValue) Reset()

func (*OpStreamCallValue) String 

func (m *OpStreamCallValue) String() string

func (*OpStreamCallValue) Validate 

func (this *OpStreamCallValue) Validate() error

func (*OpStreamCallValue) XXX_DiscardUnknown 

func (m *OpStreamCallValue) XXX_DiscardUnknown()

func (*OpStreamCallValue) XXX_Marshal 

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

func (*OpStreamCallValue) XXX_Merge 

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

func (*OpStreamCallValue) XXX_OneofWrappers added in v1.0.0 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*OpStreamCallValue) XXX_Size 

func (m *OpStreamCallValue) XXX_Size() int

func (*OpStreamCallValue) XXX_Unmarshal 

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

type OpStreamCallValue_Config 

type OpStreamCallValue_Config struct {
	Config *OpStreamCallConfig `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type OpStreamCallValue_ConfigAck 

type OpStreamCallValue_ConfigAck struct {
	ConfigAck *OpStreamCallConfigAck `protobuf:"bytes,3,opt,name=config_ack,json=configAck,proto3,oneof"`
}

type OpStreamCallValue_Exit 

type OpStreamCallValue_Exit struct {
	Exit *OpStreamCallExit `protobuf:"bytes,4,opt,name=exit,proto3,oneof"`
}

type OpStreamCallValue_Value 

type OpStreamCallValue_Value struct {
	Value *any.Any `protobuf:"bytes,1,opt,name=value,proto3,oneof"`
}

type OpUnaryCallValue 

type OpUnaryCallValue struct {
	Name                 *wrappers.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Component            *wrappers.StringValue `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	Method               *wrappers.StringValue `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Value                *any.Any              `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OpUnaryCallValue) Descriptor 

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

func (*OpUnaryCallValue) GetComponent 

func (m *OpUnaryCallValue) GetComponent() *wrappers.StringValue

func (*OpUnaryCallValue) GetMethod 

func (m *OpUnaryCallValue) GetMethod() *wrappers.StringValue

func (*OpUnaryCallValue) GetName 

func (m *OpUnaryCallValue) GetName() *wrappers.StringValue

func (*OpUnaryCallValue) GetValue 

func (m *OpUnaryCallValue) GetValue() *any.Any

func (*OpUnaryCallValue) ProtoMessage 

func (*OpUnaryCallValue) ProtoMessage()

func (*OpUnaryCallValue) Reset 

func (m *OpUnaryCallValue) Reset()

func (*OpUnaryCallValue) String 

func (m *OpUnaryCallValue) String() string

func (*OpUnaryCallValue) Validate 

func (this *OpUnaryCallValue) Validate() error

func (*OpUnaryCallValue) XXX_DiscardUnknown 

func (m *OpUnaryCallValue) XXX_DiscardUnknown()

func (*OpUnaryCallValue) XXX_Marshal 

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

func (*OpUnaryCallValue) XXX_Merge 

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

func (*OpUnaryCallValue) XXX_Size 

func (m *OpUnaryCallValue) XXX_Size() int

func (*OpUnaryCallValue) XXX_Unmarshal 

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

type PatchConfigRequest added in v1.1.27 

type PatchConfigRequest struct {
	Config               *OpConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*PatchConfigRequest) Descriptor added in v1.1.27 

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

func (*PatchConfigRequest) GetConfig added in v1.1.27 

func (m *PatchConfigRequest) GetConfig() *OpConfig

func (*PatchConfigRequest) ProtoMessage added in v1.1.27 

func (*PatchConfigRequest) ProtoMessage()

func (*PatchConfigRequest) Reset added in v1.1.27 

func (m *PatchConfigRequest) Reset()

func (*PatchConfigRequest) String added in v1.1.27 

func (m *PatchConfigRequest) String() string

func (*PatchConfigRequest) Validate added in v1.1.27 

func (this *PatchConfigRequest) Validate() error

func (*PatchConfigRequest) XXX_DiscardUnknown added in v1.1.27 

func (m *PatchConfigRequest) XXX_DiscardUnknown()

func (*PatchConfigRequest) XXX_Marshal added in v1.1.27 

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

func (*PatchConfigRequest) XXX_Merge added in v1.1.27 

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

func (*PatchConfigRequest) XXX_Size added in v1.1.27 

func (m *PatchConfigRequest) XXX_Size() int

func (*PatchConfigRequest) XXX_Unmarshal added in v1.1.27 

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

type PatchConfigResponse added in v1.1.27 

type PatchConfigResponse struct {
	Config               *Config  `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PatchConfigResponse) Descriptor added in v1.1.27 

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

func (*PatchConfigResponse) GetConfig added in v1.1.27 

func (m *PatchConfigResponse) GetConfig() *Config

func (*PatchConfigResponse) ProtoMessage added in v1.1.27 

func (*PatchConfigResponse) ProtoMessage()

func (*PatchConfigResponse) Reset added in v1.1.27 

func (m *PatchConfigResponse) Reset()

func (*PatchConfigResponse) String added in v1.1.27 

func (m *PatchConfigResponse) String() string

func (*PatchConfigResponse) Validate added in v1.1.27 

func (this *PatchConfigResponse) Validate() error

func (*PatchConfigResponse) XXX_DiscardUnknown added in v1.1.27 

func (m *PatchConfigResponse) XXX_DiscardUnknown()

func (*PatchConfigResponse) XXX_Marshal added in v1.1.27 

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

func (*PatchConfigResponse) XXX_Merge added in v1.1.27 

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

func (*PatchConfigResponse) XXX_Size added in v1.1.27 

func (m *PatchConfigResponse) XXX_Size() int

func (*PatchConfigResponse) XXX_Unmarshal added in v1.1.27 

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

type PatchDeviceRequest 

type PatchDeviceRequest struct {
	Device               *OpDevice `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*PatchDeviceRequest) Descriptor 

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

func (*PatchDeviceRequest) GetDevice 

func (m *PatchDeviceRequest) GetDevice() *OpDevice

func (*PatchDeviceRequest) ProtoMessage 

func (*PatchDeviceRequest) ProtoMessage()

func (*PatchDeviceRequest) Reset 

func (m *PatchDeviceRequest) Reset()

func (*PatchDeviceRequest) String 

func (m *PatchDeviceRequest) String() string

func (*PatchDeviceRequest) Validate 

func (this *PatchDeviceRequest) Validate() error

func (*PatchDeviceRequest) XXX_DiscardUnknown 

func (m *PatchDeviceRequest) XXX_DiscardUnknown()

func (*PatchDeviceRequest) XXX_Marshal 

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

func (*PatchDeviceRequest) XXX_Merge 

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

func (*PatchDeviceRequest) XXX_Size 

func (m *PatchDeviceRequest) XXX_Size() int

func (*PatchDeviceRequest) XXX_Unmarshal 

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

type PatchDeviceResponse 

type PatchDeviceResponse struct {
	Device               *Device  `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PatchDeviceResponse) Descriptor 

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

func (*PatchDeviceResponse) GetDevice 

func (m *PatchDeviceResponse) GetDevice() *Device

func (*PatchDeviceResponse) ProtoMessage 

func (*PatchDeviceResponse) ProtoMessage()

func (*PatchDeviceResponse) Reset 

func (m *PatchDeviceResponse) Reset()

func (*PatchDeviceResponse) String 

func (m *PatchDeviceResponse) String() string

func (*PatchDeviceResponse) Validate 

func (this *PatchDeviceResponse) Validate() error

func (*PatchDeviceResponse) XXX_DiscardUnknown 

func (m *PatchDeviceResponse) XXX_DiscardUnknown()

func (*PatchDeviceResponse) XXX_Marshal 

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

func (*PatchDeviceResponse) XXX_Merge 

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

func (*PatchDeviceResponse) XXX_Size 

func (m *PatchDeviceResponse) XXX_Size() int

func (*PatchDeviceResponse) XXX_Unmarshal 

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

type PatchFlowSetRequest added in v1.1.23 

type PatchFlowSetRequest struct {
	FlowSet              *OpFlowSet `protobuf:"bytes,1,opt,name=flow_set,json=flowSet,proto3" json:"flow_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*PatchFlowSetRequest) Descriptor added in v1.1.23 

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

func (*PatchFlowSetRequest) GetFlowSet added in v1.1.23 

func (m *PatchFlowSetRequest) GetFlowSet() *OpFlowSet

func (*PatchFlowSetRequest) ProtoMessage added in v1.1.23 

func (*PatchFlowSetRequest) ProtoMessage()

func (*PatchFlowSetRequest) Reset added in v1.1.23 

func (m *PatchFlowSetRequest) Reset()

func (*PatchFlowSetRequest) String added in v1.1.23 

func (m *PatchFlowSetRequest) String() string

func (*PatchFlowSetRequest) Validate added in v1.1.23 

func (this *PatchFlowSetRequest) Validate() error

func (*PatchFlowSetRequest) XXX_DiscardUnknown added in v1.1.23 

func (m *PatchFlowSetRequest) XXX_DiscardUnknown()

func (*PatchFlowSetRequest) XXX_Marshal added in v1.1.23 

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

func (*PatchFlowSetRequest) XXX_Merge added in v1.1.23 

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

func (*PatchFlowSetRequest) XXX_Size added in v1.1.23 

func (m *PatchFlowSetRequest) XXX_Size() int

func (*PatchFlowSetRequest) XXX_Unmarshal added in v1.1.23 

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

type PatchFlowSetResponse added in v1.1.23 

type PatchFlowSetResponse struct {
	FlowSet              *FlowSet `protobuf:"bytes,1,opt,name=flow_set,json=flowSet,proto3" json:"flow_set,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PatchFlowSetResponse) Descriptor added in v1.1.23 

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

func (*PatchFlowSetResponse) GetFlowSet added in v1.1.23 

func (m *PatchFlowSetResponse) GetFlowSet() *FlowSet

func (*PatchFlowSetResponse) ProtoMessage added in v1.1.23 

func (*PatchFlowSetResponse) ProtoMessage()

func (*PatchFlowSetResponse) Reset added in v1.1.23 

func (m *PatchFlowSetResponse) Reset()

func (*PatchFlowSetResponse) String added in v1.1.23 

func (m *PatchFlowSetResponse) String() string

func (*PatchFlowSetResponse) Validate added in v1.1.23 

func (this *PatchFlowSetResponse) Validate() error

func (*PatchFlowSetResponse) XXX_DiscardUnknown added in v1.1.23 

func (m *PatchFlowSetResponse) XXX_DiscardUnknown()

func (*PatchFlowSetResponse) XXX_Marshal added in v1.1.23 

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

func (*PatchFlowSetResponse) XXX_Merge added in v1.1.23 

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

func (*PatchFlowSetResponse) XXX_Size added in v1.1.23 

func (m *PatchFlowSetResponse) XXX_Size() int

func (*PatchFlowSetResponse) XXX_Unmarshal added in v1.1.23 

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

type PullFrameFromFlowRequest 

type PullFrameFromFlowRequest struct {
	Id *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Request:
	//	*PullFrameFromFlowRequest_Config_
	Request              isPullFrameFromFlowRequest_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*PullFrameFromFlowRequest) Descriptor 

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

func (*PullFrameFromFlowRequest) GetConfig 

func (m *PullFrameFromFlowRequest) GetConfig() *PullFrameFromFlowRequest_Config

func (*PullFrameFromFlowRequest) GetId 

func (m *PullFrameFromFlowRequest) GetId() *wrappers.StringValue

func (*PullFrameFromFlowRequest) GetRequest 

func (m *PullFrameFromFlowRequest) GetRequest() isPullFrameFromFlowRequest_Request

func (*PullFrameFromFlowRequest) ProtoMessage 

func (*PullFrameFromFlowRequest) ProtoMessage()

func (*PullFrameFromFlowRequest) Reset 

func (m *PullFrameFromFlowRequest) Reset()

func (*PullFrameFromFlowRequest) String 

func (m *PullFrameFromFlowRequest) String() string

func (*PullFrameFromFlowRequest) Validate 

func (this *PullFrameFromFlowRequest) Validate() error

func (*PullFrameFromFlowRequest) XXX_DiscardUnknown 

func (m *PullFrameFromFlowRequest) XXX_DiscardUnknown()

func (*PullFrameFromFlowRequest) XXX_Marshal 

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

func (*PullFrameFromFlowRequest) XXX_Merge 

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

func (*PullFrameFromFlowRequest) XXX_OneofWrappers added in v1.0.0 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PullFrameFromFlowRequest) XXX_Size 

func (m *PullFrameFromFlowRequest) XXX_Size() int

func (*PullFrameFromFlowRequest) XXX_Unmarshal 

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

type PullFrameFromFlowRequest_Config 

type PullFrameFromFlowRequest_Config struct {
	Device               *OpDevice           `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	ConfigAck            *wrappers.BoolValue `protobuf:"bytes,2,opt,name=config_ack,json=configAck,proto3" json:"config_ack,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*PullFrameFromFlowRequest_Config) Descriptor 

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

func (*PullFrameFromFlowRequest_Config) GetConfigAck 

func (m *PullFrameFromFlowRequest_Config) GetConfigAck() *wrappers.BoolValue

func (*PullFrameFromFlowRequest_Config) GetDevice 

func (m *PullFrameFromFlowRequest_Config) GetDevice() *OpDevice

func (*PullFrameFromFlowRequest_Config) ProtoMessage 

func (*PullFrameFromFlowRequest_Config) ProtoMessage()

func (*PullFrameFromFlowRequest_Config) Reset 

func (m *PullFrameFromFlowRequest_Config) Reset()

func (*PullFrameFromFlowRequest_Config) String 

func (m *PullFrameFromFlowRequest_Config) String() string

func (*PullFrameFromFlowRequest_Config) Validate 

func (this *PullFrameFromFlowRequest_Config) Validate() error

func (*PullFrameFromFlowRequest_Config) XXX_DiscardUnknown 

func (m *PullFrameFromFlowRequest_Config) XXX_DiscardUnknown()

func (*PullFrameFromFlowRequest_Config) XXX_Marshal 

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

func (*PullFrameFromFlowRequest_Config) XXX_Merge 

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

func (*PullFrameFromFlowRequest_Config) XXX_Size 

func (m *PullFrameFromFlowRequest_Config) XXX_Size() int

func (*PullFrameFromFlowRequest_Config) XXX_Unmarshal 

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

type PullFrameFromFlowRequest_Config_ 

type PullFrameFromFlowRequest_Config_ struct {
	Config *PullFrameFromFlowRequest_Config `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type PullFrameFromFlowResponse 

type PullFrameFromFlowResponse struct {
	// stream alive check when id is ffffffffffffffffffffffffffffffff,
	// drop it in receive side.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Response:
	//	*PullFrameFromFlowResponse_Ack_
	//	*PullFrameFromFlowResponse_Pack_
	Response             isPullFrameFromFlowResponse_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

func (*PullFrameFromFlowResponse) Descriptor 

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

func (*PullFrameFromFlowResponse) GetAck 

func (m *PullFrameFromFlowResponse) GetAck() *PullFrameFromFlowResponse_Ack

func (*PullFrameFromFlowResponse) GetId 

func (m *PullFrameFromFlowResponse) GetId() string

func (*PullFrameFromFlowResponse) GetPack 

func (m *PullFrameFromFlowResponse) GetPack() *PullFrameFromFlowResponse_Pack

func (*PullFrameFromFlowResponse) GetResponse 

func (m *PullFrameFromFlowResponse) GetResponse() isPullFrameFromFlowResponse_Response

func (*PullFrameFromFlowResponse) ProtoMessage 

func (*PullFrameFromFlowResponse) ProtoMessage()

func (*PullFrameFromFlowResponse) Reset 

func (m *PullFrameFromFlowResponse) Reset()

func (*PullFrameFromFlowResponse) String 

func (m *PullFrameFromFlowResponse) String() string

func (*PullFrameFromFlowResponse) Validate 

func (this *PullFrameFromFlowResponse) Validate() error

func (*PullFrameFromFlowResponse) XXX_DiscardUnknown 

func (m *PullFrameFromFlowResponse) XXX_DiscardUnknown()

func (*PullFrameFromFlowResponse) XXX_Marshal 

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

func (*PullFrameFromFlowResponse) XXX_Merge 

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

func (*PullFrameFromFlowResponse) XXX_OneofWrappers added in v1.0.0 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PullFrameFromFlowResponse) XXX_Size 

func (m *PullFrameFromFlowResponse) XXX_Size() int

func (*PullFrameFromFlowResponse) XXX_Unmarshal 

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

type PullFrameFromFlowResponse_Ack 

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

func (*PullFrameFromFlowResponse_Ack) Descriptor 

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

func (*PullFrameFromFlowResponse_Ack) ProtoMessage 

func (*PullFrameFromFlowResponse_Ack) ProtoMessage()

func (*PullFrameFromFlowResponse_Ack) Reset 

func (m *PullFrameFromFlowResponse_Ack) Reset()

func (*PullFrameFromFlowResponse_Ack) String 

func (m *PullFrameFromFlowResponse_Ack) String() string

func (*PullFrameFromFlowResponse_Ack) Validate 

func (this *PullFrameFromFlowResponse_Ack) Validate() error

func (*PullFrameFromFlowResponse_Ack) XXX_DiscardUnknown 

func (m *PullFrameFromFlowResponse_Ack) XXX_DiscardUnknown()

func (*PullFrameFromFlowResponse_Ack) XXX_Marshal 

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

func (*PullFrameFromFlowResponse_Ack) XXX_Merge 

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

func (*PullFrameFromFlowResponse_Ack) XXX_Size 

func (m *PullFrameFromFlowResponse_Ack) XXX_Size() int

func (*PullFrameFromFlowResponse_Ack) XXX_Unmarshal 

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

type PullFrameFromFlowResponse_Ack_ 

type PullFrameFromFlowResponse_Ack_ struct {
	Ack *PullFrameFromFlowResponse_Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type PullFrameFromFlowResponse_Pack 

type PullFrameFromFlowResponse_Pack struct {
	Flow                 *Flow    `protobuf:"bytes,1,opt,name=flow,proto3" json:"flow,omitempty"`
	Frames               []*Frame `protobuf:"bytes,2,rep,name=frames,proto3" json:"frames,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PullFrameFromFlowResponse_Pack) Descriptor 

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

func (*PullFrameFromFlowResponse_Pack) GetFlow 

func (m *PullFrameFromFlowResponse_Pack) GetFlow() *Flow

func (*PullFrameFromFlowResponse_Pack) GetFrames 

func (m *PullFrameFromFlowResponse_Pack) GetFrames() []*Frame

func (*PullFrameFromFlowResponse_Pack) ProtoMessage 

func (*PullFrameFromFlowResponse_Pack) ProtoMessage()

func (*PullFrameFromFlowResponse_Pack) Reset 

func (m *PullFrameFromFlowResponse_Pack) Reset()

func (*PullFrameFromFlowResponse_Pack) String 

func (m *PullFrameFromFlowResponse_Pack) String() string

func (*PullFrameFromFlowResponse_Pack) Validate 

func (this *PullFrameFromFlowResponse_Pack) Validate() error

func (*PullFrameFromFlowResponse_Pack) XXX_DiscardUnknown 

func (m *PullFrameFromFlowResponse_Pack) XXX_DiscardUnknown()

func (*PullFrameFromFlowResponse_Pack) XXX_Marshal 

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

func (*PullFrameFromFlowResponse_Pack) XXX_Merge 

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

func (*PullFrameFromFlowResponse_Pack) XXX_Size 

func (m *PullFrameFromFlowResponse_Pack) XXX_Size() int

func (*PullFrameFromFlowResponse_Pack) XXX_Unmarshal 

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

type PullFrameFromFlowResponse_Pack_ 

type PullFrameFromFlowResponse_Pack_ struct {
	Pack *PullFrameFromFlowResponse_Pack `protobuf:"bytes,3,opt,name=pack,proto3,oneof"`
}

type PullFrameFromFlowSetRequest added in v1.1.23 

type PullFrameFromFlowSetRequest struct {
	Id *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Request:
	//	*PullFrameFromFlowSetRequest_Config_
	Request              isPullFrameFromFlowSetRequest_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*PullFrameFromFlowSetRequest) Descriptor added in v1.1.23 

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

func (*PullFrameFromFlowSetRequest) GetConfig added in v1.1.23 

func (m *PullFrameFromFlowSetRequest) GetConfig() *PullFrameFromFlowSetRequest_Config

func (*PullFrameFromFlowSetRequest) GetId added in v1.1.23 

func (m *PullFrameFromFlowSetRequest) GetId() *wrappers.StringValue

func (*PullFrameFromFlowSetRequest) GetRequest added in v1.1.23 

func (m *PullFrameFromFlowSetRequest) GetRequest() isPullFrameFromFlowSetRequest_Request

func (*PullFrameFromFlowSetRequest) ProtoMessage added in v1.1.23 

func (*PullFrameFromFlowSetRequest) ProtoMessage()

func (*PullFrameFromFlowSetRequest) Reset added in v1.1.23 

func (m *PullFrameFromFlowSetRequest) Reset()

func (*PullFrameFromFlowSetRequest) String added in v1.1.23 

func (m *PullFrameFromFlowSetRequest) String() string

func (*PullFrameFromFlowSetRequest) Validate added in v1.1.23 

func (this *PullFrameFromFlowSetRequest) Validate() error

func (*PullFrameFromFlowSetRequest) XXX_DiscardUnknown added in v1.1.23 

func (m *PullFrameFromFlowSetRequest) XXX_DiscardUnknown()

func (*PullFrameFromFlowSetRequest) XXX_Marshal added in v1.1.23 

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

func (*PullFrameFromFlowSetRequest) XXX_Merge added in v1.1.23 

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

func (*PullFrameFromFlowSetRequest) XXX_OneofWrappers added in v1.1.23 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PullFrameFromFlowSetRequest) XXX_Size added in v1.1.23 

func (m *PullFrameFromFlowSetRequest) XXX_Size() int

func (*PullFrameFromFlowSetRequest) XXX_Unmarshal added in v1.1.23 

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

type PullFrameFromFlowSetRequest_Config added in v1.1.23 

type PullFrameFromFlowSetRequest_Config struct {
	FlowSet              *OpFlowSet          `protobuf:"bytes,1,opt,name=flow_set,json=flowSet,proto3" json:"flow_set,omitempty"`
	ConfigAck            *wrappers.BoolValue `protobuf:"bytes,2,opt,name=config_ack,json=configAck,proto3" json:"config_ack,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*PullFrameFromFlowSetRequest_Config) Descriptor added in v1.1.23 

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

func (*PullFrameFromFlowSetRequest_Config) GetConfigAck added in v1.1.23 

func (m *PullFrameFromFlowSetRequest_Config) GetConfigAck() *wrappers.BoolValue

func (*PullFrameFromFlowSetRequest_Config) GetFlowSet added in v1.1.23 

func (m *PullFrameFromFlowSetRequest_Config) GetFlowSet() *OpFlowSet

func (*PullFrameFromFlowSetRequest_Config) ProtoMessage added in v1.1.23 

func (*PullFrameFromFlowSetRequest_Config) ProtoMessage()

func (*PullFrameFromFlowSetRequest_Config) Reset added in v1.1.23 

func (m *PullFrameFromFlowSetRequest_Config) Reset()

func (*PullFrameFromFlowSetRequest_Config) String added in v1.1.23 

func (m *PullFrameFromFlowSetRequest_Config) String() string

func (*PullFrameFromFlowSetRequest_Config) Validate added in v1.1.23 

func (this *PullFrameFromFlowSetRequest_Config) Validate() error

func (*PullFrameFromFlowSetRequest_Config) XXX_DiscardUnknown added in v1.1.23 

func (m *PullFrameFromFlowSetRequest_Config) XXX_DiscardUnknown()

func (*PullFrameFromFlowSetRequest_Config) XXX_Marshal added in v1.1.23 

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

func (*PullFrameFromFlowSetRequest_Config) XXX_Merge added in v1.1.23 

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

func (*PullFrameFromFlowSetRequest_Config) XXX_Size added in v1.1.23 

func (m *PullFrameFromFlowSetRequest_Config) XXX_Size() int

func (*PullFrameFromFlowSetRequest_Config) XXX_Unmarshal added in v1.1.23 

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

type PullFrameFromFlowSetRequest_Config_ added in v1.1.23 

type PullFrameFromFlowSetRequest_Config_ struct {
	Config *PullFrameFromFlowSetRequest_Config `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type PullFrameFromFlowSetResponse added in v1.1.23 

type PullFrameFromFlowSetResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Response:
	//	*PullFrameFromFlowSetResponse_Ack_
	//	*PullFrameFromFlowSetResponse_Pack_
	Response             isPullFrameFromFlowSetResponse_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_unrecognized     []byte                                  `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

func (*PullFrameFromFlowSetResponse) Descriptor added in v1.1.23 

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

func (*PullFrameFromFlowSetResponse) GetAck added in v1.1.23 

func (m *PullFrameFromFlowSetResponse) GetAck() *PullFrameFromFlowSetResponse_Ack

func (*PullFrameFromFlowSetResponse) GetId added in v1.1.23 

func (m *PullFrameFromFlowSetResponse) GetId() string

func (*PullFrameFromFlowSetResponse) GetPack added in v1.1.23 

func (m *PullFrameFromFlowSetResponse) GetPack() *PullFrameFromFlowSetResponse_Pack

func (*PullFrameFromFlowSetResponse) GetResponse added in v1.1.23 

func (m *PullFrameFromFlowSetResponse) GetResponse() isPullFrameFromFlowSetResponse_Response

func (*PullFrameFromFlowSetResponse) ProtoMessage added in v1.1.23 

func (*PullFrameFromFlowSetResponse) ProtoMessage()

func (*PullFrameFromFlowSetResponse) Reset added in v1.1.23 

func (m *PullFrameFromFlowSetResponse) Reset()

func (*PullFrameFromFlowSetResponse) String added in v1.1.23 

func (m *PullFrameFromFlowSetResponse) String() string

func (*PullFrameFromFlowSetResponse) Validate added in v1.1.23 

func (this *PullFrameFromFlowSetResponse) Validate() error

func (*PullFrameFromFlowSetResponse) XXX_DiscardUnknown added in v1.1.23 

func (m *PullFrameFromFlowSetResponse) XXX_DiscardUnknown()

func (*PullFrameFromFlowSetResponse) XXX_Marshal added in v1.1.23 

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

func (*PullFrameFromFlowSetResponse) XXX_Merge added in v1.1.23 

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

func (*PullFrameFromFlowSetResponse) XXX_OneofWrappers added in v1.1.23 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PullFrameFromFlowSetResponse) XXX_Size added in v1.1.23 

func (m *PullFrameFromFlowSetResponse) XXX_Size() int

func (*PullFrameFromFlowSetResponse) XXX_Unmarshal added in v1.1.23 

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

type PullFrameFromFlowSetResponse_Ack added in v1.1.23 

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

func (*PullFrameFromFlowSetResponse_Ack) Descriptor added in v1.1.23 

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

func (*PullFrameFromFlowSetResponse_Ack) ProtoMessage added in v1.1.23 

func (*PullFrameFromFlowSetResponse_Ack) ProtoMessage()

func (*PullFrameFromFlowSetResponse_Ack) Reset added in v1.1.23 

func (m *PullFrameFromFlowSetResponse_Ack) Reset()

func (*PullFrameFromFlowSetResponse_Ack) String added in v1.1.23 

func (m *PullFrameFromFlowSetResponse_Ack) String() string

func (*PullFrameFromFlowSetResponse_Ack) Validate added in v1.1.23 

func (this *PullFrameFromFlowSetResponse_Ack) Validate() error

func (*PullFrameFromFlowSetResponse_Ack) XXX_DiscardUnknown added in v1.1.23 

func (m *PullFrameFromFlowSetResponse_Ack) XXX_DiscardUnknown()

func (*PullFrameFromFlowSetResponse_Ack) XXX_Marshal added in v1.1.23 

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

func (*PullFrameFromFlowSetResponse_Ack) XXX_Merge added in v1.1.23 

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

func (*PullFrameFromFlowSetResponse_Ack) XXX_Size added in v1.1.23 

func (m *PullFrameFromFlowSetResponse_Ack) XXX_Size() int

func (*PullFrameFromFlowSetResponse_Ack) XXX_Unmarshal added in v1.1.23 

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

type PullFrameFromFlowSetResponse_Ack_ added in v1.1.23 

type PullFrameFromFlowSetResponse_Ack_ struct {
	Ack *PullFrameFromFlowSetResponse_Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type PullFrameFromFlowSetResponse_Pack added in v1.1.23 

type PullFrameFromFlowSetResponse_Pack struct {
	Device               *Device  `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Frames               []*Frame `protobuf:"bytes,2,rep,name=frames,proto3" json:"frames,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PullFrameFromFlowSetResponse_Pack) Descriptor added in v1.1.23 

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

func (*PullFrameFromFlowSetResponse_Pack) GetDevice added in v1.1.23 

func (m *PullFrameFromFlowSetResponse_Pack) GetDevice() *Device

func (*PullFrameFromFlowSetResponse_Pack) GetFrames added in v1.1.23 

func (m *PullFrameFromFlowSetResponse_Pack) GetFrames() []*Frame

func (*PullFrameFromFlowSetResponse_Pack) ProtoMessage added in v1.1.23 

func (*PullFrameFromFlowSetResponse_Pack) ProtoMessage()

func (*PullFrameFromFlowSetResponse_Pack) Reset added in v1.1.23 

func (m *PullFrameFromFlowSetResponse_Pack) Reset()

func (*PullFrameFromFlowSetResponse_Pack) String added in v1.1.23 

func (m *PullFrameFromFlowSetResponse_Pack) String() string

func (*PullFrameFromFlowSetResponse_Pack) Validate added in v1.1.23 

func (this *PullFrameFromFlowSetResponse_Pack) Validate() error

func (*PullFrameFromFlowSetResponse_Pack) XXX_DiscardUnknown added in v1.1.23 

func (m *PullFrameFromFlowSetResponse_Pack) XXX_DiscardUnknown()

func (*PullFrameFromFlowSetResponse_Pack) XXX_Marshal added in v1.1.23 

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

func (*PullFrameFromFlowSetResponse_Pack) XXX_Merge added in v1.1.23 

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

func (*PullFrameFromFlowSetResponse_Pack) XXX_Size added in v1.1.23 

func (m *PullFrameFromFlowSetResponse_Pack) XXX_Size() int

func (*PullFrameFromFlowSetResponse_Pack) XXX_Unmarshal added in v1.1.23 

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

type PullFrameFromFlowSetResponse_Pack_ added in v1.1.23 

type PullFrameFromFlowSetResponse_Pack_ struct {
	Pack *PullFrameFromFlowSetResponse_Pack `protobuf:"bytes,3,opt,name=pack,proto3,oneof"`
}

type PushFrameToFlowRequest 

type PushFrameToFlowRequest struct {
	Id *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Request:
	//	*PushFrameToFlowRequest_Config_
	//	*PushFrameToFlowRequest_Frame
	Request              isPushFrameToFlowRequest_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*PushFrameToFlowRequest) Descriptor 

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

func (*PushFrameToFlowRequest) GetConfig 

func (m *PushFrameToFlowRequest) GetConfig() *PushFrameToFlowRequest_Config

func (*PushFrameToFlowRequest) GetFrame 

func (m *PushFrameToFlowRequest) GetFrame() *OpFrame

func (*PushFrameToFlowRequest) GetId 

func (m *PushFrameToFlowRequest) GetId() *wrappers.StringValue

func (*PushFrameToFlowRequest) GetRequest 

func (m *PushFrameToFlowRequest) GetRequest() isPushFrameToFlowRequest_Request

func (*PushFrameToFlowRequest) ProtoMessage 

func (*PushFrameToFlowRequest) ProtoMessage()

func (*PushFrameToFlowRequest) Reset 

func (m *PushFrameToFlowRequest) Reset()

func (*PushFrameToFlowRequest) String 

func (m *PushFrameToFlowRequest) String() string

func (*PushFrameToFlowRequest) Validate 

func (this *PushFrameToFlowRequest) Validate() error

func (*PushFrameToFlowRequest) XXX_DiscardUnknown 

func (m *PushFrameToFlowRequest) XXX_DiscardUnknown()

func (*PushFrameToFlowRequest) XXX_Marshal 

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

func (*PushFrameToFlowRequest) XXX_Merge 

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

func (*PushFrameToFlowRequest) XXX_OneofWrappers added in v1.0.0 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PushFrameToFlowRequest) XXX_Size 

func (m *PushFrameToFlowRequest) XXX_Size() int

func (*PushFrameToFlowRequest) XXX_Unmarshal 

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

type PushFrameToFlowRequest_Config 

type PushFrameToFlowRequest_Config struct {
	Device               *OpDevice           `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	ConfigAck            *wrappers.BoolValue `protobuf:"bytes,2,opt,name=config_ack,json=configAck,proto3" json:"config_ack,omitempty"`
	PushAck              *wrappers.BoolValue `protobuf:"bytes,3,opt,name=push_ack,json=pushAck,proto3" json:"push_ack,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*PushFrameToFlowRequest_Config) Descriptor 

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

func (*PushFrameToFlowRequest_Config) GetConfigAck 

func (m *PushFrameToFlowRequest_Config) GetConfigAck() *wrappers.BoolValue

func (*PushFrameToFlowRequest_Config) GetDevice 

func (m *PushFrameToFlowRequest_Config) GetDevice() *OpDevice

func (*PushFrameToFlowRequest_Config) GetPushAck 

func (m *PushFrameToFlowRequest_Config) GetPushAck() *wrappers.BoolValue

func (*PushFrameToFlowRequest_Config) ProtoMessage 

func (*PushFrameToFlowRequest_Config) ProtoMessage()

func (*PushFrameToFlowRequest_Config) Reset 

func (m *PushFrameToFlowRequest_Config) Reset()

func (*PushFrameToFlowRequest_Config) String 

func (m *PushFrameToFlowRequest_Config) String() string

func (*PushFrameToFlowRequest_Config) Validate 

func (this *PushFrameToFlowRequest_Config) Validate() error

func (*PushFrameToFlowRequest_Config) XXX_DiscardUnknown 

func (m *PushFrameToFlowRequest_Config) XXX_DiscardUnknown()

func (*PushFrameToFlowRequest_Config) XXX_Marshal 

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

func (*PushFrameToFlowRequest_Config) XXX_Merge 

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

func (*PushFrameToFlowRequest_Config) XXX_Size 

func (m *PushFrameToFlowRequest_Config) XXX_Size() int

func (*PushFrameToFlowRequest_Config) XXX_Unmarshal 

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

type PushFrameToFlowRequest_Config_ 

type PushFrameToFlowRequest_Config_ struct {
	Config *PushFrameToFlowRequest_Config `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type PushFrameToFlowRequest_Frame 

type PushFrameToFlowRequest_Frame struct {
	Frame *OpFrame `protobuf:"bytes,3,opt,name=frame,proto3,oneof"`
}

type PushFrameToFlowResponse 

type PushFrameToFlowResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Response:
	//	*PushFrameToFlowResponse_Ack_
	Response             isPushFrameToFlowResponse_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*PushFrameToFlowResponse) Descriptor 

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

func (*PushFrameToFlowResponse) GetAck 

func (m *PushFrameToFlowResponse) GetAck() *PushFrameToFlowResponse_Ack

func (*PushFrameToFlowResponse) GetId 

func (m *PushFrameToFlowResponse) GetId() string

func (*PushFrameToFlowResponse) GetResponse 

func (m *PushFrameToFlowResponse) GetResponse() isPushFrameToFlowResponse_Response

func (*PushFrameToFlowResponse) ProtoMessage 

func (*PushFrameToFlowResponse) ProtoMessage()

func (*PushFrameToFlowResponse) Reset 

func (m *PushFrameToFlowResponse) Reset()

func (*PushFrameToFlowResponse) String 

func (m *PushFrameToFlowResponse) String() string

func (*PushFrameToFlowResponse) Validate 

func (this *PushFrameToFlowResponse) Validate() error

func (*PushFrameToFlowResponse) XXX_DiscardUnknown 

func (m *PushFrameToFlowResponse) XXX_DiscardUnknown()

func (*PushFrameToFlowResponse) XXX_Marshal 

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

func (*PushFrameToFlowResponse) XXX_Merge 

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

func (*PushFrameToFlowResponse) XXX_OneofWrappers added in v1.0.0 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PushFrameToFlowResponse) XXX_Size 

func (m *PushFrameToFlowResponse) XXX_Size() int

func (*PushFrameToFlowResponse) XXX_Unmarshal 

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

type PushFrameToFlowResponse_Ack 

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

func (*PushFrameToFlowResponse_Ack) Descriptor 

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

func (*PushFrameToFlowResponse_Ack) ProtoMessage 

func (*PushFrameToFlowResponse_Ack) ProtoMessage()

func (*PushFrameToFlowResponse_Ack) Reset 

func (m *PushFrameToFlowResponse_Ack) Reset()

func (*PushFrameToFlowResponse_Ack) String 

func (m *PushFrameToFlowResponse_Ack) String() string

func (*PushFrameToFlowResponse_Ack) Validate 

func (this *PushFrameToFlowResponse_Ack) Validate() error

func (*PushFrameToFlowResponse_Ack) XXX_DiscardUnknown 

func (m *PushFrameToFlowResponse_Ack) XXX_DiscardUnknown()

func (*PushFrameToFlowResponse_Ack) XXX_Marshal 

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

func (*PushFrameToFlowResponse_Ack) XXX_Merge 

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

func (*PushFrameToFlowResponse_Ack) XXX_Size 

func (m *PushFrameToFlowResponse_Ack) XXX_Size() int

func (*PushFrameToFlowResponse_Ack) XXX_Unmarshal 

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

type PushFrameToFlowResponse_Ack_ 

type PushFrameToFlowResponse_Ack_ struct {
	Ack *PushFrameToFlowResponse_Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type PutObjectRequest 

type PutObjectRequest struct {
	Object               *OpObject            `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Content              *wrappers.BytesValue `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*PutObjectRequest) Descriptor 

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

func (*PutObjectRequest) GetContent 

func (m *PutObjectRequest) GetContent() *wrappers.BytesValue

func (*PutObjectRequest) GetObject 

func (m *PutObjectRequest) GetObject() *OpObject

func (*PutObjectRequest) ProtoMessage 

func (*PutObjectRequest) ProtoMessage()

func (*PutObjectRequest) Reset 

func (m *PutObjectRequest) Reset()

func (*PutObjectRequest) String 

func (m *PutObjectRequest) String() string

func (*PutObjectRequest) Validate 

func (this *PutObjectRequest) Validate() error

func (*PutObjectRequest) XXX_DiscardUnknown 

func (m *PutObjectRequest) XXX_DiscardUnknown()

func (*PutObjectRequest) XXX_Marshal 

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

func (*PutObjectRequest) XXX_Merge 

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

func (*PutObjectRequest) XXX_Size 

func (m *PutObjectRequest) XXX_Size() int

func (*PutObjectRequest) XXX_Unmarshal 

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

type PutObjectStreamingRequest added in v1.1.16 

type PutObjectStreamingRequest struct {
	Id *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Request:
	//	*PutObjectStreamingRequest_Metadata_
	//	*PutObjectStreamingRequest_Chunks
	//	*PutObjectStreamingRequest_Ack_
	Request              isPutObjectStreamingRequest_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*PutObjectStreamingRequest) Descriptor added in v1.1.16 

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

func (*PutObjectStreamingRequest) GetAck added in v1.1.16 

func (m *PutObjectStreamingRequest) GetAck() *PutObjectStreamingRequest_Ack

func (*PutObjectStreamingRequest) GetChunks added in v1.1.16 

func (m *PutObjectStreamingRequest) GetChunks() *OpObjectChunks

func (*PutObjectStreamingRequest) GetId added in v1.1.16 

func (m *PutObjectStreamingRequest) GetId() *wrappers.StringValue

func (*PutObjectStreamingRequest) GetMetadata added in v1.1.16 

func (m *PutObjectStreamingRequest) GetMetadata() *PutObjectStreamingRequest_Metadata

func (*PutObjectStreamingRequest) GetRequest added in v1.1.16 

func (m *PutObjectStreamingRequest) GetRequest() isPutObjectStreamingRequest_Request

func (*PutObjectStreamingRequest) ProtoMessage added in v1.1.16 

func (*PutObjectStreamingRequest) ProtoMessage()

func (*PutObjectStreamingRequest) Reset added in v1.1.16 

func (m *PutObjectStreamingRequest) Reset()

func (*PutObjectStreamingRequest) String added in v1.1.16 

func (m *PutObjectStreamingRequest) String() string

func (*PutObjectStreamingRequest) Validate added in v1.1.16 

func (this *PutObjectStreamingRequest) Validate() error

func (*PutObjectStreamingRequest) XXX_DiscardUnknown added in v1.1.16 

func (m *PutObjectStreamingRequest) XXX_DiscardUnknown()

func (*PutObjectStreamingRequest) XXX_Marshal added in v1.1.16 

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

func (*PutObjectStreamingRequest) XXX_Merge added in v1.1.16 

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

func (*PutObjectStreamingRequest) XXX_OneofWrappers added in v1.1.16 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PutObjectStreamingRequest) XXX_Size added in v1.1.16 

func (m *PutObjectStreamingRequest) XXX_Size() int

func (*PutObjectStreamingRequest) XXX_Unmarshal added in v1.1.16 

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

type PutObjectStreamingRequest_Ack added in v1.1.16 

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

func (*PutObjectStreamingRequest_Ack) Descriptor added in v1.1.16 

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

func (*PutObjectStreamingRequest_Ack) ProtoMessage added in v1.1.16 

func (*PutObjectStreamingRequest_Ack) ProtoMessage()

func (*PutObjectStreamingRequest_Ack) Reset added in v1.1.16 

func (m *PutObjectStreamingRequest_Ack) Reset()

func (*PutObjectStreamingRequest_Ack) String added in v1.1.16 

func (m *PutObjectStreamingRequest_Ack) String() string

func (*PutObjectStreamingRequest_Ack) Validate added in v1.1.16 

func (this *PutObjectStreamingRequest_Ack) Validate() error

func (*PutObjectStreamingRequest_Ack) XXX_DiscardUnknown added in v1.1.16 

func (m *PutObjectStreamingRequest_Ack) XXX_DiscardUnknown()

func (*PutObjectStreamingRequest_Ack) XXX_Marshal added in v1.1.16 

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

func (*PutObjectStreamingRequest_Ack) XXX_Merge added in v1.1.16 

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

func (*PutObjectStreamingRequest_Ack) XXX_Size added in v1.1.16 

func (m *PutObjectStreamingRequest_Ack) XXX_Size() int

func (*PutObjectStreamingRequest_Ack) XXX_Unmarshal added in v1.1.16 

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

type PutObjectStreamingRequest_Ack_ added in v1.1.16 

type PutObjectStreamingRequest_Ack_ struct {
	Ack *PutObjectStreamingRequest_Ack `protobuf:"bytes,4,opt,name=ack,proto3,oneof"`
}

type PutObjectStreamingRequest_Chunks added in v1.1.16 

type PutObjectStreamingRequest_Chunks struct {
	Chunks *OpObjectChunks `protobuf:"bytes,3,opt,name=chunks,proto3,oneof"`
}

type PutObjectStreamingRequest_Metadata added in v1.1.16 

type PutObjectStreamingRequest_Metadata struct {
	Object               *OpObject             `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Sha1                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=sha1,proto3" json:"sha1,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*PutObjectStreamingRequest_Metadata) Descriptor added in v1.1.16 

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

func (*PutObjectStreamingRequest_Metadata) GetObject added in v1.1.16 

func (m *PutObjectStreamingRequest_Metadata) GetObject() *OpObject

func (*PutObjectStreamingRequest_Metadata) GetSha1 added in v1.1.16 

func (m *PutObjectStreamingRequest_Metadata) GetSha1() *wrappers.StringValue

func (*PutObjectStreamingRequest_Metadata) ProtoMessage added in v1.1.16 

func (*PutObjectStreamingRequest_Metadata) ProtoMessage()

func (*PutObjectStreamingRequest_Metadata) Reset added in v1.1.16 

func (m *PutObjectStreamingRequest_Metadata) Reset()

func (*PutObjectStreamingRequest_Metadata) String added in v1.1.16 

func (m *PutObjectStreamingRequest_Metadata) String() string

func (*PutObjectStreamingRequest_Metadata) Validate added in v1.1.16 

func (this *PutObjectStreamingRequest_Metadata) Validate() error

func (*PutObjectStreamingRequest_Metadata) XXX_DiscardUnknown added in v1.1.16 

func (m *PutObjectStreamingRequest_Metadata) XXX_DiscardUnknown()

func (*PutObjectStreamingRequest_Metadata) XXX_Marshal added in v1.1.16 

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

func (*PutObjectStreamingRequest_Metadata) XXX_Merge added in v1.1.16 

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

func (*PutObjectStreamingRequest_Metadata) XXX_Size added in v1.1.16 

func (m *PutObjectStreamingRequest_Metadata) XXX_Size() int

func (*PutObjectStreamingRequest_Metadata) XXX_Unmarshal added in v1.1.16 

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

type PutObjectStreamingRequest_Metadata_ added in v1.1.16 

type PutObjectStreamingRequest_Metadata_ struct {
	Metadata *PutObjectStreamingRequest_Metadata `protobuf:"bytes,2,opt,name=metadata,proto3,oneof"`
}

type PutObjectStreamingResponse added in v1.1.16 

type PutObjectStreamingResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Response:
	//	*PutObjectStreamingResponse_Chunks
	//	*PutObjectStreamingResponse_Ack_
	Response             isPutObjectStreamingResponse_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*PutObjectStreamingResponse) Descriptor added in v1.1.16 

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

func (*PutObjectStreamingResponse) GetAck added in v1.1.16 

func (m *PutObjectStreamingResponse) GetAck() *PutObjectStreamingResponse_Ack

func (*PutObjectStreamingResponse) GetChunks added in v1.1.16 

func (m *PutObjectStreamingResponse) GetChunks() *ObjectChunks

func (*PutObjectStreamingResponse) GetId added in v1.1.16 

func (m *PutObjectStreamingResponse) GetId() string

func (*PutObjectStreamingResponse) GetResponse added in v1.1.16 

func (m *PutObjectStreamingResponse) GetResponse() isPutObjectStreamingResponse_Response

func (*PutObjectStreamingResponse) ProtoMessage added in v1.1.16 

func (*PutObjectStreamingResponse) ProtoMessage()

func (*PutObjectStreamingResponse) Reset added in v1.1.16 

func (m *PutObjectStreamingResponse) Reset()

func (*PutObjectStreamingResponse) String added in v1.1.16 

func (m *PutObjectStreamingResponse) String() string

func (*PutObjectStreamingResponse) Validate added in v1.1.16 

func (this *PutObjectStreamingResponse) Validate() error

func (*PutObjectStreamingResponse) XXX_DiscardUnknown added in v1.1.16 

func (m *PutObjectStreamingResponse) XXX_DiscardUnknown()

func (*PutObjectStreamingResponse) XXX_Marshal added in v1.1.16 

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

func (*PutObjectStreamingResponse) XXX_Merge added in v1.1.16 

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

func (*PutObjectStreamingResponse) XXX_OneofWrappers added in v1.1.16 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PutObjectStreamingResponse) XXX_Size added in v1.1.16 

func (m *PutObjectStreamingResponse) XXX_Size() int

func (*PutObjectStreamingResponse) XXX_Unmarshal added in v1.1.16 

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

type PutObjectStreamingResponse_Ack added in v1.1.16 

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

func (*PutObjectStreamingResponse_Ack) Descriptor added in v1.1.16 

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

func (*PutObjectStreamingResponse_Ack) ProtoMessage added in v1.1.16 

func (*PutObjectStreamingResponse_Ack) ProtoMessage()

func (*PutObjectStreamingResponse_Ack) Reset added in v1.1.16 

func (m *PutObjectStreamingResponse_Ack) Reset()

func (*PutObjectStreamingResponse_Ack) String added in v1.1.16 

func (m *PutObjectStreamingResponse_Ack) String() string

func (*PutObjectStreamingResponse_Ack) Validate added in v1.1.16 

func (this *PutObjectStreamingResponse_Ack) Validate() error

func (*PutObjectStreamingResponse_Ack) XXX_DiscardUnknown added in v1.1.16 

func (m *PutObjectStreamingResponse_Ack) XXX_DiscardUnknown()

func (*PutObjectStreamingResponse_Ack) XXX_Marshal added in v1.1.16 

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

func (*PutObjectStreamingResponse_Ack) XXX_Merge added in v1.1.16 

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

func (*PutObjectStreamingResponse_Ack) XXX_Size added in v1.1.16 

func (m *PutObjectStreamingResponse_Ack) XXX_Size() int

func (*PutObjectStreamingResponse_Ack) XXX_Unmarshal added in v1.1.16 

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

type PutObjectStreamingResponse_Ack_ added in v1.1.16 

type PutObjectStreamingResponse_Ack_ struct {
	Ack *PutObjectStreamingResponse_Ack `protobuf:"bytes,3,opt,name=ack,proto3,oneof"`
}

type PutObjectStreamingResponse_Chunks added in v1.1.16 

type PutObjectStreamingResponse_Chunks struct {
	Chunks *ObjectChunks `protobuf:"bytes,2,opt,name=chunks,proto3,oneof"`
}

type QueryFramesFromFlowRequest 

type QueryFramesFromFlowRequest struct {
	Device               *OpDevice            `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	From                 *timestamp.Timestamp `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	To                   *timestamp.Timestamp `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*QueryFramesFromFlowRequest) Descriptor 

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

func (*QueryFramesFromFlowRequest) GetDevice 

func (m *QueryFramesFromFlowRequest) GetDevice() *OpDevice

func (*QueryFramesFromFlowRequest) GetFrom 

func (m *QueryFramesFromFlowRequest) GetFrom() *timestamp.Timestamp

func (*QueryFramesFromFlowRequest) GetTo 

func (m *QueryFramesFromFlowRequest) GetTo() *timestamp.Timestamp

func (*QueryFramesFromFlowRequest) ProtoMessage 

func (*QueryFramesFromFlowRequest) ProtoMessage()

func (*QueryFramesFromFlowRequest) Reset 

func (m *QueryFramesFromFlowRequest) Reset()

func (*QueryFramesFromFlowRequest) String 

func (m *QueryFramesFromFlowRequest) String() string

func (*QueryFramesFromFlowRequest) Validate 

func (this *QueryFramesFromFlowRequest) Validate() error

func (*QueryFramesFromFlowRequest) XXX_DiscardUnknown 

func (m *QueryFramesFromFlowRequest) XXX_DiscardUnknown()

func (*QueryFramesFromFlowRequest) XXX_Marshal 

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

func (*QueryFramesFromFlowRequest) XXX_Merge 

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

func (*QueryFramesFromFlowRequest) XXX_Size 

func (m *QueryFramesFromFlowRequest) XXX_Size() int

func (*QueryFramesFromFlowRequest) XXX_Unmarshal 

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

type QueryFramesFromFlowResponse 

type QueryFramesFromFlowResponse struct {
	Packs                []*QueryFramesFromFlowResponse_Pack `protobuf:"bytes,1,rep,name=packs,proto3" json:"packs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*QueryFramesFromFlowResponse) Descriptor 

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

func (*QueryFramesFromFlowResponse) GetPacks 

func (m *QueryFramesFromFlowResponse) GetPacks() []*QueryFramesFromFlowResponse_Pack

func (*QueryFramesFromFlowResponse) ProtoMessage 

func (*QueryFramesFromFlowResponse) ProtoMessage()

func (*QueryFramesFromFlowResponse) Reset 

func (m *QueryFramesFromFlowResponse) Reset()

func (*QueryFramesFromFlowResponse) String 

func (m *QueryFramesFromFlowResponse) String() string

func (*QueryFramesFromFlowResponse) Validate 

func (this *QueryFramesFromFlowResponse) Validate() error

func (*QueryFramesFromFlowResponse) XXX_DiscardUnknown 

func (m *QueryFramesFromFlowResponse) XXX_DiscardUnknown()

func (*QueryFramesFromFlowResponse) XXX_Marshal 

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

func (*QueryFramesFromFlowResponse) XXX_Merge 

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

func (*QueryFramesFromFlowResponse) XXX_Size 

func (m *QueryFramesFromFlowResponse) XXX_Size() int

func (*QueryFramesFromFlowResponse) XXX_Unmarshal 

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

type QueryFramesFromFlowResponse_Pack 

type QueryFramesFromFlowResponse_Pack struct {
	Flow                 *Flow    `protobuf:"bytes,1,opt,name=flow,proto3" json:"flow,omitempty"`
	Frames               []*Frame `protobuf:"bytes,2,rep,name=frames,proto3" json:"frames,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryFramesFromFlowResponse_Pack) Descriptor 

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

func (*QueryFramesFromFlowResponse_Pack) GetFlow 

func (m *QueryFramesFromFlowResponse_Pack) GetFlow() *Flow

func (*QueryFramesFromFlowResponse_Pack) GetFrames 

func (m *QueryFramesFromFlowResponse_Pack) GetFrames() []*Frame

func (*QueryFramesFromFlowResponse_Pack) ProtoMessage 

func (*QueryFramesFromFlowResponse_Pack) ProtoMessage()

func (*QueryFramesFromFlowResponse_Pack) Reset 

func (m *QueryFramesFromFlowResponse_Pack) Reset()

func (*QueryFramesFromFlowResponse_Pack) String 

func (m *QueryFramesFromFlowResponse_Pack) String() string

func (*QueryFramesFromFlowResponse_Pack) Validate 

func (this *QueryFramesFromFlowResponse_Pack) Validate() error

func (*QueryFramesFromFlowResponse_Pack) XXX_DiscardUnknown 

func (m *QueryFramesFromFlowResponse_Pack) XXX_DiscardUnknown()

func (*QueryFramesFromFlowResponse_Pack) XXX_Marshal 

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

func (*QueryFramesFromFlowResponse_Pack) XXX_Merge 

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

func (*QueryFramesFromFlowResponse_Pack) XXX_Size 

func (m *QueryFramesFromFlowResponse_Pack) XXX_Size() int

func (*QueryFramesFromFlowResponse_Pack) XXX_Unmarshal 

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

type RemoveConfigsFromDeviceRequest added in v1.1.27 

type RemoveConfigsFromDeviceRequest struct {
	Device               *OpDevice   `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Configs              []*OpConfig `protobuf:"bytes,2,rep,name=configs,proto3" json:"configs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*RemoveConfigsFromDeviceRequest) Descriptor added in v1.1.27 

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

func (*RemoveConfigsFromDeviceRequest) GetConfigs added in v1.1.27 

func (m *RemoveConfigsFromDeviceRequest) GetConfigs() []*OpConfig

func (*RemoveConfigsFromDeviceRequest) GetDevice added in v1.1.27 

func (m *RemoveConfigsFromDeviceRequest) GetDevice() *OpDevice

func (*RemoveConfigsFromDeviceRequest) ProtoMessage added in v1.1.27 

func (*RemoveConfigsFromDeviceRequest) ProtoMessage()

func (*RemoveConfigsFromDeviceRequest) Reset added in v1.1.27 

func (m *RemoveConfigsFromDeviceRequest) Reset()

func (*RemoveConfigsFromDeviceRequest) String added in v1.1.27 

func (m *RemoveConfigsFromDeviceRequest) String() string

func (*RemoveConfigsFromDeviceRequest) Validate added in v1.1.27 

func (this *RemoveConfigsFromDeviceRequest) Validate() error

func (*RemoveConfigsFromDeviceRequest) XXX_DiscardUnknown added in v1.1.27 

func (m *RemoveConfigsFromDeviceRequest) XXX_DiscardUnknown()

func (*RemoveConfigsFromDeviceRequest) XXX_Marshal added in v1.1.27 

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

func (*RemoveConfigsFromDeviceRequest) XXX_Merge added in v1.1.27 

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

func (*RemoveConfigsFromDeviceRequest) XXX_Size added in v1.1.27 

func (m *RemoveConfigsFromDeviceRequest) XXX_Size() int

func (*RemoveConfigsFromDeviceRequest) XXX_Unmarshal added in v1.1.27 

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

type RemoveFlowsFromFlowSetRequest added in v1.1.23 

type RemoveFlowsFromFlowSetRequest struct {
	FlowSet              *OpFlowSet  `protobuf:"bytes,1,opt,name=flow_set,json=flowSet,proto3" json:"flow_set,omitempty"`
	Devices              []*OpDevice `protobuf:"bytes,2,rep,name=devices,proto3" json:"devices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*RemoveFlowsFromFlowSetRequest) Descriptor added in v1.1.23 

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

func (*RemoveFlowsFromFlowSetRequest) GetDevices added in v1.1.23 

func (m *RemoveFlowsFromFlowSetRequest) GetDevices() []*OpDevice

func (*RemoveFlowsFromFlowSetRequest) GetFlowSet added in v1.1.23 

func (m *RemoveFlowsFromFlowSetRequest) GetFlowSet() *OpFlowSet

func (*RemoveFlowsFromFlowSetRequest) ProtoMessage added in v1.1.23 

func (*RemoveFlowsFromFlowSetRequest) ProtoMessage()

func (*RemoveFlowsFromFlowSetRequest) Reset added in v1.1.23 

func (m *RemoveFlowsFromFlowSetRequest) Reset()

func (*RemoveFlowsFromFlowSetRequest) String added in v1.1.23 

func (m *RemoveFlowsFromFlowSetRequest) String() string

func (*RemoveFlowsFromFlowSetRequest) Validate added in v1.1.23 

func (this *RemoveFlowsFromFlowSetRequest) Validate() error

func (*RemoveFlowsFromFlowSetRequest) XXX_DiscardUnknown added in v1.1.23 

func (m *RemoveFlowsFromFlowSetRequest) XXX_DiscardUnknown()

func (*RemoveFlowsFromFlowSetRequest) XXX_Marshal added in v1.1.23 

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

func (*RemoveFlowsFromFlowSetRequest) XXX_Merge added in v1.1.23 

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

func (*RemoveFlowsFromFlowSetRequest) XXX_Size added in v1.1.23 

func (m *RemoveFlowsFromFlowSetRequest) XXX_Size() int

func (*RemoveFlowsFromFlowSetRequest) XXX_Unmarshal added in v1.1.23 

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

type RemoveObjectRequest 

type RemoveObjectRequest struct {
	Object               *OpObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RemoveObjectRequest) Descriptor 

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

func (*RemoveObjectRequest) GetObject 

func (m *RemoveObjectRequest) GetObject() *OpObject

func (*RemoveObjectRequest) ProtoMessage 

func (*RemoveObjectRequest) ProtoMessage()

func (*RemoveObjectRequest) Reset 

func (m *RemoveObjectRequest) Reset()

func (*RemoveObjectRequest) String 

func (m *RemoveObjectRequest) String() string

func (*RemoveObjectRequest) Validate 

func (this *RemoveObjectRequest) Validate() error

func (*RemoveObjectRequest) XXX_DiscardUnknown 

func (m *RemoveObjectRequest) XXX_DiscardUnknown()

func (*RemoveObjectRequest) XXX_Marshal 

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

func (*RemoveObjectRequest) XXX_Merge 

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

func (*RemoveObjectRequest) XXX_Size 

func (m *RemoveObjectRequest) XXX_Size() int

func (*RemoveObjectRequest) XXX_Unmarshal 

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

type RenameObjectRequest 

type RenameObjectRequest struct {
	Source               *OpObject `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Destination          *OpObject `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RenameObjectRequest) Descriptor 

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

func (*RenameObjectRequest) GetDestination 

func (m *RenameObjectRequest) GetDestination() *OpObject

func (*RenameObjectRequest) GetSource 

func (m *RenameObjectRequest) GetSource() *OpObject

func (*RenameObjectRequest) ProtoMessage 

func (*RenameObjectRequest) ProtoMessage()

func (*RenameObjectRequest) Reset 

func (m *RenameObjectRequest) Reset()

func (*RenameObjectRequest) String 

func (m *RenameObjectRequest) String() string

func (*RenameObjectRequest) Validate 

func (this *RenameObjectRequest) Validate() error

func (*RenameObjectRequest) XXX_DiscardUnknown 

func (m *RenameObjectRequest) XXX_DiscardUnknown()

func (*RenameObjectRequest) XXX_Marshal 

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

func (*RenameObjectRequest) XXX_Merge 

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

func (*RenameObjectRequest) XXX_Size 

func (m *RenameObjectRequest) XXX_Size() int

func (*RenameObjectRequest) XXX_Unmarshal 

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

type ShowDeviceResponse 

type ShowDeviceResponse struct {
	Device               *Device  `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShowDeviceResponse) Descriptor 

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

func (*ShowDeviceResponse) GetDevice 

func (m *ShowDeviceResponse) GetDevice() *Device

func (*ShowDeviceResponse) ProtoMessage 

func (*ShowDeviceResponse) ProtoMessage()

func (*ShowDeviceResponse) Reset 

func (m *ShowDeviceResponse) Reset()

func (*ShowDeviceResponse) String 

func (m *ShowDeviceResponse) String() string

func (*ShowDeviceResponse) Validate 

func (this *ShowDeviceResponse) Validate() error

func (*ShowDeviceResponse) XXX_DiscardUnknown 

func (m *ShowDeviceResponse) XXX_DiscardUnknown()

func (*ShowDeviceResponse) XXX_Marshal 

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

func (*ShowDeviceResponse) XXX_Merge 

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

func (*ShowDeviceResponse) XXX_Size 

func (m *ShowDeviceResponse) XXX_Size() int

func (*ShowDeviceResponse) XXX_Unmarshal 

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

type StreamCallConfig 

type StreamCallConfig struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Component            string   `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	Method               string   `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamCallConfig) Descriptor 

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

func (*StreamCallConfig) GetComponent 

func (m *StreamCallConfig) GetComponent() string

func (*StreamCallConfig) GetMethod 

func (m *StreamCallConfig) GetMethod() string

func (*StreamCallConfig) GetName 

func (m *StreamCallConfig) GetName() string

func (*StreamCallConfig) ProtoMessage 

func (*StreamCallConfig) ProtoMessage()

func (*StreamCallConfig) Reset 

func (m *StreamCallConfig) Reset()

func (*StreamCallConfig) String 

func (m *StreamCallConfig) String() string

func (*StreamCallConfig) Validate 

func (this *StreamCallConfig) Validate() error

func (*StreamCallConfig) XXX_DiscardUnknown 

func (m *StreamCallConfig) XXX_DiscardUnknown()

func (*StreamCallConfig) XXX_Marshal 

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

func (*StreamCallConfig) XXX_Merge 

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

func (*StreamCallConfig) XXX_Size 

func (m *StreamCallConfig) XXX_Size() int

func (*StreamCallConfig) XXX_Unmarshal 

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

type StreamCallConfigAck 

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

func (*StreamCallConfigAck) Descriptor 

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

func (*StreamCallConfigAck) ProtoMessage 

func (*StreamCallConfigAck) ProtoMessage()

func (*StreamCallConfigAck) Reset 

func (m *StreamCallConfigAck) Reset()

func (*StreamCallConfigAck) String 

func (m *StreamCallConfigAck) String() string

func (*StreamCallConfigAck) Validate 

func (this *StreamCallConfigAck) Validate() error

func (*StreamCallConfigAck) XXX_DiscardUnknown 

func (m *StreamCallConfigAck) XXX_DiscardUnknown()

func (*StreamCallConfigAck) XXX_Marshal 

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

func (*StreamCallConfigAck) XXX_Merge 

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

func (*StreamCallConfigAck) XXX_Size 

func (m *StreamCallConfigAck) XXX_Size() int

func (*StreamCallConfigAck) XXX_Unmarshal 

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

type StreamCallExit 

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

func (*StreamCallExit) Descriptor 

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

func (*StreamCallExit) ProtoMessage 

func (*StreamCallExit) ProtoMessage()

func (*StreamCallExit) Reset 

func (m *StreamCallExit) Reset()

func (*StreamCallExit) String 

func (m *StreamCallExit) String() string

func (*StreamCallExit) Validate 

func (this *StreamCallExit) Validate() error

func (*StreamCallExit) XXX_DiscardUnknown 

func (m *StreamCallExit) XXX_DiscardUnknown()

func (*StreamCallExit) XXX_Marshal 

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

func (*StreamCallExit) XXX_Merge 

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

func (*StreamCallExit) XXX_Size 

func (m *StreamCallExit) XXX_Size() int

func (*StreamCallExit) XXX_Unmarshal 

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

type StreamCallRequest 

type StreamCallRequest struct {
	Device               *OpDevice          `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Value                *OpStreamCallValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*StreamCallRequest) Descriptor 

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

func (*StreamCallRequest) GetDevice 

func (m *StreamCallRequest) GetDevice() *OpDevice

func (*StreamCallRequest) GetValue 

func (m *StreamCallRequest) GetValue() *OpStreamCallValue

func (*StreamCallRequest) ProtoMessage 

func (*StreamCallRequest) ProtoMessage()

func (*StreamCallRequest) Reset 

func (m *StreamCallRequest) Reset()

func (*StreamCallRequest) String 

func (m *StreamCallRequest) String() string

func (*StreamCallRequest) Validate 

func (this *StreamCallRequest) Validate() error

func (*StreamCallRequest) XXX_DiscardUnknown 

func (m *StreamCallRequest) XXX_DiscardUnknown()

func (*StreamCallRequest) XXX_Marshal 

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

func (*StreamCallRequest) XXX_Merge 

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

func (*StreamCallRequest) XXX_Size 

func (m *StreamCallRequest) XXX_Size() int

func (*StreamCallRequest) XXX_Unmarshal 

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

type StreamCallResponse 

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

func (*StreamCallResponse) Descriptor 

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

func (*StreamCallResponse) GetDevice 

func (m *StreamCallResponse) GetDevice() *Device

func (*StreamCallResponse) GetValue 

func (m *StreamCallResponse) GetValue() *StreamCallValue

func (*StreamCallResponse) ProtoMessage 

func (*StreamCallResponse) ProtoMessage()

func (*StreamCallResponse) Reset 

func (m *StreamCallResponse) Reset()

func (*StreamCallResponse) String 

func (m *StreamCallResponse) String() string

func (*StreamCallResponse) Validate 

func (this *StreamCallResponse) Validate() error

func (*StreamCallResponse) XXX_DiscardUnknown 

func (m *StreamCallResponse) XXX_DiscardUnknown()

func (*StreamCallResponse) XXX_Marshal 

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

func (*StreamCallResponse) XXX_Merge 

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

func (*StreamCallResponse) XXX_Size 

func (m *StreamCallResponse) XXX_Size() int

func (*StreamCallResponse) XXX_Unmarshal 

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

type StreamCallValue 

type StreamCallValue struct {
	// Types that are valid to be assigned to Union:
	//	*StreamCallValue_Value
	//	*StreamCallValue_Config
	//	*StreamCallValue_ConfigAck
	//	*StreamCallValue_Exit
	Union                isStreamCallValue_Union `protobuf_oneof:"union"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*StreamCallValue) Descriptor 

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

func (*StreamCallValue) GetConfig 

func (m *StreamCallValue) GetConfig() *StreamCallConfig

func (*StreamCallValue) GetConfigAck 

func (m *StreamCallValue) GetConfigAck() *StreamCallConfigAck

func (*StreamCallValue) GetExit 

func (m *StreamCallValue) GetExit() *StreamCallExit

func (*StreamCallValue) GetUnion 

func (m *StreamCallValue) GetUnion() isStreamCallValue_Union

func (*StreamCallValue) GetValue 

func (m *StreamCallValue) GetValue() *any.Any

func (*StreamCallValue) ProtoMessage 

func (*StreamCallValue) ProtoMessage()

func (*StreamCallValue) Reset 

func (m *StreamCallValue) Reset()

func (*StreamCallValue) String 

func (m *StreamCallValue) String() string

func (*StreamCallValue) Validate 

func (this *StreamCallValue) Validate() error

func (*StreamCallValue) XXX_DiscardUnknown 

func (m *StreamCallValue) XXX_DiscardUnknown()

func (*StreamCallValue) XXX_Marshal 

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

func (*StreamCallValue) XXX_Merge 

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

func (*StreamCallValue) XXX_OneofWrappers added in v1.0.0 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamCallValue) XXX_Size 

func (m *StreamCallValue) XXX_Size() int

func (*StreamCallValue) XXX_Unmarshal 

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

type StreamCallValue_Config 

type StreamCallValue_Config struct {
	Config *StreamCallConfig `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type StreamCallValue_ConfigAck 

type StreamCallValue_ConfigAck struct {
	ConfigAck *StreamCallConfigAck `protobuf:"bytes,3,opt,name=config_ack,json=configAck,proto3,oneof"`
}

type StreamCallValue_Exit 

type StreamCallValue_Exit struct {
	Exit *StreamCallExit `protobuf:"bytes,4,opt,name=exit,proto3,oneof"`
}

type StreamCallValue_Value 

type StreamCallValue_Value struct {
	Value *any.Any `protobuf:"bytes,1,opt,name=value,proto3,oneof"`
}

type UnaryCallRequest 

type UnaryCallRequest struct {
	Device               *OpDevice         `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Value                *OpUnaryCallValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*UnaryCallRequest) Descriptor 

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

func (*UnaryCallRequest) GetDevice 

func (m *UnaryCallRequest) GetDevice() *OpDevice

func (*UnaryCallRequest) GetValue 

func (m *UnaryCallRequest) GetValue() *OpUnaryCallValue

func (*UnaryCallRequest) ProtoMessage 

func (*UnaryCallRequest) ProtoMessage()

func (*UnaryCallRequest) Reset 

func (m *UnaryCallRequest) Reset()

func (*UnaryCallRequest) String 

func (m *UnaryCallRequest) String() string

func (*UnaryCallRequest) Validate 

func (this *UnaryCallRequest) Validate() error

func (*UnaryCallRequest) XXX_DiscardUnknown 

func (m *UnaryCallRequest) XXX_DiscardUnknown()

func (*UnaryCallRequest) XXX_Marshal 

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

func (*UnaryCallRequest) XXX_Merge 

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

func (*UnaryCallRequest) XXX_Size 

func (m *UnaryCallRequest) XXX_Size() int

func (*UnaryCallRequest) XXX_Unmarshal 

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

type UnaryCallResponse 

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

func (*UnaryCallResponse) Descriptor 

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

func (*UnaryCallResponse) GetDevice 

func (m *UnaryCallResponse) GetDevice() *Device

func (*UnaryCallResponse) GetValue 

func (m *UnaryCallResponse) GetValue() *UnaryCallValue

func (*UnaryCallResponse) ProtoMessage 

func (*UnaryCallResponse) ProtoMessage()

func (*UnaryCallResponse) Reset 

func (m *UnaryCallResponse) Reset()

func (*UnaryCallResponse) String 

func (m *UnaryCallResponse) String() string

func (*UnaryCallResponse) Validate 

func (this *UnaryCallResponse) Validate() error

func (*UnaryCallResponse) XXX_DiscardUnknown 

func (m *UnaryCallResponse) XXX_DiscardUnknown()

func (*UnaryCallResponse) XXX_Marshal 

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

func (*UnaryCallResponse) XXX_Merge 

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

func (*UnaryCallResponse) XXX_Size 

func (m *UnaryCallResponse) XXX_Size() int

func (*UnaryCallResponse) XXX_Unmarshal 

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

type UnaryCallValue 

type UnaryCallValue struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Component            string   `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	Method               string   `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Value                *any.Any `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnaryCallValue) Descriptor 

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

func (*UnaryCallValue) GetComponent 

func (m *UnaryCallValue) GetComponent() string

func (*UnaryCallValue) GetMethod 

func (m *UnaryCallValue) GetMethod() string

func (*UnaryCallValue) GetName 

func (m *UnaryCallValue) GetName() string

func (*UnaryCallValue) GetValue 

func (m *UnaryCallValue) GetValue() *any.Any

func (*UnaryCallValue) ProtoMessage 

func (*UnaryCallValue) ProtoMessage()

func (*UnaryCallValue) Reset 

func (m *UnaryCallValue) Reset()

func (*UnaryCallValue) String 

func (m *UnaryCallValue) String() string

func (*UnaryCallValue) Validate 

func (this *UnaryCallValue) Validate() error

func (*UnaryCallValue) XXX_DiscardUnknown 

func (m *UnaryCallValue) XXX_DiscardUnknown()

func (*UnaryCallValue) XXX_Marshal 

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

func (*UnaryCallValue) XXX_Merge 

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

func (*UnaryCallValue) XXX_Size 

func (m *UnaryCallValue) XXX_Size() int

func (*UnaryCallValue) XXX_Unmarshal 

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

type UnimplementedDevicedServiceServer added in v1.0.0 

type UnimplementedDevicedServiceServer struct {
}

UnimplementedDevicedServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDevicedServiceServer) AddConfigsToDevice added in v1.1.27 

func (*UnimplementedDevicedServiceServer) AddConfigsToDevice(ctx context.Context, req *AddConfigsToDeviceRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) AddFlowsToFlowSet added in v1.1.23 

func (*UnimplementedDevicedServiceServer) AddFlowsToFlowSet(ctx context.Context, req *AddFlowsToFlowSetRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) Connect added in v1.0.0 

func (*UnimplementedDevicedServiceServer) Connect(srv DevicedService_ConnectServer) error

func (*UnimplementedDevicedServiceServer) CreateConfig added in v1.1.27 

func (*UnimplementedDevicedServiceServer) CreateConfig(ctx context.Context, req *CreateConfigRequest) (*CreateConfigResponse, error)

func (*UnimplementedDevicedServiceServer) CreateDevice added in v1.0.0 

func (*UnimplementedDevicedServiceServer) CreateDevice(ctx context.Context, req *CreateDeviceRequest) (*CreateDeviceResponse, error)

func (*UnimplementedDevicedServiceServer) CreateFlowSet added in v1.1.23 

func (*UnimplementedDevicedServiceServer) CreateFlowSet(ctx context.Context, req *CreateFlowSetRequest) (*CreateFlowSetResponse, error)

func (*UnimplementedDevicedServiceServer) DeleteConfig added in v1.1.27 

func (*UnimplementedDevicedServiceServer) DeleteConfig(ctx context.Context, req *DeleteConfigRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) DeleteDevice added in v1.0.0 

func (*UnimplementedDevicedServiceServer) DeleteDevice(ctx context.Context, req *DeleteDeviceRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) DeleteFlowSet added in v1.1.23 

func (*UnimplementedDevicedServiceServer) DeleteFlowSet(ctx context.Context, req *DeleteFlowSetRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) GetConfig added in v1.1.27 

func (*UnimplementedDevicedServiceServer) GetConfig(ctx context.Context, req *GetConfigRequest) (*GetConfigResponse, error)

func (*UnimplementedDevicedServiceServer) GetDescriptor added in v1.1.27 

func (*UnimplementedDevicedServiceServer) GetDescriptor(ctx context.Context, req *GetDescriptorRequest) (*GetDescriptorResponse, error)

func (*UnimplementedDevicedServiceServer) GetDevice added in v1.0.0 

func (*UnimplementedDevicedServiceServer) GetDevice(ctx context.Context, req *GetDeviceRequest) (*GetDeviceResponse, error)

func (*UnimplementedDevicedServiceServer) GetDeviceByModule added in v1.0.0 

func (*UnimplementedDevicedServiceServer) GetDeviceByModule(ctx context.Context, req *GetDeviceByModuleRequest) (*GetDeviceByModuleResponse, error)

func (*UnimplementedDevicedServiceServer) GetFlowSet added in v1.1.23 

func (*UnimplementedDevicedServiceServer) GetFlowSet(ctx context.Context, req *GetFlowSetRequest) (*GetFlowSetResponse, error)

func (*UnimplementedDevicedServiceServer) GetObject added in v1.0.0 

func (*UnimplementedDevicedServiceServer) GetObject(ctx context.Context, req *GetObjectRequest) (*GetObjectResponse, error)

func (*UnimplementedDevicedServiceServer) GetObjectContent added in v1.0.0 

func (*UnimplementedDevicedServiceServer) GetObjectContent(ctx context.Context, req *GetObjectContentRequest) (*GetObjectContentResponse, error)

func (*UnimplementedDevicedServiceServer) GetObjectStreamingContent added in v1.0.0 

func (*UnimplementedDevicedServiceServer) GetObjectStreamingContent(req *GetObjectStreamingContentRequest, srv DevicedService_GetObjectStreamingContentServer) error

func (*UnimplementedDevicedServiceServer) Heartbeat added in v1.0.0 

func (*UnimplementedDevicedServiceServer) Heartbeat(ctx context.Context, req *HeartbeatRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) ListConfigs added in v1.1.27 

func (*UnimplementedDevicedServiceServer) ListConfigs(ctx context.Context, req *ListConfigsRequest) (*ListConfigsResponse, error)

func (*UnimplementedDevicedServiceServer) ListConfigsByDevice added in v1.1.27 

func (*UnimplementedDevicedServiceServer) ListConfigsByDevice(ctx context.Context, req *ListConfigsByDeviceRequest) (*ListConfigsByDeviceResponse, error)

func (*UnimplementedDevicedServiceServer) ListDevices added in v1.0.0 

func (*UnimplementedDevicedServiceServer) ListDevices(ctx context.Context, req *ListDevicesRequest) (*ListDevicesResponse, error)

func (*UnimplementedDevicedServiceServer) ListFlowSets added in v1.1.23 

func (*UnimplementedDevicedServiceServer) ListFlowSets(ctx context.Context, req *ListFlowSetsRequest) (*ListFlowSetsResponse, error)

func (*UnimplementedDevicedServiceServer) ListObjects added in v1.0.0 

func (*UnimplementedDevicedServiceServer) ListObjects(ctx context.Context, req *ListObjectsRequest) (*ListObjectsResponse, error)

func (*UnimplementedDevicedServiceServer) PatchConfig added in v1.1.27 

func (*UnimplementedDevicedServiceServer) PatchConfig(ctx context.Context, req *PatchConfigRequest) (*PatchConfigResponse, error)

func (*UnimplementedDevicedServiceServer) PatchDevice added in v1.0.0 

func (*UnimplementedDevicedServiceServer) PatchDevice(ctx context.Context, req *PatchDeviceRequest) (*PatchDeviceResponse, error)

func (*UnimplementedDevicedServiceServer) PatchFlowSet added in v1.1.23 

func (*UnimplementedDevicedServiceServer) PatchFlowSet(ctx context.Context, req *PatchFlowSetRequest) (*PatchFlowSetResponse, error)

func (*UnimplementedDevicedServiceServer) PullFrameFromFlow added in v1.0.0 

func (*UnimplementedDevicedServiceServer) PullFrameFromFlow(req *PullFrameFromFlowRequest, srv DevicedService_PullFrameFromFlowServer) error

func (*UnimplementedDevicedServiceServer) PullFrameFromFlowSet added in v1.1.23 

func (*UnimplementedDevicedServiceServer) PullFrameFromFlowSet(req *PullFrameFromFlowSetRequest, srv DevicedService_PullFrameFromFlowSetServer) error

func (*UnimplementedDevicedServiceServer) PushFrameToFlow added in v1.0.0 

func (*UnimplementedDevicedServiceServer) PushFrameToFlow(srv DevicedService_PushFrameToFlowServer) error

func (*UnimplementedDevicedServiceServer) PutObject added in v1.0.0 

func (*UnimplementedDevicedServiceServer) PutObject(ctx context.Context, req *PutObjectRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) PutObjectStreaming added in v1.1.16 

func (*UnimplementedDevicedServiceServer) PutObjectStreaming(srv DevicedService_PutObjectStreamingServer) error

func (*UnimplementedDevicedServiceServer) QueryFramesFromFlow added in v1.0.0 

func (*UnimplementedDevicedServiceServer) QueryFramesFromFlow(ctx context.Context, req *QueryFramesFromFlowRequest) (*QueryFramesFromFlowResponse, error)

func (*UnimplementedDevicedServiceServer) RemoveConfigsFromDevice added in v1.1.27 

func (*UnimplementedDevicedServiceServer) RemoveConfigsFromDevice(ctx context.Context, req *RemoveConfigsFromDeviceRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) RemoveFlowsFromFlowSet added in v1.1.23 

func (*UnimplementedDevicedServiceServer) RemoveFlowsFromFlowSet(ctx context.Context, req *RemoveFlowsFromFlowSetRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) RemoveObject added in v1.0.0 

func (*UnimplementedDevicedServiceServer) RemoveObject(ctx context.Context, req *RemoveObjectRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) RenameObject added in v1.0.0 

func (*UnimplementedDevicedServiceServer) RenameObject(ctx context.Context, req *RenameObjectRequest) (*empty.Empty, error)

func (*UnimplementedDevicedServiceServer) ShowDevice added in v1.0.0 

func (*UnimplementedDevicedServiceServer) ShowDevice(ctx context.Context, req *empty.Empty) (*ShowDeviceResponse, error)

func (*UnimplementedDevicedServiceServer) StreamCall added in v1.0.0 

func (*UnimplementedDevicedServiceServer) StreamCall(srv DevicedService_StreamCallServer) error

func (*UnimplementedDevicedServiceServer) UnaryCall added in v1.0.0 

func (*UnimplementedDevicedServiceServer) UnaryCall(ctx context.Context, req *UnaryCallRequest) (*UnaryCallResponse, error)

func (*UnimplementedDevicedServiceServer) UploadDescriptor added in v1.1.27 

func (*UnimplementedDevicedServiceServer) UploadDescriptor(ctx context.Context, req *UploadDescriptorRequest) (*UploadDescriptorResponse, error)

type UploadDescriptorRequest added in v1.1.27 

type UploadDescriptorRequest struct {
	Descriptor_          *OpDescriptor `protobuf:"bytes,1,opt,name=descriptor,proto3" json:"descriptor,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*UploadDescriptorRequest) Descriptor added in v1.1.27 

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

func (*UploadDescriptorRequest) GetDescriptor_ added in v1.1.27 

func (m *UploadDescriptorRequest) GetDescriptor_() *OpDescriptor

func (*UploadDescriptorRequest) ProtoMessage added in v1.1.27 

func (*UploadDescriptorRequest) ProtoMessage()

func (*UploadDescriptorRequest) Reset added in v1.1.27 

func (m *UploadDescriptorRequest) Reset()

func (*UploadDescriptorRequest) String added in v1.1.27 

func (m *UploadDescriptorRequest) String() string

func (*UploadDescriptorRequest) Validate added in v1.1.27 

func (this *UploadDescriptorRequest) Validate() error

func (*UploadDescriptorRequest) XXX_DiscardUnknown added in v1.1.27 

func (m *UploadDescriptorRequest) XXX_DiscardUnknown()

func (*UploadDescriptorRequest) XXX_Marshal added in v1.1.27 

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

func (*UploadDescriptorRequest) XXX_Merge added in v1.1.27 

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

func (*UploadDescriptorRequest) XXX_Size added in v1.1.27 

func (m *UploadDescriptorRequest) XXX_Size() int

func (*UploadDescriptorRequest) XXX_Unmarshal added in v1.1.27 

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

type UploadDescriptorResponse added in v1.1.27 

type UploadDescriptorResponse struct {
	Descriptor_          *Descriptor `protobuf:"bytes,1,opt,name=descriptor,proto3" json:"descriptor,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*UploadDescriptorResponse) Descriptor added in v1.1.27 

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

func (*UploadDescriptorResponse) GetDescriptor_ added in v1.1.27 

func (m *UploadDescriptorResponse) GetDescriptor_() *Descriptor

func (*UploadDescriptorResponse) ProtoMessage added in v1.1.27 

func (*UploadDescriptorResponse) ProtoMessage()

func (*UploadDescriptorResponse) Reset added in v1.1.27 

func (m *UploadDescriptorResponse) Reset()

func (*UploadDescriptorResponse) String added in v1.1.27 

func (m *UploadDescriptorResponse) String() string

func (*UploadDescriptorResponse) Validate added in v1.1.27 

func (this *UploadDescriptorResponse) Validate() error

func (*UploadDescriptorResponse) XXX_DiscardUnknown added in v1.1.27 

func (m *UploadDescriptorResponse) XXX_DiscardUnknown()

func (*UploadDescriptorResponse) XXX_Marshal added in v1.1.27 

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

func (*UploadDescriptorResponse) XXX_Merge added in v1.1.27 

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

func (*UploadDescriptorResponse) XXX_Size added in v1.1.27 

func (m *UploadDescriptorResponse) XXX_Size() int

func (*UploadDescriptorResponse) XXX_Unmarshal added in v1.1.27 

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