goconv

Documentation

Index

• func ActionGRPC2Go(actionGRPC *streamd_grpc.Action) (action.Action, error)
• func ActionGo2GRPC(input action.Action) (*streamd_grpc.Action, error)
• func BackendDataGRPC2Go(platID streamcontrol.PlatformName, dataString string) (any, error)
• func CapabilitiesGRPC2Go(ctx context.Context, caps []streamd_grpc.Capability) map[streamcontrol.Capability]struct{}
• func CapabilitiesGo2GRPC(ctx context.Context, caps map[streamcontrol.Capability]struct{}) []streamd_grpc.Capability
• func CertificateX509GRPC2Go(cert *streamd_grpc.TLSCertificate_X509) (*x509.Certificate, error)
• func EventGRPC2Go(in *streamd_grpc.Event) (config.Event, error)
• func EventGo2GRPC(in event.Event) (*streamd_grpc.Event, error)
• func EventQueryGRPC2Go(in *streamd_grpc.EventQuery) (config.EventQuery, error)
• func EventQueryGo2GRPC(in eventquery.EventQuery) (*streamd_grpc.EventQuery, error)
• func LoggingLevelGRPC2Go(level streamd_grpc.LoggingLevel) logger.Level
• func LoggingLevelGo2GRPC(level logger.Level) streamd_grpc.LoggingLevel
• func PrivateKeyGRPC2Go(privKey *streamd_grpc.PrivateKey) (crypto.PrivateKey, error)
• func PrivateKeyPKCS8GRPC2Go(privKey *streamd_grpc.PrivateKey_PKCS8) (crypto.PrivateKey, error)
• func ProfileGRPC2Go(platID streamcontrol.PlatformName, profileString string) (streamcontrol.AbstractStreamProfile, error)
• func ProfileGo2GRPC(profile streamcontrol.AbstractStreamProfile) (string, error)
• func StreamPlaybackConfigGRPC2Go(cfg *streamd_grpc.StreamPlaybackConfig) sptypes.Config
• func StreamPlaybackConfigGo2GRPC(cfg *sptypes.Config) *streamd_grpc.StreamPlaybackConfig
• func StreamPlayerTypeGRPC2Go(playerType streamd_grpc.PlayerType) player.Backend
• func StreamPlayerTypeGo2GRPC(playerType player.Backend) streamd_grpc.PlayerType
• func StreamServerConfigGRPC2Go(ctx context.Context, srv *streamd_grpc.StreamServer) (api.StreamServerType, string, streamportserver.Options, error)
• func StreamServerConfigGo2GRPC(ctx context.Context, serverType api.StreamServerType, listenAddr string, ...) (*streamd_grpc.StreamServer, error)
• func StreamServerTypeGRPC2Go(t streamd_grpc.StreamServerType) (api.StreamServerType, error)
• func StreamServerTypeGo2GRPC(t api.StreamServerType) (streamd_grpc.StreamServerType, error)
• func TLSCertificateGRPC2Go(cert *streamd_grpc.TLSCertificate) (*x509.Certificate, error)
• func TriggerRuleGRPC2Go(rule *streamd_grpc.TriggerRule) (*api.TriggerRule, error)
• func TriggerRuleGo2GRPC(rule *api.TriggerRule) (*streamd_grpc.TriggerRule, error)
• func UnixGRPC2Go(unixNano int64) time.Time

Functions

func ActionGRPC2Go

func ActionGRPC2Go(
	actionGRPC *streamd_grpc.Action,
) (action.Action, error)

func ActionGo2GRPC

func ActionGo2GRPC(
	input action.Action,
) (*streamd_grpc.Action, error)

func BackendDataGRPC2Go

func BackendDataGRPC2Go(
	platID streamcontrol.PlatformName,
	dataString string,
) (any, error)

func CapabilitiesGRPC2Go

func CapabilitiesGRPC2Go(
	ctx context.Context,
	caps []streamd_grpc.Capability,
) map[streamcontrol.Capability]struct{}

