pub trait MulticastGroupService: Send + Sync + 'static {
    // Required methods
    fn create<'life0, 'async_trait>(
        &'life0 self,
        request: Request<CreateMulticastGroupRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<CreateMulticastGroupResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetMulticastGroupRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetMulticastGroupResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn update<'life0, 'async_trait>(
        &'life0 self,
        request: Request<UpdateMulticastGroupRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn delete<'life0, 'async_trait>(
        &'life0 self,
        request: Request<DeleteMulticastGroupRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListMulticastGroupsRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListMulticastGroupsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn add_device<'life0, 'async_trait>(
        &'life0 self,
        request: Request<AddDeviceToMulticastGroupRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn remove_device<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RemoveDeviceFromMulticastGroupRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn add_gateway<'life0, 'async_trait>(
        &'life0 self,
        request: Request<AddGatewayToMulticastGroupRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn remove_gateway<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RemoveGatewayFromMulticastGroupRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn enqueue<'life0, 'async_trait>(
        &'life0 self,
        request: Request<EnqueueMulticastGroupQueueItemRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<EnqueueMulticastGroupQueueItemResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn flush_queue<'life0, 'async_trait>(
        &'life0 self,
        request: Request<FlushMulticastGroupQueueRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_queue<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListMulticastGroupQueueRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListMulticastGroupQueueResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}
Expand description

Generated trait containing gRPC methods that should be implemented for use with MulticastGroupServiceServer.

Required Methods§

source

fn create<'life0, 'async_trait>( &'life0 self, request: Request<CreateMulticastGroupRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<CreateMulticastGroupResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Create the given multicast group.

source

fn get<'life0, 'async_trait>( &'life0 self, request: Request<GetMulticastGroupRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<GetMulticastGroupResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Get returns the multicast group for the given ID.

source

fn update<'life0, 'async_trait>( &'life0 self, request: Request<UpdateMulticastGroupRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Update the given multicast group.

source

fn delete<'life0, 'async_trait>( &'life0 self, request: Request<DeleteMulticastGroupRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Delete the multicast-group with the given ID.

source

fn list<'life0, 'async_trait>( &'life0 self, request: Request<ListMulticastGroupsRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<ListMulticastGroupsResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

List the available multicast groups.

source

fn add_device<'life0, 'async_trait>( &'life0 self, request: Request<AddDeviceToMulticastGroupRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Add a device to the multicast group.

source

fn remove_device<'life0, 'async_trait>( &'life0 self, request: Request<RemoveDeviceFromMulticastGroupRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Remove a device from the multicast group.

source

fn add_gateway<'life0, 'async_trait>( &'life0 self, request: Request<AddGatewayToMulticastGroupRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Add a gateway to the multicast group.

source

fn remove_gateway<'life0, 'async_trait>( &'life0 self, request: Request<RemoveGatewayFromMulticastGroupRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Remove a gateway from the multicast group.

source

fn enqueue<'life0, 'async_trait>( &'life0 self, request: Request<EnqueueMulticastGroupQueueItemRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<EnqueueMulticastGroupQueueItemResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Add the given item to the multicast group queue.

source

fn flush_queue<'life0, 'async_trait>( &'life0 self, request: Request<FlushMulticastGroupQueueRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Flush the queue for the given multicast group.

source

fn list_queue<'life0, 'async_trait>( &'life0 self, request: Request<ListMulticastGroupQueueRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<ListMulticastGroupQueueResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

List the items in the multicast group queue.

Implementors§