server

package
v0.0.0-...-646ff60 Latest Latest
Warning

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

 Go to latest Published: Nov 16, 2024 License: CC0-1.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ErrNoOAuthHandler 

type ErrNoOAuthHandler struct {
	Err error
}

func (ErrNoOAuthHandler) Error 

func (err ErrNoOAuthHandler) Error() string

func (ErrNoOAuthHandler) Unwrap 

func (err ErrNoOAuthHandler) Unwrap() error

type ErrNoOAuthHandlerForPort 

type ErrNoOAuthHandlerForPort struct {
	Port uint16
}

func (ErrNoOAuthHandlerForPort) Error 

func (err ErrNoOAuthHandlerForPort) Error() string

type GRPCServer 

type GRPCServer struct {
	streamd_grpc.UnimplementedStreamDServer
	StreamD               api.StreamD
	MemoizeDataValue      *memoize.MemoizeData
	OAuthURLHandlerLocker xsync.Mutex
	OAuthURLHandlers      oauthURLHandlers

	UnansweredOAuthRequestsLocker xsync.Mutex
	UnansweredOAuthRequests       map[streamcontrol.PlatformName]map[uint16]*streamd_grpc.OAuthRequest
}

func NewGRPCServer 

func NewGRPCServer(streamd api.StreamD) *GRPCServer

func (*GRPCServer) AddIncomingStream 

func (grpc *GRPCServer) AddIncomingStream(
	ctx context.Context,
	req *streamd_grpc.AddIncomingStreamRequest,
) (*streamd_grpc.AddIncomingStreamReply, error)

func (*GRPCServer) AddStreamDestination 

func (grpc *GRPCServer) AddStreamDestination(
	ctx context.Context,
	req *streamd_grpc.AddStreamDestinationRequest,
) (*streamd_grpc.AddStreamDestinationReply, error)

func (*GRPCServer) AddStreamForward 

func (grpc *GRPCServer) AddStreamForward(
	ctx context.Context,
	req *streamd_grpc.AddStreamForwardRequest,
) (*streamd_grpc.AddStreamForwardReply, error)

func (*GRPCServer) AddStreamPlayer 

func (grpc *GRPCServer) AddStreamPlayer(
	ctx context.Context,
	req *streamd_grpc.AddStreamPlayerRequest,
) (_ret *streamd_grpc.AddStreamPlayerReply, _err error)

func (*GRPCServer) AddTimer 

func (grpc *GRPCServer) AddTimer(
	ctx context.Context,
	req *streamd_grpc.AddTimerRequest,
) (*streamd_grpc.AddTimerReply, error)

func (*GRPCServer) AddTriggerRule 

func (grpc *GRPCServer) AddTriggerRule(
	ctx context.Context,
	req *streamd_grpc.AddTriggerRuleRequest,
) (*streamd_grpc.AddTriggerRuleReply, error)

func (*GRPCServer) ApplyProfile 

func (grpc *GRPCServer) ApplyProfile(
	ctx context.Context,
	req *streamd_grpc.ApplyProfileRequest,
) (*streamd_grpc.ApplyProfileReply, error)

func (*GRPCServer) BanUser 

func (grpc *GRPCServer) BanUser(
	ctx context.Context,
	req *streamd_grpc.BanUserRequest,
) (*streamd_grpc.BanUserReply, error)

func (*GRPCServer) Close 

func (grpc *GRPCServer) Close() error

func (*GRPCServer) EXPERIMENTAL_ReinitStreamControllers 

func (grpc *GRPCServer) EXPERIMENTAL_ReinitStreamControllers(
	ctx context.Context,
	in *streamd_grpc.EXPERIMENTAL_ReinitStreamControllersRequest,
) (*streamd_grpc.EXPERIMENTAL_ReinitStreamControllersReply, error)

func (*GRPCServer) EndStream 

func (grpc *GRPCServer) EndStream(
	ctx context.Context,
	req *streamd_grpc.EndStreamRequest,
) (*streamd_grpc.EndStreamReply, error)

func (*GRPCServer) GetBackendInfo 

func (grpc *GRPCServer) GetBackendInfo(
	ctx context.Context,
	req *streamd_grpc.GetBackendInfoRequest,
) (*streamd_grpc.GetBackendInfoReply, error)

func (*GRPCServer) GetConfig 

