apipb

package
v0.0.0-...-c6a7f1f Latest Latest
Warning

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

 Go to latest Published: Feb 14, 2022 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package apipb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var Accounts_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "infinimesh.api.Accounts",
	HandlerType: (*AccountsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SelfAccount",
			Handler:    _Accounts_SelfAccount_Handler,
		},
		{
			MethodName: "Token",
			Handler:    _Accounts_Token_Handler,
		},
		{
			MethodName: "CreateUserAccount",
			Handler:    _Accounts_CreateUserAccount_Handler,
		},
		{
			MethodName: "GetAccount",
			Handler:    _Accounts_GetAccount_Handler,
		},
		{
			MethodName: "UpdateAccount",
			Handler:    _Accounts_UpdateAccount_Handler,
		},
		{
			MethodName: "ListAccounts",
			Handler:    _Accounts_ListAccounts_Handler,
		},
		{
			MethodName: "DeleteAccount",
			Handler:    _Accounts_DeleteAccount_Handler,
		},
		{
			MethodName: "AssignOwner",
			Handler:    _Accounts_AssignOwner_Handler,
		},
		{
			MethodName: "RemoveOwner",
			Handler:    _Accounts_RemoveOwner_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/apiserver/apipb/api.proto",
}

Accounts_ServiceDesc is the grpc.ServiceDesc for Accounts service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Devices_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "infinimesh.api.Devices",
	HandlerType: (*DevicesServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Devices_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _Devices_Update_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _Devices_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _Devices_List_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Devices_Delete_Handler,
		},
		{
			MethodName: "AssignOwnerDevices",
			Handler:    _Devices_AssignOwnerDevices_Handler,
		},
		{
			MethodName: "RemoveOwnerDevices",
			Handler:    _Devices_RemoveOwnerDevices_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/apiserver/apipb/api.proto",
}

Devices_ServiceDesc is the grpc.ServiceDesc for Devices service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_pkg_apiserver_apipb_api_proto protoreflect.FileDescriptor
View Source 
var Namespaces_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "infinimesh.api.Namespaces",
	HandlerType: (*NamespacesServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateNamespace",
			Handler:    _Namespaces_CreateNamespace_Handler,
		},
		{
			MethodName: "GetNamespace",
			Handler:    _Namespaces_GetNamespace_Handler,
		},
		{
			MethodName: "ListNamespaces",
			Handler:    _Namespaces_ListNamespaces_Handler,
		},
		{
			MethodName: "CreatePermission",
			Handler:    _Namespaces_CreatePermission_Handler,
		},
		{
			MethodName: "ListPermissions",
			Handler:    _Namespaces_ListPermissions_Handler,
		},
		{
			MethodName: "DeletePermission",
			Handler:    _Namespaces_DeletePermission_Handler,
		},
		{
			MethodName: "DeleteNamespace",
			Handler:    _Namespaces_DeleteNamespace_Handler,
		},
		{
			MethodName: "UpdateNamespace",
			Handler:    _Namespaces_UpdateNamespace_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/apiserver/apipb/api.proto",
}

Namespaces_ServiceDesc is the grpc.ServiceDesc for Namespaces service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Objects_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "infinimesh.api.Objects",
	HandlerType: (*ObjectsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListObjects",
			Handler:    _Objects_ListObjects_Handler,
		},
		{
			MethodName: "CreateObject",
			Handler:    _Objects_CreateObject_Handler,
		},
		{
			MethodName: "DeleteObject",
			Handler:    _Objects_DeleteObject_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/apiserver/apipb/api.proto",
}

Objects_ServiceDesc is the grpc.ServiceDesc for Objects service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var States_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "infinimesh.api.States",
	HandlerType: (*StatesServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _States_Get_Handler,
		},
		{
			MethodName: "GetForNS",
			Handler:    _States_GetForNS_Handler,
		},
		{
			MethodName: "PatchDesiredState",
			Handler:    _States_PatchDesiredState_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamReportedStateChanges",
			Handler:       _States_StreamReportedStateChanges_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/apiserver/apipb/api.proto",
}

States_ServiceDesc is the grpc.ServiceDesc for States service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAccountsHandler 

func RegisterAccountsHandler(ctx context.Context, mux *runtime.ServeMux, conn grpc.ClientConnInterface) error

RegisterAccountsHandler registers the http handlers for service Accounts to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAccountsHandlerClient 

func RegisterAccountsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AccountsClient) error

RegisterAccountsHandlerClient registers the http handlers for service Accounts to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AccountsClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AccountsClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AccountsClient" to call the correct interceptors.

