monibuca

package
v0.0.1-alpha Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 15, 2020 License: GPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMonibucaHandler 

func RegisterMonibucaHandler(s server.Server, hdlr MonibucaHandler, opts ...server.HandlerOption) error

Types

type MonibucaHandler 

type MonibucaHandler interface {
	Play(context.Context, *PlayRequest, *PlayResponse) error
	Stop(context.Context, *StopRequest, *StopResponse) error
	Pull(context.Context, *PullRequest, *PullResponse) error
}

type MonibucaService 

type MonibucaService interface {
	Play(ctx context.Context, in *PlayRequest, opts ...client.CallOption) (*PlayResponse, error)
	Stop(ctx context.Context, in *StopRequest, opts ...client.CallOption) (*StopResponse, error)
	Pull(ctx context.Context, in *PullRequest, opts ...client.CallOption) (*PullResponse, error)
}

func NewMonibucaService 

func NewMonibucaService(name string, c client.Client) MonibucaService

type PlayRequest 

type PlayRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Username             string   `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	Password             string   `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	Streamid             int32    `protobuf:"varint,4,opt,name=streamid,proto3" json:"streamid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PlayRequest) Descriptor 

func (*PlayRequest) Descriptor() ([]byte, []int)

func (*PlayRequest) GetId 

func (m *PlayRequest) GetId() string

func (*PlayRequest) GetPassword 

func (m *PlayRequest) GetPassword() string

func (*PlayRequest) GetStreamid 

func (m *PlayRequest) GetStreamid() int32

func (*PlayRequest) GetUsername 

func (m *PlayRequest) GetUsername() string

func (*PlayRequest) ProtoMessage 

func (*PlayRequest) ProtoMessage()

func (*PlayRequest) Reset 

func (m *PlayRequest) Reset()

func (*PlayRequest) String 

func (m *PlayRequest) String() string

func (*PlayRequest) XXX_DiscardUnknown 

func (m *PlayRequest) XXX_DiscardUnknown()

func (*PlayRequest) XXX_Marshal 

func (m *PlayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlayRequest) XXX_Merge 

func (m *PlayRequest) XXX_Merge(src proto.Message)

func (*PlayRequest) XXX_Size 

func (m *PlayRequest) XXX_Size() int

func (*PlayRequest) XXX_Unmarshal 

func (m *PlayRequest) XXX_Unmarshal(b []byte) error

type PlayResponse 

type PlayResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PlayResponse) Descriptor 

func (*PlayResponse) Descriptor() ([]byte, []int)

func (*PlayResponse) ProtoMessage 

func (*PlayResponse) ProtoMessage()

func (*PlayResponse) Reset 

func (m *PlayResponse) Reset()

func (*PlayResponse) String 

func (m *PlayResponse) String() string

func (*PlayResponse) XXX_DiscardUnknown 

func (m *PlayResponse) XXX_DiscardUnknown()

func (*PlayResponse) XXX_Marshal 

func (m *PlayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlayResponse) XXX_Merge 

func (m *PlayResponse) XXX_Merge(src proto.Message)

func (*PlayResponse) XXX_Size 

func (m *PlayResponse) XXX_Size() int

func (*PlayResponse) XXX_Unmarshal 

func (m *PlayResponse) XXX_Unmarshal(b []byte) error

type PullRequest 

type PullRequest struct {
	Streamid             int32    `protobuf:"varint,1,opt,name=streamid,proto3" json:"streamid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PullRequest) Descriptor 

func (*PullRequest) Descriptor() ([]byte, []int)

func (*PullRequest) GetStreamid 

func (m *PullRequest) GetStreamid() int32

func (*PullRequest) ProtoMessage 

func (*PullRequest) ProtoMessage()

func (*PullRequest) Reset 

func (m *PullRequest) Reset()

func (*PullRequest) String 

func (m *PullRequest) String() string

func (*PullRequest) XXX_DiscardUnknown 

func (m *PullRequest) XXX_DiscardUnknown()

func (*PullRequest) XXX_Marshal 

func (m *PullRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullRequest) XXX_Merge 

func (m *PullRequest) XXX_Merge(src proto.Message)

func (*PullRequest) XXX_Size 

func (m *PullRequest) XXX_Size() int

func (*PullRequest) XXX_Unmarshal 

func (m *PullRequest) XXX_Unmarshal(b []byte) error

type PullResponse 

type PullResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PullResponse) Descriptor 

func (*PullResponse) Descriptor() ([]byte, []int)

func (*PullResponse) ProtoMessage 

func (*PullResponse) ProtoMessage()

func (*PullResponse) Reset 

func (m *PullResponse) Reset()

func (*PullResponse) String 

func (m *PullResponse) String() string

func (*PullResponse) XXX_DiscardUnknown 

func (m *PullResponse) XXX_DiscardUnknown()

func (*PullResponse) XXX_Marshal 

func (m *PullResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PullResponse) XXX_Merge 

func (m *PullResponse) XXX_Merge(src proto.Message)

func (*PullResponse) XXX_Size 

func (m *PullResponse) XXX_Size() int

func (*PullResponse) XXX_Unmarshal 

func (m *PullResponse) XXX_Unmarshal(b []byte) error

type StopRequest 

type StopRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Streamid             int32    `protobuf:"varint,2,opt,name=streamid,proto3" json:"streamid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopRequest) Descriptor 

func (*StopRequest) Descriptor() ([]byte, []int)

func (*StopRequest) GetId 

func (m *StopRequest) GetId() string

func (*StopRequest) GetStreamid 

func (m *StopRequest) GetStreamid() int32

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) Reset 

func (m *StopRequest) Reset()

func (*StopRequest) String 

func (m *StopRequest) String() string

func (*StopRequest) XXX_DiscardUnknown 

func (m *StopRequest) XXX_DiscardUnknown()

func (*StopRequest) XXX_Marshal 

func (m *StopRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopRequest) XXX_Merge 

func (m *StopRequest) XXX_Merge(src proto.Message)

func (*StopRequest) XXX_Size 

func (m *StopRequest) XXX_Size() int

func (*StopRequest) XXX_Unmarshal 

func (m *StopRequest) XXX_Unmarshal(b []byte) error

type StopResponse 

type StopResponse struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopResponse) Descriptor 

func (*StopResponse) Descriptor() ([]byte, []int)

func (*StopResponse) GetId 

func (m *StopResponse) GetId() string

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) Reset 

func (m *StopResponse) Reset()

func (*StopResponse) String 

func (m *StopResponse) String() string

func (*StopResponse) XXX_DiscardUnknown 

func (m *StopResponse) XXX_DiscardUnknown()

func (*StopResponse) XXX_Marshal 

func (m *StopResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopResponse) XXX_Merge 

func (m *StopResponse) XXX_Merge(src proto.Message)

func (*StopResponse) XXX_Size 

func (m *StopResponse) XXX_Size() int

func (*StopResponse) XXX_Unmarshal 

func (m *StopResponse) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.