func (grpc *GRPCServer) GetConfig(
	ctx context.Context,
	req *streamd_grpc.GetConfigRequest,
) (*streamd_grpc.GetConfigReply, error)

func (*GRPCServer) GetLoggingLevel 

func (grpc *GRPCServer) GetLoggingLevel(
	ctx context.Context,
	req *streamd_grpc.GetLoggingLevelRequest,
) (*streamd_grpc.GetLoggingLevelReply, error)

func (*GRPCServer) GetStreamPlayer 

func (grpc *GRPCServer) GetStreamPlayer(
	ctx context.Context,
	req *streamd_grpc.GetStreamPlayerRequest,
) (*streamd_grpc.GetStreamPlayerReply, error)

func (*GRPCServer) GetStreamStatus 

func (grpc *GRPCServer) GetStreamStatus(
	ctx context.Context,
	req *streamd_grpc.GetStreamStatusRequest,
) (*streamd_grpc.GetStreamStatusReply, error)

func (*GRPCServer) GetVariable 

func (grpc *GRPCServer) GetVariable(
	ctx context.Context,
	req *streamd_grpc.GetVariableRequest,
) (*streamd_grpc.GetVariableReply, error)

func (*GRPCServer) GetVariableHash 

func (grpc *GRPCServer) GetVariableHash(
	ctx context.Context,
	req *streamd_grpc.GetVariableHashRequest,
) (*streamd_grpc.GetVariableHashReply, error)

func (*GRPCServer) InitCache 

func (grpc *GRPCServer) InitCache(
	ctx context.Context,
	req *streamd_grpc.InitCacheRequest,
) (*streamd_grpc.InitCacheReply, error)

func (*GRPCServer) IsBackendEnabled 

func (grpc *GRPCServer) IsBackendEnabled(
	ctx context.Context,
	req *streamd_grpc.IsBackendEnabledRequest,
) (*streamd_grpc.IsBackendEnabledReply, error)

func (*GRPCServer) ListIncomingStreams 

func (grpc *GRPCServer) ListIncomingStreams(
	ctx context.Context,
	req *streamd_grpc.ListIncomingStreamsRequest,
) (*streamd_grpc.ListIncomingStreamsReply, error)

func (*GRPCServer) ListStreamDestinations 

func (grpc *GRPCServer) ListStreamDestinations(
	ctx context.Context,
	req *streamd_grpc.ListStreamDestinationsRequest,
) (*streamd_grpc.ListStreamDestinationsReply, error)

func (*GRPCServer) ListStreamForwards 

func (grpc *GRPCServer) ListStreamForwards(
	ctx context.Context,
	req *streamd_grpc.ListStreamForwardsRequest,
) (*streamd_grpc.ListStreamForwardsReply, error)

func (*GRPCServer) ListStreamPlayers 

func (grpc *GRPCServer) ListStreamPlayers(
	ctx context.Context,
	req *streamd_grpc.ListStreamPlayersRequest,
) (*streamd_grpc.ListStreamPlayersReply, error)

func (*GRPCServer) ListStreamServers 

func (grpc *GRPCServer) ListStreamServers(
	ctx context.Context,
	_ *streamd_grpc.ListStreamServersRequest,
) (*streamd_grpc.ListStreamServersReply, error)

func (*GRPCServer) ListTimers 

func (grpc *GRPCServer) ListTimers(
	ctx context.Context,
	req *streamd_grpc.ListTimersRequest,
) (*streamd_grpc.ListTimersReply, error)

func (*GRPCServer) ListTriggerRules 

func (grpc *GRPCServer) ListTriggerRules(
	ctx context.Context,
	req *streamd_grpc.ListTriggerRulesRequest,
) (*streamd_grpc.ListTriggerRulesReply, error)

func (*GRPCServer) MemoizeData 

func (grpc *GRPCServer) MemoizeData() *memoize.MemoizeData

func (*GRPCServer) OpenBrowser 

func (grpc *GRPCServer) OpenBrowser(
	ctx context.Context,
	url string,
) (_ret error)

func (*GRPCServer) OpenOAuthURL 

func (grpc *GRPCServer) OpenOAuthURL(
	ctx context.Context,
	listenPort uint16,
	platID streamcontrol.PlatformName,
	authURL string,
) (_ret error)

func (*GRPCServer) Ping 