func CapabilitiesGo2GRPC

func CapabilitiesGo2GRPC(
	ctx context.Context,
	caps map[streamcontrol.Capability]struct{},
) []streamd_grpc.Capability

func CertificateX509GRPC2Go

func CertificateX509GRPC2Go(cert *streamd_grpc.TLSCertificate_X509) (*x509.Certificate, error)

func EventGRPC2Go

func EventGRPC2Go(in *streamd_grpc.Event) (config.Event, error)

func EventGo2GRPC

func EventGo2GRPC(in event.Event) (*streamd_grpc.Event, error)

func EventQueryGRPC2Go

func EventQueryGRPC2Go(in *streamd_grpc.EventQuery) (config.EventQuery, error)

func EventQueryGo2GRPC

func EventQueryGo2GRPC(in eventquery.EventQuery) (*streamd_grpc.EventQuery, error)

func LoggingLevelGRPC2Go

func LoggingLevelGRPC2Go(level streamd_grpc.LoggingLevel) logger.Level

func LoggingLevelGo2GRPC

func LoggingLevelGo2GRPC(level logger.Level) streamd_grpc.LoggingLevel

func PrivateKeyGRPC2Go

func PrivateKeyGRPC2Go(privKey *streamd_grpc.PrivateKey) (crypto.PrivateKey, error)

func PrivateKeyPKCS8GRPC2Go

func PrivateKeyPKCS8GRPC2Go(privKey *streamd_grpc.PrivateKey_PKCS8) (crypto.PrivateKey, error)

func ProfileGRPC2Go

func ProfileGRPC2Go(
	platID streamcontrol.PlatformName,
	profileString string,
) (streamcontrol.AbstractStreamProfile, error)

func ProfileGo2GRPC

func ProfileGo2GRPC(
	profile streamcontrol.AbstractStreamProfile,
) (string, error)

func StreamPlaybackConfigGRPC2Go

func StreamPlaybackConfigGRPC2Go(
	cfg *streamd_grpc.StreamPlaybackConfig,
) sptypes.Config

func StreamPlaybackConfigGo2GRPC

func StreamPlaybackConfigGo2GRPC(
	cfg *sptypes.Config,
) *streamd_grpc.StreamPlaybackConfig

func StreamPlayerTypeGRPC2Go

func StreamPlayerTypeGRPC2Go(
	playerType streamd_grpc.PlayerType,
) player.Backend

func StreamPlayerTypeGo2GRPC

func StreamPlayerTypeGo2GRPC(
	playerType player.Backend,
) streamd_grpc.PlayerType

func StreamServerConfigGRPC2Go

func StreamServerConfigGRPC2Go(
	ctx context.Context,
	srv *streamd_grpc.StreamServer,
) (api.StreamServerType, string, streamportserver.Options, error)

func StreamServerConfigGo2GRPC

func StreamServerConfigGo2GRPC(
	ctx context.Context,
	serverType api.StreamServerType,
	listenAddr string,
	opts ...streamportserver.Option,
) (*streamd_grpc.StreamServer, error)

func StreamServerTypeGRPC2Go

func StreamServerTypeGRPC2Go(t streamd_grpc.StreamServerType) (api.StreamServerType, error)

func StreamServerTypeGo2GRPC

func StreamServerTypeGo2GRPC(t api.StreamServerType) (streamd_grpc.StreamServerType, error)

func TLSCertificateGRPC2Go

func TLSCertificateGRPC2Go(cert *streamd_grpc.TLSCertificate) (*x509.Certificate, error)

func TriggerRuleGRPC2Go

func TriggerRuleGRPC2Go(
	rule *streamd_grpc.TriggerRule,
) (*api.TriggerRule, error)

func TriggerRuleGo2GRPC

func TriggerRuleGo2GRPC(
	rule *api.TriggerRule,
) (*streamd_grpc.TriggerRule, error)

func UnixGRPC2Go

func UnixGRPC2Go(unixNano int64) time.Time