Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrUpgrading = &ErrorResponse{StatusCode: http.StatusUpgradeRequired, ErrorText: "could not upgrade"} )
View Source
var DefaultSet = wire.NewSet( NewStreamRepository, wire.Bind(new(usecase.StreamRepository), new(*StreamRepository)), New, )
Functions ¶
This section is empty.
Types ¶
type ErrorResponse ¶
type ErrorResponse struct {
Err error `json:"-"`
StatusCode int `json:"-"`
ErrorText string `json:"error"`
}
func ErrExecute ¶
func ErrExecute(err error) *ErrorResponse
func (*ErrorResponse) Error ¶
func (e *ErrorResponse) Error() string
func (*ErrorResponse) Render ¶
func (e *ErrorResponse) Render(w http.ResponseWriter, r *http.Request) error
func (*ErrorResponse) WithError ¶
func (e *ErrorResponse) WithError(err error) *ErrorResponse
type StreamRepository ¶
type StreamRepository struct {
// contains filtered or unexported fields
}
func NewStreamRepository ¶
func NewStreamRepository() *StreamRepository
func (*StreamRepository) Add ¶
func (r *StreamRepository) Add(id string, stream *Stream)
func (*StreamRepository) Remove ¶
func (r *StreamRepository) Remove(id string)
type WebSocket ¶
type WebSocket struct {
// contains filtered or unexported fields
}
func New ¶
func New( subscribe usecase.Command[*usecase.SubscribeCommandInput, *usecase.SubscribeCommandOutput], streams *StreamRepository, ) *WebSocket
Source Files
Click to show internal directories.
Click to hide internal directories.