func (grpc *GRPCServer) Ping(
	ctx context.Context,
	req *streamd_grpc.PingRequest,
) (*streamd_grpc.PingReply, error)

func (*GRPCServer) RemoveChatMessage 

func (grpc *GRPCServer) RemoveChatMessage(
	ctx context.Context,
	req *streamd_grpc.RemoveChatMessageRequest,
) (*streamd_grpc.RemoveChatMessageReply, error)

func (*GRPCServer) RemoveIncomingStream 

func (grpc *GRPCServer) RemoveIncomingStream(
	ctx context.Context,
	req *streamd_grpc.RemoveIncomingStreamRequest,
) (*streamd_grpc.RemoveIncomingStreamReply, error)

func (*GRPCServer) RemoveStreamDestination 

func (grpc *GRPCServer) RemoveStreamDestination(
	ctx context.Context,
	req *streamd_grpc.RemoveStreamDestinationRequest,
) (*streamd_grpc.RemoveStreamDestinationReply, error)

func (*GRPCServer) RemoveStreamForward 

func (grpc *GRPCServer) RemoveStreamForward(
	ctx context.Context,
	req *streamd_grpc.RemoveStreamForwardRequest,
) (*streamd_grpc.RemoveStreamForwardReply, error)

func (*GRPCServer) RemoveStreamPlayer 

func (grpc *GRPCServer) RemoveStreamPlayer(
	ctx context.Context,
	req *streamd_grpc.RemoveStreamPlayerRequest,
) (_req *streamd_grpc.RemoveStreamPlayerReply, _err error)

func (*GRPCServer) RemoveTimer 

func (grpc *GRPCServer) RemoveTimer(
	ctx context.Context,
	req *streamd_grpc.RemoveTimerRequest,
) (*streamd_grpc.RemoveTimerReply, error)

func (*GRPCServer) RemoveTriggerRule 

func (grpc *GRPCServer) RemoveTriggerRule(
	ctx context.Context,
	req *streamd_grpc.RemoveTriggerRuleRequest,
) (*streamd_grpc.RemoveTriggerRuleReply, error)

func (*GRPCServer) ResetCache 

func (grpc *GRPCServer) ResetCache(
	ctx context.Context,
	req *streamd_grpc.ResetCacheRequest,
) (*streamd_grpc.ResetCacheReply, error)

func (*GRPCServer) SaveConfig 

func (grpc *GRPCServer) SaveConfig(
	ctx context.Context,
	req *streamd_grpc.SaveConfigRequest,
) (*streamd_grpc.SaveConfigReply, error)

func (*GRPCServer) SendChatMessage 

func (grpc *GRPCServer) SendChatMessage(
	ctx context.Context,
	req *streamd_grpc.SendChatMessageRequest,
) (*streamd_grpc.SendChatMessageReply, error)

func (*GRPCServer) SetConfig 

func (grpc *GRPCServer) SetConfig(
	ctx context.Context,
	req *streamd_grpc.SetConfigRequest,
) (*streamd_grpc.SetConfigReply, error)

func (*GRPCServer) SetDescription 

func (grpc *GRPCServer) SetDescription(
	ctx context.Context,
	req *streamd_grpc.SetDescriptionRequest,
) (*streamd_grpc.SetDescriptionReply, error)

func (*GRPCServer) SetLoggingLevel 

func (grpc *GRPCServer) SetLoggingLevel(
	ctx context.Context,
	req *streamd_grpc.SetLoggingLevelRequest,
) (*streamd_grpc.SetLoggingLevelReply, error)

func (*GRPCServer) SetTitle 

func (grpc *GRPCServer) SetTitle(
	ctx context.Context,
	req *streamd_grpc.SetTitleRequest,
) (*streamd_grpc.SetTitleReply, error)

func (*GRPCServer) SetVariable 

func (grpc *GRPCServer) SetVariable(
	ctx context.Context,
	req *streamd_grpc.SetVariableRequest,
) (*streamd_grpc.SetVariableReply, error)

func (*GRPCServer) StartStream 

func (grpc *GRPCServer) StartStream(
	ctx context.Context,
	req *streamd_grpc.StartStreamRequest,
) (*streamd_grpc.StartStreamReply, error)

func (*GRPCServer) StartStreamServer 

func (grpc *GRPCServer) StartStreamServer(
	ctx context.Context,
	req *streamd_grpc.StartStreamServerRequest,
) (*streamd_grpc.StartStreamServerReply, error)

