rpc

package
Version: v0.0.0-...-f08620b Latest Latest
Warning

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

Go to latest
Published: Jun 1, 2020 License: MIT Imports: 24 Imported by: 0

Documentation

Overview

Package rpc is a generated twirp stub package. This code was generated with github.com/twitchtv/twirp/protoc-gen-twirp v5.5.0.

It is generated from these files:

radio.proto

Index

Constants

View Source
const AnnouncerPathPrefix = "/twirp/radio.Announcer/"

AnnouncerPathPrefix is used for all URL paths on a twirp Announcer server. Requests are always: POST AnnouncerPathPrefix/method It can be used in an HTTP mux to route twirp requests along with non-twirp requests on other routes.

View Source
const ManagerPathPrefix = "/twirp/radio.Manager/"

ManagerPathPrefix is used for all URL paths on a twirp Manager server. Requests are always: POST ManagerPathPrefix/method It can be used in an HTTP mux to route twirp requests along with non-twirp requests on other routes.

View Source
const QueuePathPrefix = "/twirp/radio.Queue/"

QueuePathPrefix is used for all URL paths on a twirp Queue server. Requests are always: POST QueuePathPrefix/method It can be used in an HTTP mux to route twirp requests along with non-twirp requests on other routes.

View Source
const StreamerPathPrefix = "/twirp/radio.Streamer/"

StreamerPathPrefix is used for all URL paths on a twirp Streamer server. Requests are always: POST StreamerPathPrefix/method It can be used in an HTTP mux to route twirp requests along with non-twirp requests on other routes.

Variables

This section is empty.

Functions

func NewAnnouncerClient

func NewAnnouncerClient(addr string, c HTTPClient) radio.AnnounceService

NewAnnouncerClient returns a new AnnouncerClient with the client connecting to the given addr and using the client given.

func NewManagerClient

func NewManagerClient(addr string, httpclient HTTPClient) radio.ManagerService

NewManagerClient returns a new client implementing radio.ManagerService

func NewQueueClient

func NewQueueClient(addr string, c HTTPClient) radio.QueueService

NewQueueClient returns a new client implement radio.QueueService

func NewStreamerClient

func NewStreamerClient(addr string, httpclient HTTPClient) radio.StreamerService

NewStreamerClient returns a new client implementing radio.StreamerService

func WriteError

func WriteError(resp http.ResponseWriter, err error)

WriteError writes an HTTP response with a valid Twirp error format. If err is not a twirp.Error, it will get wrapped with twirp.InternalErrorWith(err)

Types

type Announcer

type Announcer interface {
	AnnounceSong(context.Context, *SongAnnouncement) (*google_protobuf1.Empty, error)

	AnnounceRequest(context.Context, *SongRequestAnnouncement) (*google_protobuf1.Empty, error)
}

func NewAnnouncer

func NewAnnouncer(a radio.AnnounceService) Announcer

NewAnnouncer returns a new shim around the service given

func NewAnnouncerJSONClient

func NewAnnouncerJSONClient(addr string, client HTTPClient) Announcer

NewAnnouncerJSONClient creates a JSON client that implements the Announcer interface. It communicates using JSON and can be configured with a custom HTTPClient.

func NewAnnouncerProtobufClient

func NewAnnouncerProtobufClient(addr string, client HTTPClient) Announcer

NewAnnouncerProtobufClient creates a Protobuf client that implements the Announcer interface. It communicates using Protobuf and can be configured with a custom HTTPClient.

type AnnouncerClient

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

AnnouncerClient is a twirp client that implements radio.AnnounceService

func (AnnouncerClient) AnnounceRequest

func (a AnnouncerClient) AnnounceRequest(ctx context.Context, s radio.Song) error

AnnounceRequest implements radio.AnnounceService

func (AnnouncerClient) AnnounceSong

func (a AnnouncerClient) AnnounceSong(ctx context.Context, s radio.Status) error

AnnounceSong implements radio.AnnounceService

type AnnouncerShim

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

AnnouncerShim implements Announcer

func (AnnouncerShim) AnnounceRequest

func (as AnnouncerShim) AnnounceRequest(ctx context.Context, ar *SongRequestAnnouncement) (*empty.Empty, error)

AnnounceRequest implements Announcer

func (AnnouncerShim) AnnounceSong

func (as AnnouncerShim) AnnounceSong(ctx context.Context, a *SongAnnouncement) (*empty.Empty, error)

AnnounceSong implements Announcer

type DJ

