biz

Documentation

Index

• Variables
• type Channel
• type ChannelRepo
• type KakaUseCase
  • func NewKakaUseCase(logger log.Logger, repo ChannelRepo) *KakaUseCase
  • func (uc *KakaUseCase) CreateChannel(ctx context.Context) (*Channel, error)
  • func (uc *KakaUseCase) GetChannel(ctx context.Context, id string) (*Channel, error)
  • func (uc *KakaUseCase) ListChannels(ctx context.Context) ([]*Channel, error)
  • func (uc *KakaUseCase) SetChannelPresentationDescription(ctx context.Context, id string, sdp *sdp.Message, raw []byte) error

Variables

var ProviderSet = wire.NewSet(NewKakaUseCase)

Types

type Channel

type Channel struct {
	Id     string
	Source rtsp.Transaction
	SDP    *sdp.Message
	RawSDP []byte
	// contains filtered or unexported fields
}

type ChannelRepo

type ChannelRepo interface {
	Create(ctx context.Context, id string) (*Channel, error)
	Get(ctx context.Context, id string) (*Channel, error)
	Delete(ctx context.Context, id string) error
	List(ctx context.Context) ([]*Channel, error)
}

type KakaUseCase

type KakaUseCase struct {
	// contains filtered or unexported fields
}

func NewKakaUseCase

func NewKakaUseCase(logger log.Logger, repo ChannelRepo) *KakaUseCase

func (*KakaUseCase) CreateChannel

func (uc *KakaUseCase) CreateChannel(ctx context.Context) (*Channel, error)

func (*KakaUseCase) GetChannel

func (uc *KakaUseCase) GetChannel(ctx context.Context, id string) (*Channel, error)

func (*KakaUseCase) ListChannels

func (uc *KakaUseCase) ListChannels(ctx context.Context) ([]*Channel, error)

func (*KakaUseCase) SetChannelPresentationDescription

func (uc *KakaUseCase) SetChannelPresentationDescription(ctx context.Context, id string, sdp *sdp.Message, raw []byte) error