func (*GRPCServer) StopStreamServer 

func (grpc *GRPCServer) StopStreamServer(
	ctx context.Context,
	req *streamd_grpc.StopStreamServerRequest,
) (*streamd_grpc.StopStreamServerReply, error)

func (*GRPCServer) StreamPlayerClose 

func (grpc *GRPCServer) StreamPlayerClose(
	ctx context.Context,
	req *streamd_grpc.StreamPlayerCloseRequest,
) (*streamd_grpc.StreamPlayerCloseReply, error)

func (*GRPCServer) StreamPlayerEndChan 

func (grpc *GRPCServer) StreamPlayerEndChan(
	req *streamd_grpc.StreamPlayerEndChanRequest,
	srv streamd_grpc.StreamD_StreamPlayerEndChanServer,
) error

func (*GRPCServer) StreamPlayerGetLength 

func (grpc *GRPCServer) StreamPlayerGetLength(
	ctx context.Context,
	req *streamd_grpc.StreamPlayerGetLengthRequest,
) (*streamd_grpc.StreamPlayerGetLengthReply, error)
func (grpc *GRPCServer) StreamPlayerGetLink(
	ctx context.Context,
	req *streamd_grpc.StreamPlayerGetLinkRequest,
) (*streamd_grpc.StreamPlayerGetLinkReply, error)

func (*GRPCServer) StreamPlayerGetPosition 

func (grpc *GRPCServer) StreamPlayerGetPosition(
	ctx context.Context,
	req *streamd_grpc.StreamPlayerGetPositionRequest,
) (*streamd_grpc.StreamPlayerGetPositionReply, error)

func (*GRPCServer) StreamPlayerIsEnded 

func (grpc *GRPCServer) StreamPlayerIsEnded(
	ctx context.Context,
	req *streamd_grpc.StreamPlayerIsEndedRequest,
) (*streamd_grpc.StreamPlayerIsEndedReply, error)

func (*GRPCServer) StreamPlayerOpen 

func (grpc *GRPCServer) StreamPlayerOpen(
	ctx context.Context,
	req *streamd_grpc.StreamPlayerOpenRequest,
) (*streamd_grpc.StreamPlayerOpenReply, error)

func (*GRPCServer) StreamPlayerProcessTitle 

func (grpc *GRPCServer) StreamPlayerProcessTitle(
	ctx context.Context,
	req *streamd_grpc.StreamPlayerProcessTitleRequest,
) (*streamd_grpc.StreamPlayerProcessTitleReply, error)

func (*GRPCServer) StreamPlayerSetPause 

func (grpc *GRPCServer) StreamPlayerSetPause(
	ctx context.Context,
	req *streamd_grpc.StreamPlayerSetPauseRequest,
) (*streamd_grpc.StreamPlayerSetPauseReply, error)

func (*GRPCServer) StreamPlayerSetSpeed 

func (grpc *GRPCServer) StreamPlayerSetSpeed(
	ctx context.Context,
	req *streamd_grpc.StreamPlayerSetSpeedRequest,
) (*streamd_grpc.StreamPlayerSetSpeedReply, error)

func (*GRPCServer) StreamPlayerStop 

func (grpc *GRPCServer) StreamPlayerStop(
	ctx context.Context,
	req *streamd_grpc.StreamPlayerStopRequest,
) (*streamd_grpc.StreamPlayerStopReply, error)

func (*GRPCServer) SubmitEvent 

func (grpc *GRPCServer) SubmitEvent(
	ctx context.Context,
	req *streamd_grpc.SubmitEventRequest,
) (*streamd_grpc.SubmitEventReply, error)

func (*GRPCServer) SubmitOAuthCode 

func (grpc *GRPCServer) SubmitOAuthCode(
	ctx context.Context,
	req *streamd_grpc.SubmitOAuthCodeRequest,
) (*streamd_grpc.SubmitOAuthCodeReply, error)

func (*GRPCServer) SubscribeToChatMessages 

func (grpc *GRPCServer) SubscribeToChatMessages(
	req *streamd_grpc.SubscribeToChatMessagesRequest,
	srv streamd_grpc.StreamD_SubscribeToChatMessagesServer,
) error

func (*GRPCServer) SubscribeToConfigChanges 

