proto

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Oct 19, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_plugin_proto protoreflect.FileDescriptor

Functions

func RegisterPluginServer 

func RegisterPluginServer(s *grpc.Server, srv PluginServer)

Types

type Action 

type Action struct {
	Identity   string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	InstanceId int32  `protobuf:"varint,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Attributes []byte `protobuf:"bytes,3,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*Action) Descriptor deprecated 

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetAttributes 

func (x *Action) GetAttributes() []byte

func (*Action) GetIdentity 

func (x *Action) GetIdentity() string

func (*Action) GetInstanceId 

func (x *Action) GetInstanceId() int32

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect 

func (x *Action) ProtoReflect() protoreflect.Message

func (*Action) Reset 

func (x *Action) Reset()

func (*Action) String 

func (x *Action) String() string

type Device 

type Device struct {
	Identity     string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	Model        string `protobuf:"bytes,2,opt,name=model,proto3" json:"model,omitempty"`
	Manufacturer string `protobuf:"bytes,3,opt,name=manufacturer,proto3" json:"manufacturer,omitempty"`
	// contains filtered or unexported fields
}

func (*Device) Descriptor deprecated 

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

Deprecated: Use Device.ProtoReflect.Descriptor instead.

func (*Device) GetIdentity 

func (x *Device) GetIdentity() string

func (*Device) GetManufacturer 

func (x *Device) GetManufacturer() string

func (*Device) GetModel 

func (x *Device) GetModel() string

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) ProtoReflect 

func (x *Device) ProtoReflect() protoreflect.Message

func (*Device) Reset 

func (x *Device) Reset()

func (*Device) String 

func (x *Device) String() string

type Empty 

type Empty struct {
	// contains filtered or unexported fields
}

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type ExecuteReq 

type ExecuteReq struct {
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	Cmd      string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteReq) Descriptor deprecated 

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

Deprecated: Use ExecuteReq.ProtoReflect.Descriptor instead.

func (*ExecuteReq) GetCmd 

func (x *ExecuteReq) GetCmd() string

func (*ExecuteReq) GetData 

func (x *ExecuteReq) GetData() []byte

func (*ExecuteReq) GetIdentity 

func (x *ExecuteReq) GetIdentity() string

func (*ExecuteReq) ProtoMessage 

func (*ExecuteReq) ProtoMessage()

func (*ExecuteReq) ProtoReflect 

func (x *ExecuteReq) ProtoReflect() protoreflect.Message

func (*ExecuteReq) Reset 

func (x *ExecuteReq) Reset()

func (*ExecuteReq) String 

func (x *ExecuteReq) String() string

type ExecuteResp 

type ExecuteResp struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Data    []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteResp) Descriptor deprecated 

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

Deprecated: Use ExecuteResp.ProtoReflect.Descriptor instead.

func (*ExecuteResp) GetData 

func (x *ExecuteResp) GetData() []byte

func (*ExecuteResp) GetError 

func (x *ExecuteResp) GetError() string

func (*ExecuteResp) GetSuccess 

func (x *ExecuteResp) GetSuccess() bool

func (*ExecuteResp) ProtoMessage 

func (*ExecuteResp) ProtoMessage()

func (*ExecuteResp) ProtoReflect 

func (x *ExecuteResp) ProtoReflect() protoreflect.Message

func (*ExecuteResp) Reset 

func (x *ExecuteResp) Reset()

func (*ExecuteResp) String 

func (x *ExecuteResp) String() string

type GetAttributesReq 

type GetAttributesReq struct {
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAttributesReq) Descriptor deprecated 

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

Deprecated: Use GetAttributesReq.ProtoReflect.Descriptor instead.

func (*GetAttributesReq) GetIdentity 

func (x *GetAttributesReq) GetIdentity() string

func (*GetAttributesReq) ProtoMessage 

func (*GetAttributesReq) ProtoMessage()

func (*GetAttributesReq) ProtoReflect 

func (x *GetAttributesReq) ProtoReflect() protoreflect.Message

func (*GetAttributesReq) Reset 

func (x *GetAttributesReq) Reset()

func (*GetAttributesReq) String 

func (x *GetAttributesReq) String() string

type GetAttributesResp 