func RegisterAccountsHandlerFromEndpoint 

func RegisterAccountsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAccountsHandlerFromEndpoint is same as RegisterAccountsHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAccountsHandlerServer 

func RegisterAccountsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AccountsServer) error

RegisterAccountsHandlerServer registers the http handlers for service Accounts to "mux". UnaryRPC :call AccountsServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAccountsHandlerFromEndpoint instead.

func RegisterAccountsServer 

func RegisterAccountsServer(s grpc.ServiceRegistrar, srv AccountsServer)

func RegisterDevicesHandler 

func RegisterDevicesHandler(ctx context.Context, mux *runtime.ServeMux, conn grpc.ClientConnInterface) error

RegisterDevicesHandler registers the http handlers for service Devices to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDevicesHandlerClient 

func RegisterDevicesHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DevicesClient) error

RegisterDevicesHandlerClient registers the http handlers for service Devices to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DevicesClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DevicesClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DevicesClient" to call the correct interceptors.

func RegisterDevicesHandlerFromEndpoint 

func RegisterDevicesHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDevicesHandlerFromEndpoint is same as RegisterDevicesHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDevicesHandlerServer 

func RegisterDevicesHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DevicesServer) error

RegisterDevicesHandlerServer registers the http handlers for service Devices to "mux". UnaryRPC :call DevicesServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDevicesHandlerFromEndpoint instead.

func RegisterDevicesServer 

func RegisterDevicesServer(s grpc.ServiceRegistrar, srv DevicesServer)

func RegisterNamespacesHandler 

func RegisterNamespacesHandler(ctx context.Context, mux *runtime.ServeMux, conn grpc.ClientConnInterface) error

RegisterNamespacesHandler registers the http handlers for service Namespaces to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterNamespacesHandlerClient 

func RegisterNamespacesHandlerClient(ctx context.Context, mux *runtime.ServeMux, client NamespacesClient) error

RegisterNamespacesHandlerClient registers the http handlers for service Namespaces to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "NamespacesClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "NamespacesClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "NamespacesClient" to call the correct interceptors.

func RegisterNamespacesHandlerFromEndpoint 

func RegisterNamespacesHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterNamespacesHandlerFromEndpoint is same as RegisterNamespacesHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterNamespacesHandlerServer 

func RegisterNamespacesHandlerServer(ctx context.Context, mux *runtime.ServeMux, server NamespacesServer) error

RegisterNamespacesHandlerServer registers the http handlers for service Namespaces to "mux". UnaryRPC :call NamespacesServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterNamespacesHandlerFromEndpoint instead.

func RegisterNamespacesServer 

func RegisterNamespacesServer(s grpc.ServiceRegistrar, srv NamespacesServer)

func RegisterObjectsHandler 

func RegisterObjectsHandler(ctx context.Context, mux *runtime.ServeMux, conn grpc.ClientConnInterface) error

RegisterObjectsHandler registers the http handlers for service Objects to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterObjectsHandlerClient 

func RegisterObjectsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ObjectsClient) error

RegisterObjectsHandlerClient registers the http handlers for service Objects to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ObjectsClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ObjectsClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ObjectsClient" to call the correct interceptors.

func RegisterObjectsHandlerFromEndpoint 

func RegisterObjectsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterObjectsHandlerFromEndpoint is same as RegisterObjectsHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterObjectsHandlerServer 

func RegisterObjectsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ObjectsServer) error

RegisterObjectsHandlerServer registers the http handlers for service Objects to "mux". UnaryRPC :call ObjectsServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterObjectsHandlerFromEndpoint instead.

func RegisterObjectsServer 

func RegisterObjectsServer(s grpc.ServiceRegistrar, srv ObjectsServer)

func RegisterStatesHandler 

func RegisterStatesHandler(ctx context.Context, mux *runtime.ServeMux, conn grpc.ClientConnInterface) error

RegisterStatesHandler registers the http handlers for service States to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterStatesHandlerClient 

func RegisterStatesHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StatesClient) error

RegisterStatesHandlerClient registers the http handlers for service States to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "StatesClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "StatesClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "StatesClient" to call the correct interceptors.

func RegisterStatesHandlerFromEndpoint 

func RegisterStatesHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterStatesHandlerFromEndpoint is same as RegisterStatesHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterStatesHandlerServer 

func RegisterStatesHandlerServer(ctx context.Context, mux *runtime.ServeMux, server StatesServer) error