func (grpc *GRPCServer) SubscribeToConfigChanges(
	req *streamd_grpc.SubscribeToConfigChangesRequest,
	srv streamd_grpc.StreamD_SubscribeToConfigChangesServer,
) error

func (*GRPCServer) SubscribeToIncomingStreamsChanges 

func (grpc *GRPCServer) SubscribeToIncomingStreamsChanges(
	req *streamd_grpc.SubscribeToIncomingStreamsChangesRequest,
	srv streamd_grpc.StreamD_SubscribeToIncomingStreamsChangesServer,
) error

func (*GRPCServer) SubscribeToOAuthRequests 

func (grpc *GRPCServer) SubscribeToOAuthRequests(
	req *streamd_grpc.SubscribeToOAuthRequestsRequest,
	sender streamd_grpc.StreamD_SubscribeToOAuthRequestsServer,
) (_ret error)

func (*GRPCServer) SubscribeToStreamDestinationsChanges 

func (grpc *GRPCServer) SubscribeToStreamDestinationsChanges(
	req *streamd_grpc.SubscribeToStreamDestinationsChangesRequest,
	srv streamd_grpc.StreamD_SubscribeToStreamDestinationsChangesServer,
) error

func (*GRPCServer) SubscribeToStreamForwardsChanges 

func (grpc *GRPCServer) SubscribeToStreamForwardsChanges(
	req *streamd_grpc.SubscribeToStreamForwardsChangesRequest,
	srv streamd_grpc.StreamD_SubscribeToStreamForwardsChangesServer,
) error

func (*GRPCServer) SubscribeToStreamPlayersChanges 

func (grpc *GRPCServer) SubscribeToStreamPlayersChanges(
	req *streamd_grpc.SubscribeToStreamPlayersChangesRequest,
	srv streamd_grpc.StreamD_SubscribeToStreamPlayersChangesServer,
) error

func (*GRPCServer) SubscribeToStreamServersChanges 

func (grpc *GRPCServer) SubscribeToStreamServersChanges(
	req *streamd_grpc.SubscribeToStreamServersChangesRequest,
	srv streamd_grpc.StreamD_SubscribeToStreamServersChangesServer,
) error

func (*GRPCServer) SubscribeToStreamsChanges 

func (grpc *GRPCServer) SubscribeToStreamsChanges(
	req *streamd_grpc.SubscribeToStreamsChangesRequest,
	srv streamd_grpc.StreamD_SubscribeToStreamsChangesServer,
) error

func (*GRPCServer) UpdateStream 

func (grpc *GRPCServer) UpdateStream(
	ctx context.Context,
	req *streamd_grpc.UpdateStreamRequest,
) (*streamd_grpc.UpdateStreamReply, error)

func (*GRPCServer) UpdateStreamDestination 

func (grpc *GRPCServer) UpdateStreamDestination(
	ctx context.Context,
	req *streamd_grpc.UpdateStreamDestinationRequest,
) (*streamd_grpc.UpdateStreamDestinationReply, error)

func (*GRPCServer) UpdateStreamForward 

func (grpc *GRPCServer) UpdateStreamForward(
	ctx context.Context,
	req *streamd_grpc.UpdateStreamForwardRequest,
) (*streamd_grpc.UpdateStreamForwardReply, error)

func (*GRPCServer) UpdateStreamPlayer 

func (grpc *GRPCServer) UpdateStreamPlayer(
	ctx context.Context,
	req *streamd_grpc.UpdateStreamPlayerRequest,
) (_req *streamd_grpc.UpdateStreamPlayerReply, _err error)

func (*GRPCServer) UpdateTriggerRule 

func (grpc *GRPCServer) UpdateTriggerRule(
	ctx context.Context,
	req *streamd_grpc.UpdateTriggerRuleRequest,
) (*streamd_grpc.UpdateTriggerRuleReply, error)

func (*GRPCServer) WaitForStreamPublisher 

func (grpc *GRPCServer) WaitForStreamPublisher(
	req *streamd_grpc.WaitForStreamPublisherRequest,
	sender streamd_grpc.StreamD_WaitForStreamPublisherServer,
) (_ret error)

type OAuthURLHandler 

type OAuthURLHandler struct {
	Sender   streamd_grpc.StreamD_SubscribeToOAuthRequestsServer
	CancelFn context.CancelFunc
}

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.