service

Documentation

Index

• type PortServer
  • func NewPortServer(storage PortStorage) *PortServer
  • func (server *PortServer) Load(_ *empty.Empty, stream proto.Storage_LoadServer) error
  • func (server *PortServer) Save(stream proto.Storage_SaveServer) error
• type PortStorage

Types

type PortServer

type PortServer struct {
	proto.UnimplementedStorageServer

	PortStorage
}

PortServer is the server that provides operations on Port(s).

func NewPortServer

func NewPortServer(storage PortStorage) *PortServer

NewPortServer returns a new PortServer.

func (*PortServer) Load

func (server *PortServer) Load(_ *empty.Empty, stream proto.Storage_LoadServer) error

Load is a server-streaming RPC to return all available ports. TODO: - logging

func (*PortServer) Save

func (server *PortServer) Save(stream proto.Storage_SaveServer) error

Save is a server-streaming RPC to store ports to the repository.

type PortStorage

type PortStorage interface {
	Save(key string, port *proto.Port)
	Each(func(key string, port *proto.Port) error) error
}

PortStorage is a port repository providing basic data operation.