RegisterStatesHandlerServer registers the http handlers for service States to "mux". UnaryRPC :call StatesServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterStatesHandlerFromEndpoint instead.

func RegisterStatesServer 

func RegisterStatesServer(s grpc.ServiceRegistrar, srv StatesServer)

Types

type AccountsClient 

type AccountsClient interface {
	SelfAccount(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*nodepb.Account, error)
	Token(ctx context.Context, in *TokenRequest, opts ...grpc.CallOption) (*TokenResponse, error)
	CreateUserAccount(ctx context.Context, in *nodepb.CreateUserAccountRequest, opts ...grpc.CallOption) (*nodepb.CreateUserAccountResponse, error)
	GetAccount(ctx context.Context, in *nodepb.GetAccountRequest, opts ...grpc.CallOption) (*nodepb.Account, error)
	UpdateAccount(ctx context.Context, in *nodepb.UpdateAccountRequest, opts ...grpc.CallOption) (*nodepb.UpdateAccountResponse, error)
	ListAccounts(ctx context.Context, in *nodepb.ListAccountsRequest, opts ...grpc.CallOption) (*nodepb.ListAccountsResponse, error)
	DeleteAccount(ctx context.Context, in *nodepb.DeleteAccountRequest, opts ...grpc.CallOption) (*nodepb.DeleteAccountResponse, error)
	AssignOwner(ctx context.Context, in *nodepb.OwnershipRequest, opts ...grpc.CallOption) (*nodepb.OwnershipResponse, error)
	RemoveOwner(ctx context.Context, in *nodepb.OwnershipRequest, opts ...grpc.CallOption) (*nodepb.OwnershipResponse, error)
}

AccountsClient is the client API for Accounts 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 NewAccountsClient 

func NewAccountsClient(cc grpc.ClientConnInterface) AccountsClient

type AccountsServer 

type AccountsServer interface {
	SelfAccount(context.Context, *emptypb.Empty) (*nodepb.Account, error)
	Token(context.Context, *TokenRequest) (*TokenResponse, error)
	CreateUserAccount(context.Context, *nodepb.CreateUserAccountRequest) (*nodepb.CreateUserAccountResponse, error)
	GetAccount(context.Context, *nodepb.GetAccountRequest) (*nodepb.Account, error)
	UpdateAccount(context.Context, *nodepb.UpdateAccountRequest) (*nodepb.UpdateAccountResponse, error)
	ListAccounts(context.Context, *nodepb.ListAccountsRequest) (*nodepb.ListAccountsResponse, error)
	DeleteAccount(context.Context, *nodepb.DeleteAccountRequest) (*nodepb.DeleteAccountResponse, error)
	AssignOwner(context.Context, *nodepb.OwnershipRequest) (*nodepb.OwnershipResponse, error)
	RemoveOwner(context.Context, *nodepb.OwnershipRequest) (*nodepb.OwnershipResponse, error)
	// contains filtered or unexported methods
}

AccountsServer is the server API for Accounts service. All implementations must embed UnimplementedAccountsServer for forward compatibility

type CreateNamespacePermissionRequest 