type GetAttributesResp struct {
	Success   bool        `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error     string      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Instances []*Instance `protobuf:"bytes,3,rep,name=instances,proto3" json:"instances,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAttributesResp) Descriptor deprecated 

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

Deprecated: Use GetAttributesResp.ProtoReflect.Descriptor instead.

func (*GetAttributesResp) GetError 

func (x *GetAttributesResp) GetError() string

func (*GetAttributesResp) GetInstances 

func (x *GetAttributesResp) GetInstances() []*Instance

func (*GetAttributesResp) GetSuccess 

func (x *GetAttributesResp) GetSuccess() bool

func (*GetAttributesResp) ProtoMessage 

func (*GetAttributesResp) ProtoMessage()

func (*GetAttributesResp) ProtoReflect 

func (x *GetAttributesResp) ProtoReflect() protoreflect.Message

func (*GetAttributesResp) Reset 

func (x *GetAttributesResp) Reset()

func (*GetAttributesResp) String 

func (x *GetAttributesResp) String() string

type HealthCheckReq 

type HealthCheckReq struct {
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckReq) Descriptor deprecated 

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

Deprecated: Use HealthCheckReq.ProtoReflect.Descriptor instead.

func (*HealthCheckReq) GetIdentity 

func (x *HealthCheckReq) GetIdentity() string

func (*HealthCheckReq) ProtoMessage 

func (*HealthCheckReq) ProtoMessage()

func (*HealthCheckReq) ProtoReflect 

func (x *HealthCheckReq) ProtoReflect() protoreflect.Message

func (*HealthCheckReq) Reset 

func (x *HealthCheckReq) Reset()

func (*HealthCheckReq) String 

func (x *HealthCheckReq) String() string

type HealthCheckResp 

type HealthCheckResp struct {
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	Online   bool   `protobuf:"varint,2,opt,name=online,proto3" json:"online,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResp) Descriptor deprecated 

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

Deprecated: Use HealthCheckResp.ProtoReflect.Descriptor instead.

func (*HealthCheckResp) GetIdentity 

func (x *HealthCheckResp) GetIdentity() string

func (*HealthCheckResp) GetOnline 

func (x *HealthCheckResp) GetOnline() bool

func (*HealthCheckResp) ProtoMessage 

func (*HealthCheckResp) ProtoMessage()

func (*HealthCheckResp) ProtoReflect 

func (x *HealthCheckResp) ProtoReflect() protoreflect.Message

func (*HealthCheckResp) Reset 

func (x *HealthCheckResp) Reset()

func (*HealthCheckResp) String 

func (x *HealthCheckResp) String() string

type Instance 

type Instance struct {
	Identity   string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	InstanceId int32  `protobuf:"varint,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Attributes []byte `protobuf:"bytes,3,opt,name=attributes,proto3" json:"attributes,omitempty"`
	Type       string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Instance) Descriptor deprecated 

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

Deprecated: Use Instance.ProtoReflect.Descriptor instead.

func (*Instance) GetAttributes 

func (x *Instance) GetAttributes() []byte

func (*Instance) GetIdentity 

func (x *Instance) GetIdentity() string

func (*Instance) GetInstanceId 

func (x *Instance) GetInstanceId() int32

func (*Instance) GetType 

func (x *Instance) GetType() string

func (*Instance) ProtoMessage 

func (*Instance) ProtoMessage()

func (*Instance) ProtoReflect 

func (x *Instance) ProtoReflect() protoreflect.Message

func (*Instance) Reset 

func (x *Instance) Reset()

func (*Instance) String 

func (x *Instance) String() string

type PluginClient 

type PluginClient interface {
	Discover(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Plugin_DiscoverClient, error)
	StateChange(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Plugin_StateChangeClient, error)
	HealthCheck(ctx context.Context, in *HealthCheckReq, opts ...grpc.CallOption) (*HealthCheckResp, error)
	GetAttributes(ctx context.Context, in *GetAttributesReq, opts ...grpc.CallOption) (*GetAttributesResp, error)
	SetAttributes(ctx context.Context, in *SetAttributesReq, opts ...grpc.CallOption) (*SetAttributesResp, error)
}

PluginClient is the client API for Plugin service.

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

func NewPluginClient 

func NewPluginClient(cc grpc.ClientConnInterface) PluginClient

type PluginServer 

type PluginServer interface {
	Discover(*Empty, Plugin_DiscoverServer) error
	StateChange(*Empty, Plugin_StateChangeServer) error
	HealthCheck(context.Context, *HealthCheckReq) (*HealthCheckResp, error)
	GetAttributes(context.Context, *GetAttributesReq) (*GetAttributesResp, error)
	SetAttributes(context.Context, *SetAttributesReq) (*SetAttributesResp, error)
}

PluginServer is the server API for Plugin service.

type Plugin_DiscoverClient 

type Plugin_DiscoverClient interface {
	Recv() (*Device, error)
	grpc.ClientStream
}

type Plugin_DiscoverServer 

type Plugin_DiscoverServer interface {
	Send(*Device) error
	grpc.ServerStream
}

type Plugin_StateChangeClient 

type Plugin_StateChangeClient interface {
	Recv() (*State, error)
	grpc.ClientStream
}

type Plugin_StateChangeServer 

type Plugin_StateChangeServer interface {
	Send(*State) error
	grpc.ServerStream
}

type SetAttributesReq 

type SetAttributesReq struct {
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	Data     []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SetAttributesReq) Descriptor deprecated 

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

Deprecated: Use SetAttributesReq.ProtoReflect.Descriptor instead.

func (*SetAttributesReq) GetData 

func (x *SetAttributesReq) GetData() []byte

func (*SetAttributesReq) GetIdentity 

func (x *SetAttributesReq) GetIdentity() string

func (*SetAttributesReq) ProtoMessage 

func (*SetAttributesReq) ProtoMessage()

func (*SetAttributesReq) ProtoReflect 

func (x *SetAttributesReq) ProtoReflect() protoreflect.Message

func (*SetAttributesReq) Reset 

func (x *SetAttributesReq) Reset()

func (*SetAttributesReq) String 

func (x *SetAttributesReq) String() string

type SetAttributesResp 

type SetAttributesResp struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*SetAttributesResp) Descriptor deprecated 

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

