ai_metathings_service_device

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: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDeviceServiceServer 

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

Types

type DeviceServiceClient 

type DeviceServiceClient interface {
	IssueModuleToken(ctx context.Context, in *IssueModuleTokenRequest, opts ...grpc.CallOption) (*IssueModuleTokenResponse, error)
	ShowModule(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ShowModuleResponse, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	PushFrameToFlow(ctx context.Context, opts ...grpc.CallOption) (DeviceService_PushFrameToFlowClient, error)
	PutObject(ctx context.Context, in *PutObjectRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	PutObjectStreaming(ctx context.Context, opts ...grpc.CallOption) (DeviceService_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) (*GetObjectStreamingContentResponse, error)
	ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (*ListObjectsResponse, error)
}

DeviceServiceClient is the client API for DeviceService service.

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

func NewDeviceServiceClient 

func NewDeviceServiceClient(cc *grpc.ClientConn) DeviceServiceClient

type DeviceServiceServer 

type DeviceServiceServer interface {
	IssueModuleToken(context.Context, *IssueModuleTokenRequest) (*IssueModuleTokenResponse, error)
	ShowModule(context.Context, *empty.Empty) (*ShowModuleResponse, error)
	Heartbeat(context.Context, *HeartbeatRequest) (*empty.Empty, error)
	PushFrameToFlow(DeviceService_PushFrameToFlowServer) error
	PutObject(context.Context, *PutObjectRequest) (*empty.Empty, error)
	PutObjectStreaming(DeviceService_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(context.Context, *GetObjectStreamingContentRequest) (*GetObjectStreamingContentResponse, error)
	ListObjects(context.Context, *ListObjectsRequest) (*ListObjectsResponse, error)
}

DeviceServiceServer is the server API for DeviceService service.

type DeviceService_PushFrameToFlowClient 

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

type DeviceService_PushFrameToFlowServer 

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

type DeviceService_PutObjectStreamingClient added in v1.1.16 

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

type DeviceService_PutObjectStreamingServer added in v1.1.16 

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

type GetObjectContentRequest 

type GetObjectContentRequest struct {
	Object               *deviced.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() *deviced.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               *deviced.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() *deviced.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               *deviced.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() *deviced.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               *deviced.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() *deviced.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 {
	Module               *deviced.OpModule `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*HeartbeatRequest) Descriptor 

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

func (*HeartbeatRequest) GetModule 

func (m *HeartbeatRequest) GetModule() *deviced.OpModule

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 IssueModuleTokenRequest 

type IssueModuleTokenRequest struct {
	Credential           *identityd2.OpCredential `protobuf:"bytes,1,opt,name=credential,proto3" json:"credential,omitempty"`
	Timestamp            *timestamp.Timestamp     `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Nonce                *wrappers.Int64Value     `protobuf:"bytes,3,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Hmac                 *wrappers.StringValue    `protobuf:"bytes,4,opt,name=hmac,proto3" json:"hmac,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*IssueModuleTokenRequest) Descriptor 

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

func (*IssueModuleTokenRequest) GetCredential 

func (m *IssueModuleTokenRequest) GetCredential() *identityd2.OpCredential

func (*IssueModuleTokenRequest) GetHmac 

func (m *IssueModuleTokenRequest) GetHmac() *wrappers.StringValue

func (*IssueModuleTokenRequest) GetNonce 

func (m *IssueModuleTokenRequest) GetNonce() *wrappers.Int64Value

func (*IssueModuleTokenRequest) GetTimestamp 

func (m *IssueModuleTokenRequest) GetTimestamp() *timestamp.Timestamp

func (*IssueModuleTokenRequest) ProtoMessage 

func (*IssueModuleTokenRequest) ProtoMessage()

func (*IssueModuleTokenRequest) Reset 

func (m *IssueModuleTokenRequest) Reset()

func (*IssueModuleTokenRequest) String 

func (m *IssueModuleTokenRequest) String() string

func (*IssueModuleTokenRequest) Validate 

func (this *IssueModuleTokenRequest) Validate() error

func (*IssueModuleTokenRequest) XXX_DiscardUnknown 

func (m *IssueModuleTokenRequest) XXX_DiscardUnknown()

func (*IssueModuleTokenRequest) XXX_Marshal 

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

func (*IssueModuleTokenRequest) XXX_Merge 

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

func (*IssueModuleTokenRequest) XXX_Size 

func (m *IssueModuleTokenRequest) XXX_Size() int

func (*IssueModuleTokenRequest) XXX_Unmarshal 

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

type IssueModuleTokenResponse 

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

func (*IssueModuleTokenResponse) Descriptor 

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

func (*IssueModuleTokenResponse) GetToken 

func (m *IssueModuleTokenResponse) GetToken() *identityd2.Token

func (*IssueModuleTokenResponse) ProtoMessage 

func (*IssueModuleTokenResponse) ProtoMessage()

func (*IssueModuleTokenResponse) Reset 

func (m *IssueModuleTokenResponse) Reset()

func (*IssueModuleTokenResponse) String 

func (m *IssueModuleTokenResponse) String() string

func (*IssueModuleTokenResponse) Validate 

func (this *IssueModuleTokenResponse) Validate() error

func (*IssueModuleTokenResponse) XXX_DiscardUnknown 

func (m *IssueModuleTokenResponse) XXX_DiscardUnknown()

func (*IssueModuleTokenResponse) XXX_Marshal 

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

func (*IssueModuleTokenResponse) XXX_Merge 

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

func (*IssueModuleTokenResponse) XXX_Size 

func (m *IssueModuleTokenResponse) XXX_Size() int

func (*IssueModuleTokenResponse) XXX_Unmarshal 

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

type ListObjectsRequest 

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

func (*ListObjectsRequest) Descriptor 

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

func (*ListObjectsRequest) GetObject 

func (m *ListObjectsRequest) GetObject() *deviced.OpObject

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              []*deviced.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() []*deviced.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 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_Ping_
	//	*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() *deviced.OpFrame

func (*PushFrameToFlowRequest) GetId 

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

func (*PushFrameToFlowRequest) GetPing added in v1.0.0 

func (m *PushFrameToFlowRequest) GetPing() *PushFrameToFlowRequest_Ping

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 {
	Flow                 *deviced.OpFlow     `protobuf:"bytes,1,opt,name=flow,proto3" json:"flow,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) GetFlow 

func (m *PushFrameToFlowRequest_Config) GetFlow() *deviced.OpFlow

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 *deviced.OpFrame `protobuf:"bytes,4,opt,name=frame,proto3,oneof"`
}

type PushFrameToFlowRequest_Ping added in v1.0.0 

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

func (*PushFrameToFlowRequest_Ping) Descriptor added in v1.0.0 

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

func (*PushFrameToFlowRequest_Ping) ProtoMessage added in v1.0.0 

func (*PushFrameToFlowRequest_Ping) ProtoMessage()

func (*PushFrameToFlowRequest_Ping) Reset added in v1.0.0 

func (m *PushFrameToFlowRequest_Ping) Reset()

func (*PushFrameToFlowRequest_Ping) String added in v1.0.0 

func (m *PushFrameToFlowRequest_Ping) String() string

func (*PushFrameToFlowRequest_Ping) Validate added in v1.0.0 

func (this *PushFrameToFlowRequest_Ping) Validate() error

func (*PushFrameToFlowRequest_Ping) XXX_DiscardUnknown added in v1.0.0 

func (m *PushFrameToFlowRequest_Ping) XXX_DiscardUnknown()

func (*PushFrameToFlowRequest_Ping) XXX_Marshal added in v1.0.0 

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

func (*PushFrameToFlowRequest_Ping) XXX_Merge added in v1.0.0 

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

func (*PushFrameToFlowRequest_Ping) XXX_Size added in v1.0.0 

func (m *PushFrameToFlowRequest_Ping) XXX_Size() int

func (*PushFrameToFlowRequest_Ping) XXX_Unmarshal added in v1.0.0 

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

type PushFrameToFlowRequest_Ping_ added in v1.0.0 

type PushFrameToFlowRequest_Ping_ struct {
	Ping *PushFrameToFlowRequest_Ping `protobuf:"bytes,3,opt,name=ping,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_Config_
	//	*PushFrameToFlowResponse_Pong_
	//	*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) GetConfig added in v1.0.0 

func (m *PushFrameToFlowResponse) GetConfig() *PushFrameToFlowResponse_Config

func (*PushFrameToFlowResponse) GetId 

func (m *PushFrameToFlowResponse) GetId() string

func (*PushFrameToFlowResponse) GetPong added in v1.0.0 

func (m *PushFrameToFlowResponse) GetPong() *PushFrameToFlowResponse_Pong

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,4,opt,name=ack,proto3,oneof"`
}

type PushFrameToFlowResponse_Config added in v1.0.0 

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

func (*PushFrameToFlowResponse_Config) Descriptor added in v1.0.0 

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

func (*PushFrameToFlowResponse_Config) GetSession added in v1.0.0 

func (m *PushFrameToFlowResponse_Config) GetSession() string

func (*PushFrameToFlowResponse_Config) ProtoMessage added in v1.0.0 

func (*PushFrameToFlowResponse_Config) ProtoMessage()

func (*PushFrameToFlowResponse_Config) Reset added in v1.0.0 

func (m *PushFrameToFlowResponse_Config) Reset()

func (*PushFrameToFlowResponse_Config) String added in v1.0.0 

func (m *PushFrameToFlowResponse_Config) String() string

func (*PushFrameToFlowResponse_Config) Validate added in v1.0.0 

func (this *PushFrameToFlowResponse_Config) Validate() error

func (*PushFrameToFlowResponse_Config) XXX_DiscardUnknown added in v1.0.0 

func (m *PushFrameToFlowResponse_Config) XXX_DiscardUnknown()

func (*PushFrameToFlowResponse_Config) XXX_Marshal added in v1.0.0 

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

func (*PushFrameToFlowResponse_Config) XXX_Merge added in v1.0.0 

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

func (*PushFrameToFlowResponse_Config) XXX_Size added in v1.0.0 

func (m *PushFrameToFlowResponse_Config) XXX_Size() int

func (*PushFrameToFlowResponse_Config) XXX_Unmarshal added in v1.0.0 

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

type PushFrameToFlowResponse_Config_ added in v1.0.0 

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

type PushFrameToFlowResponse_Pong added in v1.0.0 

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

func (*PushFrameToFlowResponse_Pong) Descriptor added in v1.0.0 

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

func (*PushFrameToFlowResponse_Pong) ProtoMessage added in v1.0.0 

func (*PushFrameToFlowResponse_Pong) ProtoMessage()

func (*PushFrameToFlowResponse_Pong) Reset added in v1.0.0 

func (m *PushFrameToFlowResponse_Pong) Reset()

func (*PushFrameToFlowResponse_Pong) String added in v1.0.0 

func (m *PushFrameToFlowResponse_Pong) String() string

func (*PushFrameToFlowResponse_Pong) Validate added in v1.0.0 

func (this *PushFrameToFlowResponse_Pong) Validate() error

func (*PushFrameToFlowResponse_Pong) XXX_DiscardUnknown added in v1.0.0 

func (m *PushFrameToFlowResponse_Pong) XXX_DiscardUnknown()

func (*PushFrameToFlowResponse_Pong) XXX_Marshal added in v1.0.0 

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

func (*PushFrameToFlowResponse_Pong) XXX_Merge added in v1.0.0 

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

func (*PushFrameToFlowResponse_Pong) XXX_Size added in v1.0.0 

func (m *PushFrameToFlowResponse_Pong) XXX_Size() int

func (*PushFrameToFlowResponse_Pong) XXX_Unmarshal added in v1.0.0 

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

type PushFrameToFlowResponse_Pong_ added in v1.0.0 

type PushFrameToFlowResponse_Pong_ struct {
	Pong *PushFrameToFlowResponse_Pong `protobuf:"bytes,3,opt,name=pong,proto3,oneof"`
}

type PutObjectRequest 

type PutObjectRequest struct {
	Object               *deviced.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() *deviced.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
	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) GetChunks added in v1.1.16 

func (m *PutObjectStreamingRequest) GetChunks() *deviced.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_Chunks added in v1.1.16 

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

type PutObjectStreamingRequest_Metadata added in v1.1.16 

type PutObjectStreamingRequest_Metadata struct {
	Object               *deviced.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() *deviced.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
	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) GetChunks added in v1.1.16 

func (m *PutObjectStreamingResponse) GetChunks() *deviced.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_Chunks added in v1.1.16 

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

type RemoveObjectRequest 

type RemoveObjectRequest struct {
	Object               *deviced.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() *deviced.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               *deviced.OpObject `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Destination          *deviced.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() *deviced.OpObject

func (*RenameObjectRequest) GetSource 

func (m *RenameObjectRequest) GetSource() *deviced.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 ShowModuleResponse 

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

func (*ShowModuleResponse) Descriptor 

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

func (*ShowModuleResponse) GetModule 

func (m *ShowModuleResponse) GetModule() *deviced.Module

func (*ShowModuleResponse) ProtoMessage 

func (*ShowModuleResponse) ProtoMessage()

func (*ShowModuleResponse) Reset 

func (m *ShowModuleResponse) Reset()

func (*ShowModuleResponse) String 

func (m *ShowModuleResponse) String() string

func (*ShowModuleResponse) Validate 

func (this *ShowModuleResponse) Validate() error

func (*ShowModuleResponse) XXX_DiscardUnknown 

func (m *ShowModuleResponse) XXX_DiscardUnknown()

func (*ShowModuleResponse) XXX_Marshal 

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

func (*ShowModuleResponse) XXX_Merge 

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

func (*ShowModuleResponse) XXX_Size 

func (m *ShowModuleResponse) XXX_Size() int

func (*ShowModuleResponse) XXX_Unmarshal 

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

type UnimplementedDeviceServiceServer added in v1.0.0 

type UnimplementedDeviceServiceServer struct {
}

UnimplementedDeviceServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDeviceServiceServer) GetObject added in v1.0.0 

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

func (*UnimplementedDeviceServiceServer) GetObjectContent added in v1.0.0 

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

func (*UnimplementedDeviceServiceServer) GetObjectStreamingContent added in v1.0.0 

func (*UnimplementedDeviceServiceServer) GetObjectStreamingContent(ctx context.Context, req *GetObjectStreamingContentRequest) (*GetObjectStreamingContentResponse, error)

func (*UnimplementedDeviceServiceServer) Heartbeat added in v1.0.0 

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

func (*UnimplementedDeviceServiceServer) IssueModuleToken added in v1.0.0 

func (*UnimplementedDeviceServiceServer) IssueModuleToken(ctx context.Context, req *IssueModuleTokenRequest) (*IssueModuleTokenResponse, error)

func (*UnimplementedDeviceServiceServer) ListObjects added in v1.0.0 

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

func (*UnimplementedDeviceServiceServer) PushFrameToFlow added in v1.0.0 

func (*UnimplementedDeviceServiceServer) PushFrameToFlow(srv DeviceService_PushFrameToFlowServer) error

func (*UnimplementedDeviceServiceServer) PutObject added in v1.0.0 

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

func (*UnimplementedDeviceServiceServer) PutObjectStreaming added in v1.1.16 

func (*UnimplementedDeviceServiceServer) PutObjectStreaming(srv DeviceService_PutObjectStreamingServer) error

func (*UnimplementedDeviceServiceServer) RemoveObject added in v1.0.0 

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

func (*UnimplementedDeviceServiceServer) RenameObject added in v1.0.0 

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

func (*UnimplementedDeviceServiceServer) ShowModule added in v1.0.0 

func (*UnimplementedDeviceServiceServer) ShowModule(ctx context.Context, req *empty.Empty) (*ShowModuleResponse, 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.