type DJ struct {
	// DJ fields
	Id                   int32    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Regex                string   `protobuf:"bytes,3,opt,name=regex,proto3" json:"regex,omitempty"`
	Text                 string   `protobuf:"bytes,4,opt,name=text,proto3" json:"text,omitempty"`
	Image                string   `protobuf:"bytes,5,opt,name=image,proto3" json:"image,omitempty"`
	Visible              bool     `protobuf:"varint,6,opt,name=visible,proto3" json:"visible,omitempty"`
	Priority             int32    `protobuf:"varint,7,opt,name=priority,proto3" json:"priority,omitempty"`
	Role                 string   `protobuf:"bytes,8,opt,name=role,proto3" json:"role,omitempty"`
	Css                  string   `protobuf:"bytes,9,opt,name=css,proto3" json:"css,omitempty"`
	Color                string   `protobuf:"bytes,10,opt,name=color,proto3" json:"color,omitempty"`
	Theme                *Theme   `protobuf:"bytes,11,opt,name=theme,proto3" json:"theme,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DJ) Descriptor

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

func (*DJ) GetColor

func (m *DJ) GetColor() string

func (*DJ) GetCss

func (m *DJ) GetCss() string

func (*DJ) GetId

func (m *DJ) GetId() int32

func (*DJ) GetImage

func (m *DJ) GetImage() string

func (*DJ) GetName

func (m *DJ) GetName() string

func (*DJ) GetPriority

func (m *DJ) GetPriority() int32

func (*DJ) GetRegex

func (m *DJ) GetRegex() string

func (*DJ) GetRole

func (m *DJ) GetRole() string

func (*DJ) GetText

func (m *DJ) GetText() string

func (*DJ) GetTheme

func (m *DJ) GetTheme() *Theme

func (*DJ) GetVisible

func (m *DJ) GetVisible() bool

func (*DJ) ProtoMessage

func (*DJ) ProtoMessage()

func (*DJ) Reset

func (m *DJ) Reset()

func (*DJ) String

func (m *DJ) String() string

func (*DJ) XXX_DiscardUnknown

func (m *DJ) XXX_DiscardUnknown()

func (*DJ) XXX_Marshal

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

func (*DJ) XXX_Merge

func (dst *DJ) XXX_Merge(src proto.Message)

func (*DJ) XXX_Size

func (m *DJ) XXX_Size() int

func (*DJ) XXX_Unmarshal

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

type Error

type Error struct {
	Kind                 uint32             `protobuf:"varint,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Op                   string             `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"`
	SongId               int32              `protobuf:"varint,3,opt,name=song_id,json=songId,proto3" json:"song_id,omitempty"`
	TrackId              int32              `protobuf:"varint,4,opt,name=track_id,json=trackId,proto3" json:"track_id,omitempty"`
	Delay                *duration.Duration `protobuf:"bytes,5,opt,name=delay,proto3" json:"delay,omitempty"`
	Info                 string             `protobuf:"bytes,6,opt,name=info,proto3" json:"info,omitempty"`
	Error                string             `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Error) Descriptor

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

func (*Error) GetDelay

func (m *Error) GetDelay() *duration.Duration

func (*Error) GetError

func (m *Error) GetError() string

func (*Error) GetInfo

func (m *Error) GetInfo() string

func (*Error) GetKind

func (m *Error) GetKind() uint32

func (*Error) GetOp

func (m *Error) GetOp() string

func (*Error) GetSongId

func (m *Error) GetSongId() int32

func (*Error) GetTrackId

func (m *Error) GetTrackId() int32

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) Reset

func (m *Error) Reset()

func (*Error) String

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal

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

func (*Error) XXX_Merge