type CreateNamespacePermissionRequest struct {
	AccountId  string      `protobuf:"bytes,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	Namespace  string      `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Permission *Permission `protobuf:"bytes,3,opt,name=permission,proto3" json:"permission,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateNamespacePermissionRequest) Descriptor deprecated 

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

Deprecated: Use CreateNamespacePermissionRequest.ProtoReflect.Descriptor instead.

func (*CreateNamespacePermissionRequest) GetAccountId 

func (x *CreateNamespacePermissionRequest) GetAccountId() string

func (*CreateNamespacePermissionRequest) GetNamespace 

func (x *CreateNamespacePermissionRequest) GetNamespace() string

func (*CreateNamespacePermissionRequest) GetPermission 

func (x *CreateNamespacePermissionRequest) GetPermission() *Permission

func (*CreateNamespacePermissionRequest) ProtoMessage 

func (*CreateNamespacePermissionRequest) ProtoMessage()

func (*CreateNamespacePermissionRequest) ProtoReflect 

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

func (*CreateNamespacePermissionRequest) Reset 

func (x *CreateNamespacePermissionRequest) Reset()

func (*CreateNamespacePermissionRequest) String 

func (x *CreateNamespacePermissionRequest) String() string

type CreateNamespacePermissionResponse 

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

func (*CreateNamespacePermissionResponse) Descriptor deprecated 

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

Deprecated: Use CreateNamespacePermissionResponse.ProtoReflect.Descriptor instead.

func (*CreateNamespacePermissionResponse) ProtoMessage 

func (*CreateNamespacePermissionResponse) ProtoMessage()

func (*CreateNamespacePermissionResponse) ProtoReflect 

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

func (*CreateNamespacePermissionResponse) Reset 

func (x *CreateNamespacePermissionResponse) Reset()

func (*CreateNamespacePermissionResponse) String 

func (x *CreateNamespacePermissionResponse) String() string

type CreateObjectRequest 

type CreateObjectRequest struct {
	Parent    *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Namespace string                  `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Object    *nodepb.Object          `protobuf:"bytes,3,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateObjectRequest) Descriptor deprecated 

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

Deprecated: Use CreateObjectRequest.ProtoReflect.Descriptor instead.

func (*CreateObjectRequest) GetNamespace 

func (x *CreateObjectRequest) GetNamespace() string

func (*CreateObjectRequest) GetObject 

func (x *CreateObjectRequest) GetObject() *nodepb.Object

func (*CreateObjectRequest) GetParent 

func (x *CreateObjectRequest) GetParent() *wrapperspb.StringValue

func (*CreateObjectRequest) ProtoMessage 

func (*CreateObjectRequest) ProtoMessage()

func (*CreateObjectRequest) ProtoReflect 

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

func (*CreateObjectRequest) Reset 

func (x *CreateObjectRequest) Reset()

func (*CreateObjectRequest) String 

func (x *CreateObjectRequest) String() string

type DevicesClient 

type DevicesClient interface {
	Create(ctx context.Context, in *registrypb.CreateRequest, opts ...grpc.CallOption) (*registrypb.CreateResponse, error)
	Update(ctx context.Context, in *registrypb.UpdateRequest, opts ...grpc.CallOption) (*registrypb.UpdateResponse, error)
	Get(ctx context.Context, in *registrypb.GetRequest, opts ...grpc.CallOption) (*registrypb.GetResponse, error)
	List(ctx context.Context, in *ListDevicesRequest, opts ...grpc.CallOption) (*registrypb.ListResponse, error)
	Delete(ctx context.Context, in *registrypb.DeleteRequest, opts ...grpc.CallOption) (*registrypb.DeleteResponse, error)
	AssignOwnerDevices(ctx context.Context, in *registrypb.OwnershipRequestDevices, opts ...grpc.CallOption) (*registrypb.OwnershipResponseDevices, error)
	RemoveOwnerDevices(ctx context.Context, in *registrypb.OwnershipRequestDevices, opts ...grpc.CallOption) (*registrypb.OwnershipResponseDevices, error)
}

DevicesClient is the client API for Devices 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 NewDevicesClient 

func NewDevicesClient(cc grpc.ClientConnInterface) DevicesClient

type DevicesServer 

type DevicesServer interface {
	Create(context.Context, *registrypb.CreateRequest) (*registrypb.CreateResponse, error)
	Update(context.Context, *registrypb.UpdateRequest) (*registrypb.UpdateResponse, error)
	Get(context.Context, *registrypb.GetRequest) (*registrypb.GetResponse, error)
	List(context.Context, *ListDevicesRequest) (*registrypb.ListResponse, error)
	Delete(context.Context, *registrypb.DeleteRequest) (*registrypb.DeleteResponse, error)
	AssignOwnerDevices(context.Context, *registrypb.OwnershipRequestDevices) (*registrypb.OwnershipResponseDevices, error)
	RemoveOwnerDevices(context.Context, *registrypb.OwnershipRequestDevices) (*registrypb.OwnershipResponseDevices, error)
	// contains filtered or unexported methods
}

DevicesServer is the server API for Devices service. All implementations must embed UnimplementedDevicesServer for forward compatibility

type ListDevicesRequest 

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

func (*ListDevicesRequest) Descriptor deprecated 

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

Deprecated: Use ListDevicesRequest.ProtoReflect.Descriptor instead.

func (*ListDevicesRequest) GetNamespaceid 

func (x *ListDevicesRequest) GetNamespaceid() string

func (*ListDevicesRequest) ProtoMessage 

func (*ListDevicesRequest) ProtoMessage()

func (*ListDevicesRequest) ProtoReflect 

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

func (*ListDevicesRequest) Reset 

func (x *ListDevicesRequest) Reset()

func (*ListDevicesRequest) String 

func (x *ListDevicesRequest) String() string

type ListObjectsRequest 

type ListObjectsRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Recurse   bool   `protobuf:"varint,2,opt,name=recurse,proto3" json:"recurse,omitempty"`
	// contains filtered or unexported fields
}

func (*ListObjectsRequest) Descriptor deprecated 

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

Deprecated: Use ListObjectsRequest.ProtoReflect.Descriptor instead.

func (*ListObjectsRequest) GetNamespace 

func (x *ListObjectsRequest) GetNamespace() string

func (*ListObjectsRequest) GetRecurse 

func (x *ListObjectsRequest) GetRecurse() bool

func (*ListObjectsRequest) ProtoMessage 

func (*ListObjectsRequest) ProtoMessage()

func (*ListObjectsRequest) ProtoReflect 

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

func (*ListObjectsRequest) Reset 

func (x *ListObjectsRequest) Reset()

func (*ListObjectsRequest) String 

func (x *ListObjectsRequest) String() string

type NamespacesClient 

type NamespacesClient interface {
	CreateNamespace(ctx context.Context, in *nodepb.CreateNamespaceRequest, opts ...grpc.CallOption) (*nodepb.Namespace, error)
	GetNamespace(ctx context.Context, in *nodepb.GetNamespaceRequest, opts ...grpc.CallOption) (*nodepb.Namespace, error)
	ListNamespaces(ctx context.Context, in *nodepb.ListNamespacesRequest, opts ...grpc.CallOption) (*nodepb.ListNamespacesResponse, error)
	CreatePermission(ctx context.Context, in *CreateNamespacePermissionRequest, opts ...grpc.CallOption) (*CreateNamespacePermissionResponse, error)
	ListPermissions(ctx context.Context, in *nodepb.ListPermissionsRequest, opts ...grpc.CallOption) (*nodepb.ListPermissionsResponse, error)
	DeletePermission(ctx context.Context, in *nodepb.DeletePermissionRequest, opts ...grpc.CallOption) (*nodepb.DeletePermissionResponse, error)
	DeleteNamespace(ctx context.Context, in *nodepb.DeleteNamespaceRequest, opts ...grpc.CallOption) (*nodepb.DeleteNamespaceResponse, error)
	UpdateNamespace(ctx context.Context, in *nodepb.UpdateNamespaceRequest, opts ...grpc.CallOption) (*nodepb.UpdateNamespaceResponse, error)
}

NamespacesClient is the client API for Namespaces 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 NewNamespacesClient 

func NewNamespacesClient(cc grpc.ClientConnInterface) NamespacesClient

type NamespacesServer 

type NamespacesServer interface {
	CreateNamespace(context.Context, *nodepb.CreateNamespaceRequest) (*nodepb.Namespace, error)
	GetNamespace(context.Context, *nodepb.GetNamespaceRequest) (*nodepb.Namespace, error)
	ListNamespaces(context.Context, *nodepb.ListNamespacesRequest) (*nodepb.ListNamespacesResponse, error)
	CreatePermission(context.Context, *CreateNamespacePermissionRequest) (*CreateNamespacePermissionResponse, error)
	ListPermissions(context.Context, *nodepb.ListPermissionsRequest) (*nodepb.ListPermissionsResponse, error)
	DeletePermission(context.Context, *nodepb.DeletePermissionRequest) (*nodepb.DeletePermissionResponse, error)
	DeleteNamespace(context.Context, *nodepb.DeleteNamespaceRequest) (*nodepb.DeleteNamespaceResponse, error)
	UpdateNamespace(context.Context, *nodepb.UpdateNamespaceRequest) (*nodepb.UpdateNamespaceResponse, error)
	// contains filtered or unexported methods
}

NamespacesServer is the server API for Namespaces service. All implementations must embed UnimplementedNamespacesServer for forward compatibility

type ObjectsClient 

type ObjectsClient interface {
	ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (*nodepb.ListObjectsResponse, error)
	CreateObject(ctx context.Context, in *CreateObjectRequest, opts ...grpc.CallOption) (*nodepb.Object, error)
	DeleteObject(ctx context.Context, in *nodepb.DeleteObjectRequest, opts ...grpc.CallOption) (*nodepb.DeleteObjectResponse, error)
}

ObjectsClient is the client API for Objects 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 NewObjectsClient 

func NewObjectsClient(cc grpc.ClientConnInterface) ObjectsClient

type ObjectsServer 

type ObjectsServer interface {
	ListObjects(context.Context, *ListObjectsRequest) (*nodepb.ListObjectsResponse, error)
	CreateObject(context.Context, *CreateObjectRequest) (*nodepb.Object, error)
	DeleteObject(context.Context, *nodepb.DeleteObjectRequest) (*nodepb.DeleteObjectResponse, error)
	// contains filtered or unexported methods
}

ObjectsServer is the server API for Objects service. All implementations must embed UnimplementedObjectsServer for forward compatibility

type Permission 

type Permission struct {
	Action nodepb.Action `protobuf:"varint,3,opt,name=action,proto3,enum=infinimesh.node.Action" json:"action,omitempty"`
	// contains filtered or unexported fields
}

Permission.Action may either be NONE, READ or WRITE.

func (*Permission) Descriptor deprecated 

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

Deprecated: Use Permission.ProtoReflect.Descriptor instead.

func (*Permission) GetAction 

func (x *Permission) GetAction() nodepb.Action

func (*Permission) ProtoMessage 

func (*Permission) ProtoMessage()

func (*Permission) ProtoReflect 

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

func (*Permission) Reset 

func (x *Permission) Reset()

func (*Permission) String 

func (x *Permission) String() string

type RestrictionRule 

type RestrictionRule struct {
	Type string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Ids  []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*RestrictionRule) Descriptor deprecated 

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

Deprecated: Use RestrictionRule.ProtoReflect.Descriptor instead.

func (*RestrictionRule) GetIds 

func (x *RestrictionRule) GetIds() []string

func (*RestrictionRule) GetType 

func (x *RestrictionRule) GetType() string

func (*RestrictionRule) ProtoMessage 

func (*RestrictionRule) ProtoMessage()

func (*RestrictionRule) ProtoReflect 

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

func (*RestrictionRule) Reset 

func (x *RestrictionRule) Reset()

func (*RestrictionRule) String 

func (x *RestrictionRule) String() string

type StatesClient 

type StatesClient interface {
	Get(ctx context.Context, in *shadowpb.GetRequest, opts ...grpc.CallOption) (*shadowpb.GetResponse, error)
	GetForNS(ctx context.Context, in *shadowpb.GetRequest, opts ...grpc.CallOption) (*shadowpb.GetForNSResponse, error)
	PatchDesiredState(ctx context.Context, in *shadowpb.PatchDesiredStateRequest, opts ...grpc.CallOption) (*shadowpb.PatchDesiredStateResponse, error)
	StreamReportedStateChanges(ctx context.Context, in *shadowpb.StreamReportedStateChangesRequest, opts ...grpc.CallOption) (States_StreamReportedStateChangesClient, error)
}

StatesClient is the client API for States 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 NewStatesClient 

func NewStatesClient(cc grpc.ClientConnInterface) StatesClient

type StatesServer 

type StatesServer interface {
	Get(context.Context, *shadowpb.GetRequest) (*shadowpb.GetResponse, error)
	GetForNS(context.Context, *shadowpb.GetRequest) (*shadowpb.GetForNSResponse, error)
	PatchDesiredState(context.Context, *shadowpb.PatchDesiredStateRequest) (*shadowpb.PatchDesiredStateResponse, error)
	StreamReportedStateChanges(*shadowpb.StreamReportedStateChangesRequest, States_StreamReportedStateChangesServer) error
	// contains filtered or unexported methods
}

StatesServer is the server API for States service. All implementations must embed UnimplementedStatesServer for forward compatibility

type States_StreamReportedStateChangesClient 

type States_StreamReportedStateChangesClient interface {
	Recv() (*shadowpb.StreamReportedStateChangesResponse, error)
	grpc.ClientStream
}

type States_StreamReportedStateChangesServer 

type States_StreamReportedStateChangesServer interface {
	Send(*shadowpb.StreamReportedStateChangesResponse) error
	grpc.ServerStream
}

type TokenRequest 

type TokenRequest struct {
	Username   string             `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password   string             `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	ExpireTime string             `protobuf:"bytes,3,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"` // token expire time in seconds
	Ruleset    []*RestrictionRule `protobuf:"bytes,4,rep,name=ruleset,proto3" json:"ruleset,omitempty"`                         // methods restrictions ruleset
	// contains filtered or unexported fields
}

func (*TokenRequest) Descriptor deprecated 

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

Deprecated: Use TokenRequest.ProtoReflect.Descriptor instead.

func (*TokenRequest) GetExpireTime 

func (x *TokenRequest) GetExpireTime() string

func (*TokenRequest) GetPassword 

func (x *TokenRequest) GetPassword() string

func (*TokenRequest) GetRuleset 

func (x *TokenRequest) GetRuleset() []*RestrictionRule

func (*TokenRequest) GetUsername 

func (x *TokenRequest) GetUsername() string

func (*TokenRequest) ProtoMessage 

func (*TokenRequest) ProtoMessage()

func (*TokenRequest) ProtoReflect 

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

func (*TokenRequest) Reset 

func (x *TokenRequest) Reset()

func (*TokenRequest) String 

func (x *TokenRequest) String() string

type TokenResponse 

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

func (*TokenResponse) Descriptor deprecated 

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

Deprecated: Use TokenResponse.ProtoReflect.Descriptor instead.

func (*TokenResponse) GetToken 

func (x *TokenResponse) GetToken() string

func (*TokenResponse) ProtoMessage 

func (*TokenResponse) ProtoMessage()

func (*TokenResponse) ProtoReflect 

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

func (*TokenResponse) Reset 

func (x *TokenResponse) Reset()

func (*TokenResponse) String 

func (x *TokenResponse) String() string

type UnimplementedAccountsServer 

type UnimplementedAccountsServer struct {
}

UnimplementedAccountsServer must be embedded to have forward compatible implementations.

func (UnimplementedAccountsServer) AssignOwner 

func (UnimplementedAccountsServer) AssignOwner(context.Context, *nodepb.OwnershipRequest) (*nodepb.OwnershipResponse, error)

func (UnimplementedAccountsServer) CreateUserAccount 

func (UnimplementedAccountsServer) CreateUserAccount(context.Context, *nodepb.CreateUserAccountRequest) (*nodepb.CreateUserAccountResponse, error)

func (UnimplementedAccountsServer) DeleteAccount 

func (UnimplementedAccountsServer) DeleteAccount(context.Context, *nodepb.DeleteAccountRequest) (*nodepb.DeleteAccountResponse, error)

func (UnimplementedAccountsServer) GetAccount 

func (UnimplementedAccountsServer) GetAccount(context.Context, *nodepb.GetAccountRequest) (*nodepb.Account, error)

func (UnimplementedAccountsServer) ListAccounts 

func (UnimplementedAccountsServer) ListAccounts(context.Context, *nodepb.ListAccountsRequest) (*nodepb.ListAccountsResponse, error)

func (UnimplementedAccountsServer) RemoveOwner 

func (UnimplementedAccountsServer) RemoveOwner(context.Context, *nodepb.OwnershipRequest) (*nodepb.OwnershipResponse, error)

func (UnimplementedAccountsServer) SelfAccount 

func (UnimplementedAccountsServer) SelfAccount(context.Context, *emptypb.Empty) (*nodepb.Account, error)

func (UnimplementedAccountsServer) Token 

func (UnimplementedAccountsServer) Token(context.Context, *TokenRequest) (*TokenResponse, error)

func (UnimplementedAccountsServer) UpdateAccount 

func (UnimplementedAccountsServer) UpdateAccount(context.Context, *nodepb.UpdateAccountRequest) (*nodepb.UpdateAccountResponse, error)

type UnimplementedDevicesServer 

type UnimplementedDevicesServer struct {
}

UnimplementedDevicesServer must be embedded to have forward compatible implementations.

func (UnimplementedDevicesServer) AssignOwnerDevices 

func (UnimplementedDevicesServer) AssignOwnerDevices(context.Context, *registrypb.OwnershipRequestDevices) (*registrypb.OwnershipResponseDevices, error)

func (UnimplementedDevicesServer) Create 

func (UnimplementedDevicesServer) Create(context.Context, *registrypb.CreateRequest) (*registrypb.CreateResponse, error)

func (UnimplementedDevicesServer) Delete 

func (UnimplementedDevicesServer) Delete(context.Context, *registrypb.DeleteRequest) (*registrypb.DeleteResponse, error)

func (UnimplementedDevicesServer) Get 

func (UnimplementedDevicesServer) Get(context.Context, *registrypb.GetRequest) (*registrypb.GetResponse, error)

func (UnimplementedDevicesServer) List 

func (UnimplementedDevicesServer) List(context.Context, *ListDevicesRequest) (*registrypb.ListResponse, error)

func (UnimplementedDevicesServer) RemoveOwnerDevices 

func (UnimplementedDevicesServer) RemoveOwnerDevices(context.Context, *registrypb.OwnershipRequestDevices) (*registrypb.OwnershipResponseDevices, error)

func (UnimplementedDevicesServer) Update 

func (UnimplementedDevicesServer) Update(context.Context, *registrypb.UpdateRequest) (*registrypb.UpdateResponse, error)

type UnimplementedNamespacesServer 

type UnimplementedNamespacesServer struct {
}

UnimplementedNamespacesServer must be embedded to have forward compatible implementations.

func (UnimplementedNamespacesServer) CreateNamespace 

func (UnimplementedNamespacesServer) CreateNamespace(context.Context, *nodepb.CreateNamespaceRequest) (*nodepb.Namespace, error)

func (UnimplementedNamespacesServer) CreatePermission 

func (UnimplementedNamespacesServer) CreatePermission(context.Context, *CreateNamespacePermissionRequest) (*CreateNamespacePermissionResponse, error)

func (UnimplementedNamespacesServer) DeleteNamespace 

func (UnimplementedNamespacesServer) DeleteNamespace(context.Context, *nodepb.DeleteNamespaceRequest) (*nodepb.DeleteNamespaceResponse, error)

func (UnimplementedNamespacesServer) DeletePermission 

func (UnimplementedNamespacesServer) DeletePermission(context.Context, *nodepb.DeletePermissionRequest) (*nodepb.DeletePermissionResponse, error)

func (UnimplementedNamespacesServer) GetNamespace 

func (UnimplementedNamespacesServer) GetNamespace(context.Context, *nodepb.GetNamespaceRequest) (*nodepb.Namespace, error)

func (UnimplementedNamespacesServer) ListNamespaces 

func (UnimplementedNamespacesServer) ListNamespaces(context.Context, *nodepb.ListNamespacesRequest) (*nodepb.ListNamespacesResponse, error)

func (UnimplementedNamespacesServer) ListPermissions 

func (UnimplementedNamespacesServer) ListPermissions(context.Context, *nodepb.ListPermissionsRequest) (*nodepb.ListPermissionsResponse, error)

func (UnimplementedNamespacesServer) UpdateNamespace 

func (UnimplementedNamespacesServer) UpdateNamespace(context.Context, *nodepb.UpdateNamespaceRequest) (*nodepb.UpdateNamespaceResponse, error)

type UnimplementedObjectsServer 

type UnimplementedObjectsServer struct {
}

UnimplementedObjectsServer must be embedded to have forward compatible implementations.

func (UnimplementedObjectsServer) CreateObject 

func (UnimplementedObjectsServer) CreateObject(context.Context, *CreateObjectRequest) (*nodepb.Object, error)

func (UnimplementedObjectsServer) DeleteObject 

func (UnimplementedObjectsServer) DeleteObject(context.Context, *nodepb.DeleteObjectRequest) (*nodepb.DeleteObjectResponse, error)

func (UnimplementedObjectsServer) ListObjects 

func (UnimplementedObjectsServer) ListObjects(context.Context, *ListObjectsRequest) (*nodepb.ListObjectsResponse, error)

type UnimplementedStatesServer 

type UnimplementedStatesServer struct {
}

UnimplementedStatesServer must be embedded to have forward compatible implementations.

func (UnimplementedStatesServer) Get 

func (UnimplementedStatesServer) Get(context.Context, *shadowpb.GetRequest) (*shadowpb.GetResponse, error)

func (UnimplementedStatesServer) GetForNS 

func (UnimplementedStatesServer) GetForNS(context.Context, *shadowpb.GetRequest) (*shadowpb.GetForNSResponse, error)

func (UnimplementedStatesServer) PatchDesiredState 

func (UnimplementedStatesServer) PatchDesiredState(context.Context, *shadowpb.PatchDesiredStateRequest) (*shadowpb.PatchDesiredStateResponse, error)

func (UnimplementedStatesServer) StreamReportedStateChanges 

func (UnimplementedStatesServer) StreamReportedStateChanges(*shadowpb.StreamReportedStateChangesRequest, States_StreamReportedStateChangesServer) error

type UnsafeAccountsServer 

type UnsafeAccountsServer interface {
	// contains filtered or unexported methods
}

UnsafeAccountsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AccountsServer will result in compilation errors.

type UnsafeDevicesServer 

type UnsafeDevicesServer interface {
	// contains filtered or unexported methods
}

UnsafeDevicesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DevicesServer will result in compilation errors.

type UnsafeNamespacesServer 

type UnsafeNamespacesServer interface {
	// contains filtered or unexported methods
}

UnsafeNamespacesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NamespacesServer will result in compilation errors.

type UnsafeObjectsServer 

type UnsafeObjectsServer interface {
	// contains filtered or unexported methods
}

UnsafeObjectsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ObjectsServer will result in compilation errors.

type UnsafeStatesServer 

type UnsafeStatesServer interface {
	// contains filtered or unexported methods
}

UnsafeStatesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StatesServer will result in compilation errors.

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.