Deprecated: Use SetAttributesResp.ProtoReflect.Descriptor instead.

func (*SetAttributesResp) GetError 

func (x *SetAttributesResp) GetError() string

func (*SetAttributesResp) GetSuccess 

func (x *SetAttributesResp) GetSuccess() bool

func (*SetAttributesResp) ProtoMessage 

func (*SetAttributesResp) ProtoMessage()

func (*SetAttributesResp) ProtoReflect 

func (x *SetAttributesResp) ProtoReflect() protoreflect.Message

func (*SetAttributesResp) Reset 

func (x *SetAttributesResp) Reset()

func (*SetAttributesResp) String 

func (x *SetAttributesResp) String() string

type State 

type State struct {
	Identity   string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	InstanceId int32  `protobuf:"varint,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Attributes []byte `protobuf:"bytes,3,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*State) Descriptor deprecated 

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

Deprecated: Use State.ProtoReflect.Descriptor instead.

func (*State) GetAttributes 

func (x *State) GetAttributes() []byte

func (*State) GetIdentity 

func (x *State) GetIdentity() string

func (*State) GetInstanceId 

func (x *State) GetInstanceId() int32

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) ProtoReflect 

func (x *State) ProtoReflect() protoreflect.Message

func (*State) Reset 

func (x *State) Reset()

func (*State) String 

func (x *State) String() string

type UnimplementedPluginServer 

type UnimplementedPluginServer struct {
}

UnimplementedPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedPluginServer) Discover 

func (*UnimplementedPluginServer) Discover(*Empty, Plugin_DiscoverServer) error

func (*UnimplementedPluginServer) GetAttributes 

func (*UnimplementedPluginServer) GetAttributes(context.Context, *GetAttributesReq) (*GetAttributesResp, error)

func (*UnimplementedPluginServer) HealthCheck 

func (*UnimplementedPluginServer) HealthCheck(context.Context, *HealthCheckReq) (*HealthCheckResp, error)

func (*UnimplementedPluginServer) SetAttributes 

func (*UnimplementedPluginServer) SetAttributes(context.Context, *SetAttributesReq) (*SetAttributesResp, error)

func (*UnimplementedPluginServer) StateChange 

func (*UnimplementedPluginServer) StateChange(*Empty, Plugin_StateChangeServer) 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.