func (dst *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal

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

type HTTPClient

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

HTTPClient is the interface used by generated clients to send HTTP requests. It is fulfilled by *(net/http).Client, which is sufficient for most users. Users can provide their own implementation for special retry policies.

HTTPClient implementations should not follow redirects. Redirects are automatically disabled if *(net/http).Client is passed to client constructors. See the withoutRedirects function in this file for more details.

type ListenerInfo

type ListenerInfo struct {
	// the amount of listeners to the stream
	Listeners            int64    `protobuf:"varint,1,opt,name=listeners,proto3" json:"listeners,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListenerInfo) Descriptor

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

func (*ListenerInfo) GetListeners

func (m *ListenerInfo) GetListeners() int64

func (*ListenerInfo) ProtoMessage

func (*ListenerInfo) ProtoMessage()

func (*ListenerInfo) Reset

func (m *ListenerInfo) Reset()

func (*ListenerInfo) String

func (m *ListenerInfo) String() string

func (*ListenerInfo) XXX_DiscardUnknown

func (m *ListenerInfo) XXX_DiscardUnknown()

func (*ListenerInfo) XXX_Marshal

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

func (*ListenerInfo) XXX_Merge

func (dst *ListenerInfo) XXX_Merge(src proto.Message)

func (*ListenerInfo) XXX_Size

func (m *ListenerInfo) XXX_Size() int

func (*ListenerInfo) XXX_Unmarshal

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

type Manager

func NewManager

func NewManager(m radio.ManagerService) Manager

NewManager returns a new shim around the service given

func NewManagerJSONClient

func NewManagerJSONClient(addr string, client HTTPClient) Manager

NewManagerJSONClient creates a JSON client that implements the Manager interface. It communicates using JSON and can be configured with a custom HTTPClient.

func NewManagerProtobufClient

func NewManagerProtobufClient(addr string, client HTTPClient) Manager

NewManagerProtobufClient creates a Protobuf client that implements the Manager interface. It communicates using Protobuf and can be configured with a custom HTTPClient.

type ManagerClient

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

ManagerClient is a twirp client that implements radio.ManagerService

func (ManagerClient) Status

func (m ManagerClient) Status(ctx context.Context) (*radio.Status, error)

Status implements radio.ManagerService

func (ManagerClient) UpdateListeners

func (m ManagerClient) UpdateListeners(ctx context.Context, count int) error

UpdateListeners implements radio.ManagerService

func (ManagerClient) UpdateSong

func (m ManagerClient) UpdateSong(ctx context.Context, s radio.Song, i radio.SongInfo) error

UpdateSong implements radio.ManagerService

func (ManagerClient) UpdateThread

func (m ManagerClient) UpdateThread(ctx context.Context, thread string) error

UpdateThread implements radio.ManagerService

func (ManagerClient) UpdateUser

func (m ManagerClient) UpdateUser(ctx context.Context, n string, u radio.User) error

UpdateUser implements radio.ManagerService

type ManagerShim

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

ManagerShim implements Manager

func (ManagerShim) SetListenerInfo

func (m ManagerShim) SetListenerInfo(ctx context.Context, i *ListenerInfo) (*empty.Empty, error)

SetListenerInfo implements Manager

func (ManagerShim) SetSong

func (m ManagerShim) SetSong(ctx context.Context, su *SongUpdate) (*empty.Empty, error)

SetSong implements Manager

func (ManagerShim) SetStreamerConfig

func (m ManagerShim) SetStreamerConfig(ctx context.Context, c *StreamerConfig) (*empty.Empty, error)

SetStreamerConfig implements Manager

func (ManagerShim) SetThread

func (m ManagerShim) SetThread(ctx context.Context, t *wrappers.StringValue) (*empty.Empty, error)

SetThread implements Manager

func (ManagerShim) SetUser

func (m ManagerShim) SetUser(ctx context.Context, u *UserUpdate) (*empty.Empty, error)

SetUser implements Manager

func (ManagerShim) Status

func (m ManagerShim) Status(ctx context.Context, _ *empty.Empty) (*StatusResponse, error)

Status implements Manager

type Queue

Queue is documented under the radio.QueueService interface in the Go package

func NewQueue

func NewQueue(q radio.QueueService) Queue

NewQueue returns a new shim around the service given

func NewQueueJSONClient

func NewQueueJSONClient(addr string, client HTTPClient) Queue

NewQueueJSONClient creates a JSON client that implements the Queue interface. It communicates using JSON and can be configured with a custom HTTPClient.

func NewQueueProtobufClient

func NewQueueProtobufClient(addr string, client HTTPClient) Queue

NewQueueProtobufClient creates a Protobuf client that implements the Queue interface. It communicates using Protobuf and can be configured with a custom HTTPClient.

type QueueClient

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

QueueClient is a twirp client that implements radio.QueueService

func (QueueClient) AddRequest

func (q QueueClient) AddRequest(ctx context.Context, s radio.Song, identifier string) error

AddRequest implements radio.QueueService

func (QueueClient) Entries

func (q QueueClient) Entries(ctx context.Context) ([]radio.QueueEntry, error)

Entries implements radio.QueueService

func (QueueClient) Remove

func (q QueueClient) Remove(ctx context.Context, entry radio.QueueEntry) (bool, error)

Remove implements radio.QueueService

func (QueueClient) ReserveNext

func (q QueueClient) ReserveNext(ctx context.Context) (*radio.QueueEntry, error)

ReserveNext implements radio.QueueService

func (QueueClient) ResetReserved

func (q QueueClient) ResetReserved(ctx context.Context) error

type QueueEntry

type QueueEntry struct {
	Song *Song `protobuf:"bytes,1,opt,name=song,proto3" json:"song,omitempty"`
	// is_user_request indicates if this was a request made by a human
	IsUserRequest bool `protobuf:"varint,2,opt,name=is_user_request,json=isUserRequest,proto3" json:"is_user_request,omitempty"`
	// user_identifier is the way we identify the user that added this to the
	// queue; This can be anything that uniquely identifies a user
	UserIdentifier string `protobuf:"bytes,3,opt,name=user_identifier,json=userIdentifier,proto3" json:"user_identifier,omitempty"`
	// expected_start_time is the expected time this song will start playing
	ExpectedStartTime    *timestamp.Timestamp `protobuf:"bytes,4,opt,name=expected_start_time,json=expectedStartTime,proto3" json:"expected_start_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*QueueEntry) Descriptor

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

func (*QueueEntry) GetExpectedStartTime

func (m *QueueEntry) GetExpectedStartTime() *timestamp.Timestamp

func (*QueueEntry) GetIsUserRequest

func (m *QueueEntry) GetIsUserRequest() bool

func (*QueueEntry) GetSong

func (m *QueueEntry) GetSong() *Song

func (*QueueEntry) GetUserIdentifier

func (m *QueueEntry) GetUserIdentifier() string

func (*QueueEntry) ProtoMessage

func (*QueueEntry) ProtoMessage()

func (*QueueEntry) Reset

func (m *QueueEntry) Reset()

func (*QueueEntry) String

func (m *QueueEntry) String() string

func (*QueueEntry) XXX_DiscardUnknown

func (m *QueueEntry) XXX_DiscardUnknown()

func (*QueueEntry) XXX_Marshal

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

func (*QueueEntry) XXX_Merge

func (dst *QueueEntry) XXX_Merge(src proto.Message)

func (*QueueEntry) XXX_Size

func (m *QueueEntry) XXX_Size() int

func (*QueueEntry) XXX_Unmarshal

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

type QueueInfo

type QueueInfo struct {
	// the name of the queue implementation
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// the entries in the queue
	Entries              []*QueueEntry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*QueueInfo) Descriptor

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

func (*QueueInfo) GetEntries

func (m *QueueInfo) GetEntries() []*QueueEntry

func (*QueueInfo) GetName

func (m *QueueInfo) GetName() string

func (*QueueInfo) ProtoMessage

func (*QueueInfo) ProtoMessage()

func (*QueueInfo) Reset

func (m *QueueInfo) Reset()

func (*QueueInfo) String

func (m *QueueInfo) String() string

func (*QueueInfo) XXX_DiscardUnknown

func (m *QueueInfo) XXX_DiscardUnknown()

func (*QueueInfo) XXX_Marshal

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

func (*QueueInfo) XXX_Merge

func (dst *QueueInfo) XXX_Merge(src proto.Message)

func (*QueueInfo) XXX_Size

func (m *QueueInfo) XXX_Size() int

func (*QueueInfo) XXX_Unmarshal

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

type QueueShim

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

QueueShim implements Queue

func (QueueShim) AddRequest

func (q QueueShim) AddRequest(ctx context.Context, e *QueueEntry) (*empty.Empty, error)

AddRequest implements Queue

func (QueueShim) Entries

func (q QueueShim) Entries(ctx context.Context, _ *empty.Empty) (*QueueInfo, error)

Entries implements Queue

func (QueueShim) Remove

func (q QueueShim) Remove(ctx context.Context, e *QueueEntry) (*wrappers.BoolValue, error)

Remove implements Queue

func (QueueShim) ReserveNext

func (q QueueShim) ReserveNext(ctx context.Context, _ *empty.Empty) (*QueueEntry, error)

ReserveNext implements Queue

type RequestResponse

type RequestResponse struct {
	Error                []*Error `protobuf:"bytes,1,rep,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestResponse) Descriptor

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

func (*RequestResponse) GetError

func (m *RequestResponse) GetError() []*Error

func (*RequestResponse) ProtoMessage

func (*RequestResponse) ProtoMessage()

func (*RequestResponse) Reset

func (m *RequestResponse) Reset()

func (*RequestResponse) String

func (m *RequestResponse) String() string

func (*RequestResponse) XXX_DiscardUnknown

func (m *RequestResponse) XXX_DiscardUnknown()

func (*RequestResponse) XXX_Marshal

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

func (*RequestResponse) XXX_Merge

func (dst *RequestResponse) XXX_Merge(src proto.Message)

func (*RequestResponse) XXX_Size

func (m *RequestResponse) XXX_Size() int

func (*RequestResponse) XXX_Unmarshal

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

type Song

type Song struct {
	// song identifier (esong.id)
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// sha1 hexdigest of metadata contents
	Hash string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// short metadata
	Metadata string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// song length
	Length *duration.Duration `protobuf:"bytes,4,opt,name=length,proto3" json:"length,omitempty"`
	// last time this song was played
	LastPlayed *timestamp.Timestamp `protobuf:"bytes,5,opt,name=last_played,json=lastPlayed,proto3" json:"last_played,omitempty"`
	// DatabaseTrack fields
	TrackId       int32                `protobuf:"varint,16,opt,name=track_id,json=trackId,proto3" json:"track_id,omitempty"`
	Artist        string               `protobuf:"bytes,17,opt,name=artist,proto3" json:"artist,omitempty"`
	Title         string               `protobuf:"bytes,18,opt,name=title,proto3" json:"title,omitempty"`
	Album         string               `protobuf:"bytes,19,opt,name=album,proto3" json:"album,omitempty"`
	FilePath      string               `protobuf:"bytes,20,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	Tags          string               `protobuf:"bytes,21,opt,name=tags,proto3" json:"tags,omitempty"`
	Acceptor      string               `protobuf:"bytes,22,opt,name=acceptor,proto3" json:"acceptor,omitempty"`
	LastEditor    string               `protobuf:"bytes,23,opt,name=last_editor,json=lastEditor,proto3" json:"last_editor,omitempty"`
	Priority      int32                `protobuf:"varint,24,opt,name=priority,proto3" json:"priority,omitempty"`
	Usable        bool                 `protobuf:"varint,25,opt,name=usable,proto3" json:"usable,omitempty"`
	LastRequested *timestamp.Timestamp `protobuf:"bytes,26,opt,name=last_requested,json=lastRequested,proto3" json:"last_requested,omitempty"`
	RequestCount  int32                `protobuf:"varint,27,opt,name=request_count,json=requestCount,proto3" json:"request_count,omitempty"`
	RequestDelay  *duration.Duration   `protobuf:"bytes,28,opt,name=request_delay,json=requestDelay,proto3" json:"request_delay,omitempty"`
	// the time the fields above were acquired from the database
	SyncTime             *timestamp.Timestamp `protobuf:"bytes,100,opt,name=sync_time,json=syncTime,proto3" json:"sync_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Song) Descriptor

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

func (*Song) GetAcceptor

func (m *Song) GetAcceptor() string

func (*Song) GetAlbum

func (m *Song) GetAlbum() string

func (*Song) GetArtist

func (m *Song) GetArtist() string

func (*Song) GetFilePath

func (m *Song) GetFilePath() string

func (*Song) GetHash

func (m *Song) GetHash() string

func (*Song) GetId

func (m *Song) GetId() int32

func (*Song) GetLastEditor

func (m *Song) GetLastEditor() string

func (*Song) GetLastPlayed

func (m *Song) GetLastPlayed() *timestamp.Timestamp

func (*Song) GetLastRequested

func (m *Song) GetLastRequested() *timestamp.Timestamp

func (*Song) GetLength

func (m *Song) GetLength() *duration.Duration

func (*Song) GetMetadata

func (m *Song) GetMetadata() string

func (*Song) GetPriority

func (m *Song) GetPriority() int32

func (*Song) GetRequestCount

func (m *Song) GetRequestCount() int32

func (*Song) GetRequestDelay

func (m *Song) GetRequestDelay() *duration.Duration

func (*Song) GetSyncTime

func (m *Song) GetSyncTime() *timestamp.Timestamp

func (*Song) GetTags

func (m *Song) GetTags() string

func (*Song) GetTitle

func (m *Song) GetTitle() string

func (*Song) GetTrackId

func (m *Song) GetTrackId() int32

func (*Song) GetUsable

func (m *Song) GetUsable() bool

func (*Song) ProtoMessage

func (*Song) ProtoMessage()

func (*Song) Reset

func (m *Song) Reset()

func (*Song) String

func (m *Song) String() string

func (*Song) XXX_DiscardUnknown

func (m *Song) XXX_DiscardUnknown()

func (*Song) XXX_Marshal

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

func (*Song) XXX_Merge

func (dst *Song) XXX_Merge(src proto.Message)

func (*Song) XXX_Size

func (m *Song) XXX_Size() int

func (*Song) XXX_Unmarshal

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

type SongAnnouncement

type SongAnnouncement struct {
	Song                 *Song         `protobuf:"bytes,1,opt,name=song,proto3" json:"song,omitempty"`
	Info                 *SongInfo     `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	ListenerInfo         *ListenerInfo `protobuf:"bytes,3,opt,name=listener_info,json=listenerInfo,proto3" json:"listener_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*SongAnnouncement) Descriptor

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

func (*SongAnnouncement) GetInfo

func (m *SongAnnouncement) GetInfo() *SongInfo

func (*SongAnnouncement) GetListenerInfo

func (m *SongAnnouncement) GetListenerInfo() *ListenerInfo

func (*SongAnnouncement) GetSong

func (m *SongAnnouncement) GetSong() *Song

func (*SongAnnouncement) ProtoMessage

func (*SongAnnouncement) ProtoMessage()

func (*SongAnnouncement) Reset

func (m *SongAnnouncement) Reset()

func (*SongAnnouncement) String

func (m *SongAnnouncement) String() string

func (*SongAnnouncement) XXX_DiscardUnknown

func (m *SongAnnouncement) XXX_DiscardUnknown()

func (*SongAnnouncement) XXX_Marshal

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

func (*SongAnnouncement) XXX_Merge

func (dst *SongAnnouncement) XXX_Merge(src proto.Message)

func (*SongAnnouncement) XXX_Size

func (m *SongAnnouncement) XXX_Size() int

func (*SongAnnouncement) XXX_Unmarshal

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

type SongInfo

type SongInfo struct {
	// the time this song started playing
	StartTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// the time this song will end playing
	EndTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// indicates if the song is a fallback track
	IsFallback           bool     `protobuf:"varint,5,opt,name=is_fallback,json=isFallback,proto3" json:"is_fallback,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SongInfo) Descriptor

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

func (*SongInfo) GetEndTime

func (m *SongInfo) GetEndTime() *timestamp.Timestamp

func (*SongInfo) GetIsFallback

func (m *SongInfo) GetIsFallback() bool

func (*SongInfo) GetStartTime

func (m *SongInfo) GetStartTime() *timestamp.Timestamp

func (*SongInfo) ProtoMessage

func (*SongInfo) ProtoMessage()

func (*SongInfo) Reset

func (m *SongInfo) Reset()

func (*SongInfo) String

func (m *SongInfo) String() string

func (*SongInfo) XXX_DiscardUnknown

func (m *SongInfo) XXX_DiscardUnknown()

func (*SongInfo) XXX_Marshal

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

func (*SongInfo) XXX_Merge

func (dst *SongInfo) XXX_Merge(src proto.Message)

func (*SongInfo) XXX_Size

func (m *SongInfo) XXX_Size() int

func (*SongInfo) XXX_Unmarshal

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

type SongRequest

type SongRequest struct {
	UserIdentifier       string   `protobuf:"bytes,1,opt,name=user_identifier,json=userIdentifier,proto3" json:"user_identifier,omitempty"`
	Song                 *Song    `protobuf:"bytes,2,opt,name=song,proto3" json:"song,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SongRequest) Descriptor

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

func (*SongRequest) GetSong

func (m *SongRequest) GetSong() *Song

func (*SongRequest) GetUserIdentifier

func (m *SongRequest) GetUserIdentifier() string

func (*SongRequest) ProtoMessage

func (*SongRequest) ProtoMessage()

func (*SongRequest) Reset

func (m *SongRequest) Reset()

func (*SongRequest) String

func (m *SongRequest) String() string

func (*SongRequest) XXX_DiscardUnknown

func (m *SongRequest) XXX_DiscardUnknown()

func (*SongRequest) XXX_Marshal

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

func (*SongRequest) XXX_Merge

func (dst *SongRequest) XXX_Merge(src proto.Message)

func (*SongRequest) XXX_Size

func (m *SongRequest) XXX_Size() int

func (*SongRequest) XXX_Unmarshal

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

type SongRequestAnnouncement

type SongRequestAnnouncement struct {
	Song                 *Song    `protobuf:"bytes,1,opt,name=song,proto3" json:"song,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SongRequestAnnouncement) Descriptor

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

func (*SongRequestAnnouncement) GetSong

func (m *SongRequestAnnouncement) GetSong() *Song

func (*SongRequestAnnouncement) ProtoMessage

func (*SongRequestAnnouncement) ProtoMessage()

func (*SongRequestAnnouncement) Reset

func (m *SongRequestAnnouncement) Reset()

func (*SongRequestAnnouncement) String

func (m *SongRequestAnnouncement) String() string

func (*SongRequestAnnouncement) XXX_DiscardUnknown

func (m *SongRequestAnnouncement) XXX_DiscardUnknown()

func (*SongRequestAnnouncement) XXX_Marshal

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

func (*SongRequestAnnouncement) XXX_Merge

func (dst *SongRequestAnnouncement) XXX_Merge(src proto.Message)

func (*SongRequestAnnouncement) XXX_Size

func (m *SongRequestAnnouncement) XXX_Size() int

func (*SongRequestAnnouncement) XXX_Unmarshal

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

type SongUpdate

type SongUpdate struct {
	Song                 *Song     `protobuf:"bytes,1,opt,name=song,proto3" json:"song,omitempty"`
	Info                 *SongInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*SongUpdate) Descriptor

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

func (*SongUpdate) GetInfo

func (m *SongUpdate) GetInfo() *SongInfo

func (*SongUpdate) GetSong

func (m *SongUpdate) GetSong() *Song

func (*SongUpdate) ProtoMessage

func (*SongUpdate) ProtoMessage()

func (*SongUpdate) Reset

func (m *SongUpdate) Reset()

func (*SongUpdate) String

func (m *SongUpdate) String() string

func (*SongUpdate) XXX_DiscardUnknown

func (m *SongUpdate) XXX_DiscardUnknown()

func (*SongUpdate) XXX_Marshal

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

func (*SongUpdate) XXX_Merge

func (dst *SongUpdate) XXX_Merge(src proto.Message)

func (*SongUpdate) XXX_Size

func (m *SongUpdate) XXX_Size() int

func (*SongUpdate) XXX_Unmarshal

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

type StatusResponse

type StatusResponse struct {
	// the current user that is streaming
	User *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// the current song being played
	Song *Song `protobuf:"bytes,2,opt,name=song,proto3" json:"song,omitempty"`
	// information about the current song
	Info *SongInfo `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	// information about the current listeners
	ListenerInfo *ListenerInfo `protobuf:"bytes,4,opt,name=listener_info,json=listenerInfo,proto3" json:"listener_info,omitempty"`
	// the current thread to be shown on the website or elsewhere
	Thread string `protobuf:"bytes,5,opt,name=thread,proto3" json:"thread,omitempty"`
	// the current configuration of the streamer
	StreamerConfig *StreamerConfig `protobuf:"bytes,6,opt,name=streamer_config,json=streamerConfig,proto3" json:"streamer_config,omitempty"`
	// the display name given to us by the streaming user
	StreamerName         string   `protobuf:"bytes,7,opt,name=streamer_name,json=streamerName,proto3" json:"streamer_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatusResponse) Descriptor

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

func (*StatusResponse) GetInfo

func (m *StatusResponse) GetInfo() *SongInfo

func (*StatusResponse) GetListenerInfo

func (m *StatusResponse) GetListenerInfo() *ListenerInfo

func (*StatusResponse) GetSong

func (m *StatusResponse) GetSong() *Song

func (*StatusResponse) GetStreamerConfig

func (m *StatusResponse) GetStreamerConfig() *StreamerConfig

func (*StatusResponse) GetStreamerName

func (m *StatusResponse) GetStreamerName() string

func (*StatusResponse) GetThread

func (m *StatusResponse) GetThread() string

func (*StatusResponse) GetUser

func (m *StatusResponse) GetUser() *User

func (*StatusResponse) ProtoMessage

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset

func (m *StatusResponse) Reset()

func (*StatusResponse) String

func (m *StatusResponse) String() string

func (*StatusResponse) XXX_DiscardUnknown

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal

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

func (*StatusResponse) XXX_Merge

func (dst *StatusResponse) XXX_Merge(src proto.Message)

func (*StatusResponse) XXX_Size

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal

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

type Streamer

type Streamer interface {
	// Start starts the streamer
	Start(context.Context, *google_protobuf1.Empty) (*StreamerResponse, error)

	// Stop stops the streamer, the boolean argument indicates if we should stop
	// right away, or wait until the current song ends
	Stop(context.Context, *google_protobuf2.BoolValue) (*StreamerResponse, error)

	// RequestSong requests a song to be played by the streamer
	RequestSong(context.Context, *SongRequest) (*RequestResponse, error)

	// SetConfig changes the configuration of the streamer
	SetConfig(context.Context, *StreamerConfig) (*google_protobuf1.Empty, error)

	// Queue returns the current queue contents of the streamer
	Queue(context.Context, *google_protobuf1.Empty) (*QueueInfo, error)
}

func NewStreamer

func NewStreamer(s radio.StreamerService) Streamer

NewStreamer returns a new shim around the service given

func NewStreamerJSONClient

func NewStreamerJSONClient(addr string, client HTTPClient) Streamer

NewStreamerJSONClient creates a JSON client that implements the Streamer interface. It communicates using JSON and can be configured with a custom HTTPClient.

func NewStreamerProtobufClient

func NewStreamerProtobufClient(addr string, client HTTPClient) Streamer

NewStreamerProtobufClient creates a Protobuf client that implements the Streamer interface. It communicates using Protobuf and can be configured with a custom HTTPClient.

type StreamerClient

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

StreamerClient is a twirp client that implements radio.StreamerService

func (StreamerClient) Queue

func (s StreamerClient) Queue(ctx context.Context) ([]radio.QueueEntry, error)

Queue implements radio.StreamerService

func (StreamerClient) RequestSong

func (s StreamerClient) RequestSong(ctx context.Context, song radio.Song, identifier string) error

RequestSong implements radio.StreamerService

func (StreamerClient) Start

func (s StreamerClient) Start(ctx context.Context) error

Start implements radio.StreamerService

func (StreamerClient) Stop

func (s StreamerClient) Stop(ctx context.Context, force bool) error

Stop implements radio.StreamerService

type StreamerConfig

type StreamerConfig struct {
	// can users request songs to be played right now
	RequestsEnabled bool `protobuf:"varint,1,opt,name=requests_enabled,json=requestsEnabled,proto3" json:"requests_enabled,omitempty"`
	// the queue implementation to use for the streamer
	QueueUsed            string   `protobuf:"bytes,2,opt,name=queue_used,json=queueUsed,proto3" json:"queue_used,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamerConfig) Descriptor

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

func (*StreamerConfig) GetQueueUsed

func (m *StreamerConfig) GetQueueUsed() string

func (*StreamerConfig) GetRequestsEnabled

func (m *StreamerConfig) GetRequestsEnabled() bool

func (*StreamerConfig) ProtoMessage

func (*StreamerConfig) ProtoMessage()

func (*StreamerConfig) Reset

func (m *StreamerConfig) Reset()

func (*StreamerConfig) String

func (m *StreamerConfig) String() string

func (*StreamerConfig) XXX_DiscardUnknown

func (m *StreamerConfig) XXX_DiscardUnknown()

func (*StreamerConfig) XXX_Marshal

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

func (*StreamerConfig) XXX_Merge

func (dst *StreamerConfig) XXX_Merge(src proto.Message)

func (*StreamerConfig) XXX_Size

func (m *StreamerConfig) XXX_Size() int

func (*StreamerConfig) XXX_Unmarshal

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

type StreamerResponse

type StreamerResponse struct {
	Error                []*Error `protobuf:"bytes,1,rep,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamerResponse) Descriptor

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

func (*StreamerResponse) GetError

func (m *StreamerResponse) GetError() []*Error

func (*StreamerResponse) ProtoMessage

func (*StreamerResponse) ProtoMessage()

func (*StreamerResponse) Reset

func (m *StreamerResponse) Reset()

func (*StreamerResponse) String

func (m *StreamerResponse) String() string

func (*StreamerResponse) XXX_DiscardUnknown

func (m *StreamerResponse) XXX_DiscardUnknown()

func (*StreamerResponse) XXX_Marshal

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

func (*StreamerResponse) XXX_Merge

func (dst *StreamerResponse) XXX_Merge(src proto.Message)

func (*StreamerResponse) XXX_Size

func (m *StreamerResponse) XXX_Size() int

func (*StreamerResponse) XXX_Unmarshal

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

type StreamerShim

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

StreamerShim implements Streamer

func (StreamerShim) Queue

func (ss StreamerShim) Queue(ctx context.Context, _ *empty.Empty) (*QueueInfo, error)

Queue implements Streamer

func (StreamerShim) RequestSong

func (ss StreamerShim) RequestSong(ctx context.Context, req *SongRequest) (*RequestResponse, error)

RequestSong implements Streamer

func (StreamerShim) SetConfig

func (ss StreamerShim) SetConfig(ctx context.Context, c *StreamerConfig) (*empty.Empty, error)

SetConfig implements Streamer

func (StreamerShim) Start

Start implements Streamer

func (StreamerShim) Stop

Stop implements Streamer

type Theme

type Theme struct {
	Id                   int32    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	DisplayName          string   `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	Author               string   `protobuf:"bytes,4,opt,name=author,proto3" json:"author,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Theme) Descriptor

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

func (*Theme) GetAuthor

func (m *Theme) GetAuthor() string

func (*Theme) GetDisplayName

func (m *Theme) GetDisplayName() string

func (*Theme) GetId

func (m *Theme) GetId() int32

func (*Theme) GetName

func (m *Theme) GetName() string

func (*Theme) ProtoMessage

func (*Theme) ProtoMessage()

func (*Theme) Reset

func (m *Theme) Reset()

func (*Theme) String

func (m *Theme) String() string

func (*Theme) XXX_DiscardUnknown

func (m *Theme) XXX_DiscardUnknown()

func (*Theme) XXX_Marshal

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

func (*Theme) XXX_Merge

func (dst *Theme) XXX_Merge(src proto.Message)

func (*Theme) XXX_Size

func (m *Theme) XXX_Size() int

func (*Theme) XXX_Unmarshal

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

type TwirpServer

type TwirpServer interface {
	http.Handler
	// ServiceDescriptor returns gzipped bytes describing the .proto file that
	// this service was generated from. Once unzipped, the bytes can be
	// unmarshalled as a
	// github.com/golang/protobuf/protoc-gen-go/descriptor.FileDescriptorProto.
	//
	// The returned integer is the index of this particular service within that
	// FileDescriptorProto's 'Service' slice of ServiceDescriptorProtos. This is a
	// low-level field, expected to be used for reflection.
	ServiceDescriptor() ([]byte, int)
	// ProtocGenTwirpVersion is the semantic version string of the version of
	// twirp used to generate this file.
	ProtocGenTwirpVersion() string
}

TwirpServer is the interface generated server structs will support: they're HTTP handlers with additional methods for accessing metadata about the service. Those accessors are a low-level API for building reflection tools. Most people can think of TwirpServers as just http.Handlers.

func NewAnnouncerServer

func NewAnnouncerServer(svc Announcer, hooks *twirp.ServerHooks) TwirpServer

func NewManagerServer

func NewManagerServer(svc Manager, hooks *twirp.ServerHooks) TwirpServer

func NewQueueServer

func NewQueueServer(svc Queue, hooks *twirp.ServerHooks) TwirpServer

func NewStreamerServer

func NewStreamerServer(svc Streamer, hooks *twirp.ServerHooks) TwirpServer

type User

type User struct {
	// user fields
	Id                   int32                `protobuf:"varint,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"`
	Email                string               `protobuf:"bytes,4,opt,name=email,proto3" json:"email,omitempty"`
	RememberToken        string               `protobuf:"bytes,5,opt,name=remember_token,json=rememberToken,proto3" json:"remember_token,omitempty"`
	Ip                   string               `protobuf:"bytes,6,opt,name=ip,proto3" json:"ip,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	DeletedAt            *timestamp.Timestamp `protobuf:"bytes,8,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Dj                   *DJ                  `protobuf:"bytes,10,opt,name=dj,proto3" json:"dj,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*User) Descriptor

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

func (*User) GetCreatedAt

func (m *User) GetCreatedAt() *timestamp.Timestamp

func (*User) GetDeletedAt

func (m *User) GetDeletedAt() *timestamp.Timestamp

func (*User) GetDj

func (m *User) GetDj() *DJ

func (*User) GetEmail

func (m *User) GetEmail() string

func (*User) GetId

func (m *User) GetId() int32

func (*User) GetIp

func (m *User) GetIp() string

func (*User) GetPassword

func (m *User) GetPassword() string

func (*User) GetRememberToken

func (m *User) GetRememberToken() string

func (*User) GetUpdatedAt

func (m *User) GetUpdatedAt() *timestamp.Timestamp

func (*User) GetUsername

func (m *User) GetUsername() string

func (*User) ProtoMessage

func (*User) ProtoMessage()

func (*User) Reset

func (m *User) Reset()

func (*User) String

func (m *User) String() string

func (*User) XXX_DiscardUnknown

func (m *User) XXX_DiscardUnknown()

func (*User) XXX_Marshal

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

func (*User) XXX_Merge

func (dst *User) XXX_Merge(src proto.Message)

func (*User) XXX_Size

func (m *User) XXX_Size() int

func (*User) XXX_Unmarshal

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

type UserUpdate

type UserUpdate struct {
	User                 *User    `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	StreamerName         string   `protobuf:"bytes,2,opt,name=streamer_name,json=streamerName,proto3" json:"streamer_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserUpdate) Descriptor

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

func (*UserUpdate) GetStreamerName

func (m *UserUpdate) GetStreamerName() string

func (*UserUpdate) GetUser

func (m *UserUpdate) GetUser() *User

func (*UserUpdate) ProtoMessage

func (*UserUpdate) ProtoMessage()

func (*UserUpdate) Reset

func (m *UserUpdate) Reset()

func (*UserUpdate) String

func (m *UserUpdate) String() string

func (*UserUpdate) XXX_DiscardUnknown

func (m *UserUpdate) XXX_DiscardUnknown()

func (*UserUpdate) XXX_Marshal

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

func (*UserUpdate) XXX_Merge

func (dst *UserUpdate) XXX_Merge(src proto.Message)

func (*UserUpdate) XXX_Size

func (m *UserUpdate) XXX_Size() int

func (*UserUpdate) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL