Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterAdapterServer(s grpc.ServiceRegistrar, srv AdapterServer)
- type AdapterClient
- type AdapterServer
- type AddResourceResponse
- func (*AddResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AddResourceResponse) GetSuccess() bool
- func (*AddResourceResponse) ProtoMessage()
- func (x *AddResourceResponse) ProtoReflect() protoreflect.Message
- func (x *AddResourceResponse) Reset()
- func (x *AddResourceResponse) String() string
- type ClearStateRequest
- type ClearStateResponse
- func (*ClearStateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ClearStateResponse) GetResponse() string
- func (*ClearStateResponse) ProtoMessage()
- func (x *ClearStateResponse) ProtoReflect() protoreflect.Message
- func (x *ClearStateResponse) Reset()
- func (x *ClearStateResponse) String() string
- type RemoveResourceResponse
- func (*RemoveResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveResourceResponse) GetSuccess() bool
- func (*RemoveResourceResponse) ProtoMessage()
- func (x *RemoveResourceResponse) ProtoReflect() protoreflect.Message
- func (x *RemoveResourceResponse) Reset()
- func (x *RemoveResourceResponse) String() string
- type ResourceRequest
- func (*ResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceRequest) GetNode() string
- func (x *ResourceRequest) GetResourceName() string
- func (x *ResourceRequest) GetTypeUrl() string
- func (x *ResourceRequest) GetVersion() string
- func (*ResourceRequest) ProtoMessage()
- func (x *ResourceRequest) ProtoReflect() protoreflect.Message
- func (x *ResourceRequest) Reset()
- func (x *ResourceRequest) String() string
- type SetStateRequest
- func (*SetStateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetStateRequest) GetNode() string
- func (x *SetStateRequest) GetResources() []*anypb.Any
- func (x *SetStateRequest) GetVersion() string
- func (*SetStateRequest) ProtoMessage()
- func (x *SetStateRequest) ProtoReflect() protoreflect.Message
- func (x *SetStateRequest) Reset()
- func (x *SetStateRequest) String() string
- type SetStateResponse
- type UnimplementedAdapterServer
- func (UnimplementedAdapterServer) AddResource(context.Context, *ResourceRequest) (*AddResourceResponse, error)
- func (UnimplementedAdapterServer) ClearState(context.Context, *ClearStateRequest) (*ClearStateResponse, error)
- func (UnimplementedAdapterServer) RemoveResource(context.Context, *ResourceRequest) (*RemoveResourceResponse, error)
- func (UnimplementedAdapterServer) SetState(context.Context, *SetStateRequest) (*SetStateResponse, error)
- func (UnimplementedAdapterServer) UpdateResource(context.Context, *ResourceRequest) (*UpdateResourceResponse, error)
- type UnsafeAdapterServer
- type UpdateResourceResponse
- func (*UpdateResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateResourceResponse) GetSuccess() bool
- func (*UpdateResourceResponse) ProtoMessage()
- func (x *UpdateResourceResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateResourceResponse) Reset()
- func (x *UpdateResourceResponse) String() string
Constants ¶
const ( Adapter_SetState_FullMethodName = "/adapter.Adapter/SetState" Adapter_ClearState_FullMethodName = "/adapter.Adapter/ClearState" Adapter_UpdateResource_FullMethodName = "/adapter.Adapter/UpdateResource" Adapter_AddResource_FullMethodName = "/adapter.Adapter/AddResource" Adapter_RemoveResource_FullMethodName = "/adapter.Adapter/RemoveResource" )
Variables ¶
var Adapter_ServiceDesc = grpc.ServiceDesc{ ServiceName: "adapter.Adapter", HandlerType: (*AdapterServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SetState", Handler: _Adapter_SetState_Handler, }, { MethodName: "ClearState", Handler: _Adapter_ClearState_Handler, }, { MethodName: "UpdateResource", Handler: _Adapter_UpdateResource_Handler, }, { MethodName: "AddResource", Handler: _Adapter_AddResource_Handler, }, { MethodName: "RemoveResource", Handler: _Adapter_RemoveResource_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/adapter/adapter.proto", }
Adapter_ServiceDesc is the grpc.ServiceDesc for Adapter service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_api_adapter_adapter_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAdapterServer ¶
func RegisterAdapterServer(s grpc.ServiceRegistrar, srv AdapterServer)
Types ¶
type AdapterClient ¶
type AdapterClient interface { SetState(ctx context.Context, in *SetStateRequest, opts ...grpc.CallOption) (*SetStateResponse, error) ClearState(ctx context.Context, in *ClearStateRequest, opts ...grpc.CallOption) (*ClearStateResponse, error) UpdateResource(ctx context.Context, in *ResourceRequest, opts ...grpc.CallOption) (*UpdateResourceResponse, error) AddResource(ctx context.Context, in *ResourceRequest, opts ...grpc.CallOption) (*AddResourceResponse, error) RemoveResource(ctx context.Context, in *ResourceRequest, opts ...grpc.CallOption) (*RemoveResourceResponse, error) }
AdapterClient is the client API for Adapter service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAdapterClient ¶
func NewAdapterClient(cc grpc.ClientConnInterface) AdapterClient
type AdapterServer ¶
type AdapterServer interface { SetState(context.Context, *SetStateRequest) (*SetStateResponse, error) ClearState(context.Context, *ClearStateRequest) (*ClearStateResponse, error) UpdateResource(context.Context, *ResourceRequest) (*UpdateResourceResponse, error) AddResource(context.Context, *ResourceRequest) (*AddResourceResponse, error) RemoveResource(context.Context, *ResourceRequest) (*RemoveResourceResponse, error) // contains filtered or unexported methods }
AdapterServer is the server API for Adapter service. All implementations must embed UnimplementedAdapterServer for forward compatibility
type AddResourceResponse ¶
type AddResourceResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
func (*AddResourceResponse) Descriptor
deprecated
func (*AddResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddResourceResponse.ProtoReflect.Descriptor instead.
func (*AddResourceResponse) GetSuccess ¶
func (x *AddResourceResponse) GetSuccess() bool
func (*AddResourceResponse) ProtoMessage ¶
func (*AddResourceResponse) ProtoMessage()
func (*AddResourceResponse) ProtoReflect ¶
func (x *AddResourceResponse) ProtoReflect() protoreflect.Message
func (*AddResourceResponse) Reset ¶
func (x *AddResourceResponse) Reset()
func (*AddResourceResponse) String ¶
func (x *AddResourceResponse) String() string
type ClearStateRequest ¶
type ClearStateRequest struct { Node string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // contains filtered or unexported fields }
func (*ClearStateRequest) Descriptor
deprecated
func (*ClearStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClearStateRequest.ProtoReflect.Descriptor instead.
func (*ClearStateRequest) GetNode ¶
func (x *ClearStateRequest) GetNode() string
func (*ClearStateRequest) ProtoMessage ¶
func (*ClearStateRequest) ProtoMessage()
func (*ClearStateRequest) ProtoReflect ¶
func (x *ClearStateRequest) ProtoReflect() protoreflect.Message
func (*ClearStateRequest) Reset ¶
func (x *ClearStateRequest) Reset()
func (*ClearStateRequest) String ¶
func (x *ClearStateRequest) String() string
type ClearStateResponse ¶
type ClearStateResponse struct { Response string `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"` // contains filtered or unexported fields }
func (*ClearStateResponse) Descriptor
deprecated
func (*ClearStateResponse) Descriptor() ([]byte, []int)
Deprecated: Use ClearStateResponse.ProtoReflect.Descriptor instead.
func (*ClearStateResponse) GetResponse ¶
func (x *ClearStateResponse) GetResponse() string
func (*ClearStateResponse) ProtoMessage ¶
func (*ClearStateResponse) ProtoMessage()
func (*ClearStateResponse) ProtoReflect ¶
func (x *ClearStateResponse) ProtoReflect() protoreflect.Message
func (*ClearStateResponse) Reset ¶
func (x *ClearStateResponse) Reset()
func (*ClearStateResponse) String ¶
func (x *ClearStateResponse) String() string
type RemoveResourceResponse ¶
type RemoveResourceResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
func (*RemoveResourceResponse) Descriptor
deprecated
func (*RemoveResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveResourceResponse.ProtoReflect.Descriptor instead.
func (*RemoveResourceResponse) GetSuccess ¶
func (x *RemoveResourceResponse) GetSuccess() bool
func (*RemoveResourceResponse) ProtoMessage ¶
func (*RemoveResourceResponse) ProtoMessage()
func (*RemoveResourceResponse) ProtoReflect ¶
func (x *RemoveResourceResponse) ProtoReflect() protoreflect.Message
func (*RemoveResourceResponse) Reset ¶
func (x *RemoveResourceResponse) Reset()
func (*RemoveResourceResponse) String ¶
func (x *RemoveResourceResponse) String() string
type ResourceRequest ¶
type ResourceRequest struct { Node string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` TypeUrl string `protobuf:"bytes,2,opt,name=typeUrl,proto3" json:"typeUrl,omitempty"` ResourceName string `protobuf:"bytes,3,opt,name=resourceName,proto3" json:"resourceName,omitempty"` Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*ResourceRequest) Descriptor
deprecated
func (*ResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResourceRequest.ProtoReflect.Descriptor instead.
func (*ResourceRequest) GetNode ¶
func (x *ResourceRequest) GetNode() string
func (*ResourceRequest) GetResourceName ¶
func (x *ResourceRequest) GetResourceName() string
func (*ResourceRequest) GetTypeUrl ¶
func (x *ResourceRequest) GetTypeUrl() string
func (*ResourceRequest) GetVersion ¶
func (x *ResourceRequest) GetVersion() string
func (*ResourceRequest) ProtoMessage ¶
func (*ResourceRequest) ProtoMessage()
func (*ResourceRequest) ProtoReflect ¶
func (x *ResourceRequest) ProtoReflect() protoreflect.Message
func (*ResourceRequest) Reset ¶
func (x *ResourceRequest) Reset()
func (*ResourceRequest) String ¶
func (x *ResourceRequest) String() string
type SetStateRequest ¶
type SetStateRequest struct { Node string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` Resources []*anypb.Any `protobuf:"bytes,3,rep,name=resources,proto3" json:"resources,omitempty"` // contains filtered or unexported fields }
func (*SetStateRequest) Descriptor
deprecated
func (*SetStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetStateRequest.ProtoReflect.Descriptor instead.
func (*SetStateRequest) GetNode ¶
func (x *SetStateRequest) GetNode() string
func (*SetStateRequest) GetResources ¶
func (x *SetStateRequest) GetResources() []*anypb.Any
func (*SetStateRequest) GetVersion ¶
func (x *SetStateRequest) GetVersion() string
func (*SetStateRequest) ProtoMessage ¶
func (*SetStateRequest) ProtoMessage()
func (*SetStateRequest) ProtoReflect ¶
func (x *SetStateRequest) ProtoReflect() protoreflect.Message
func (*SetStateRequest) Reset ¶
func (x *SetStateRequest) Reset()
func (*SetStateRequest) String ¶
func (x *SetStateRequest) String() string
type SetStateResponse ¶
type SetStateResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
func (*SetStateResponse) Descriptor
deprecated
func (*SetStateResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetStateResponse.ProtoReflect.Descriptor instead.
func (*SetStateResponse) GetSuccess ¶
func (x *SetStateResponse) GetSuccess() bool
func (*SetStateResponse) ProtoMessage ¶
func (*SetStateResponse) ProtoMessage()
func (*SetStateResponse) ProtoReflect ¶
func (x *SetStateResponse) ProtoReflect() protoreflect.Message
func (*SetStateResponse) Reset ¶
func (x *SetStateResponse) Reset()
func (*SetStateResponse) String ¶
func (x *SetStateResponse) String() string
type UnimplementedAdapterServer ¶
type UnimplementedAdapterServer struct { }
UnimplementedAdapterServer must be embedded to have forward compatible implementations.
func (UnimplementedAdapterServer) AddResource ¶
func (UnimplementedAdapterServer) AddResource(context.Context, *ResourceRequest) (*AddResourceResponse, error)
func (UnimplementedAdapterServer) ClearState ¶
func (UnimplementedAdapterServer) ClearState(context.Context, *ClearStateRequest) (*ClearStateResponse, error)
func (UnimplementedAdapterServer) RemoveResource ¶
func (UnimplementedAdapterServer) RemoveResource(context.Context, *ResourceRequest) (*RemoveResourceResponse, error)
func (UnimplementedAdapterServer) SetState ¶
func (UnimplementedAdapterServer) SetState(context.Context, *SetStateRequest) (*SetStateResponse, error)
func (UnimplementedAdapterServer) UpdateResource ¶
func (UnimplementedAdapterServer) UpdateResource(context.Context, *ResourceRequest) (*UpdateResourceResponse, error)
type UnsafeAdapterServer ¶
type UnsafeAdapterServer interface {
// contains filtered or unexported methods
}
UnsafeAdapterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AdapterServer will result in compilation errors.
type UpdateResourceResponse ¶
type UpdateResourceResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
func (*UpdateResourceResponse) Descriptor
deprecated
func (*UpdateResourceResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResourceResponse.ProtoReflect.Descriptor instead.
func (*UpdateResourceResponse) GetSuccess ¶
func (x *UpdateResourceResponse) GetSuccess() bool
func (*UpdateResourceResponse) ProtoMessage ¶
func (*UpdateResourceResponse) ProtoMessage()
func (*UpdateResourceResponse) ProtoReflect ¶
func (x *UpdateResourceResponse) ProtoReflect() protoreflect.Message
func (*UpdateResourceResponse) Reset ¶
func (x *UpdateResourceResponse) Reset()
func (*UpdateResourceResponse) String ¶
func (x *UpdateResourceResponse) String() string