streambiz

Documentation

Index

• func NewStreamBiz(streamRepo StreamRepo, channelRepo ChannelRepo, ps pubsub.Pubsub) *streamBiz
• type ChannelRepo
• type StreamBiz
• type StreamRepo

Functions

func NewStreamBiz

func NewStreamBiz(streamRepo StreamRepo, channelRepo ChannelRepo, ps pubsub.Pubsub) *streamBiz

Types

type ChannelRepo

type ChannelRepo interface {
	FindUserChannel(ctx context.Context, userId int) (*channelmodel.Channel, error)
}

type StreamBiz

type StreamBiz interface {
	Create(ctx context.Context, requester core.Requester, create *streammodel.StreamCreate) (*streammodel.StreamCreateResponse, error)
	FindStreamById(ctx context.Context, id int) (*streammodel.Stream, error)
	UpdateStreamState(ctx context.Context, requester core.Requester, id int, state string) error
	FindStreams(ctx context.Context, filter *streammodel.StreamFilter, paging *core.Paging) ([]streammodel.StreamList, error)
	UpdateStreamView(ctx context.Context, id, view int) error
}

type StreamRepo

type StreamRepo interface {
	Create(ctx context.Context, create *streammodel.StreamCreate) error
	FindStreamByID(ctx context.Context, id int) (*streammodel.Stream, error)
	UpdateStream(ctx context.Context, id int, update *streammodel.StreamUpdate) error
	FindStreams(ctx context.Context, filter *streammodel.StreamFilter, paging *core.Paging) ([]streammodel.StreamList, error)
	UpdateStreamView(ctx context.Context, id, view int) error
}