// package serv_public -- сервер запросов на публикацию package serv_public import ( "context" "fmt" "p78git.ddns.net/svi/gobus/pkg/net/netapi" "p78git.ddns.net/svi/gobus/pkg/types" ) // ServPublic -- отвечает на запросы публикации type ServPublic struct { serv types.IService dictTopic types.IDictTopic } // NewServPublic -- возвращает новый публикатор func NewServPublic(serv types.IService) (*ServPublic, error) { if serv == nil { return nil, fmt.Errorf("NewServPublic(): IService==nil") } sf := &ServPublic{ serv: serv, dictTopic: serv.DictTopic(), } return sf, nil } // Public -- публикация сообщения в топик func (sf *ServPublic) Public(ctx context.Context, req *netapi.PublicRequest) (*netapi.DefaultResponse, error) { return &netapi.DefaultResponse{}, nil }