server

package

Go to main page

Versions in this module

v0

v0.2.1

Mar 8, 2024

v0.2.0

Feb 16, 2024

Changes in this version

type FmDevice

+ RegisterTs int64

+ SpecpipeVersion string

type IqDevice

+ Forward bool

+ RegisterTs int64

+ SpecpipeVersion string

v0.1.0

Nov 20, 2023

Changes in this version

type FmDevice

+ ResampleRate string

type UpdateFmDeviceRequest

+ ResampleRate *string

v0.0.3

Nov 17, 2023

Changes in this version

type Config

+ Controller *ControllerConfig

+ Health *HealthConfig

+ type ControllerConfig struct

+ Http *HttpConfig

+ Logging *LoggingConfig

+ Nats *NatsConfig

+ func NewControllerConfig() (*ControllerConfig, error)

+ type HealthConfig struct

+ Logging *LoggingConfig

+ Nats *NatsConfig

+ TimeoutSec int64

+ func NewHealthConfig() (*HealthConfig, error)

v0.0.2

Nov 15, 2023

v0.0.1

Nov 15, 2023

Changes in this version

+ const JWTAuthHeader

+ func CorsMiddleware() gin.HandlerFunc

+ func GetSwagger() (swagger *openapi3.T, err error)

+ func Healthcheck(ctx context.Context, conn *nats.Conn, store *Store, heartbeatTimoutSec int64, ...)

+ func LoggingMiddleware(logger common.ServerLogrus) gin.HandlerFunc

+ func NewHttpServer(specpipeServer *SpecpipeServer, logger common.ServerLogrus, port string) *http.Server

+ func PathToRawSpec(pathToFile string) map[string]func() ([]byte, error)

+ func RegisterHandlers(router gin.IRouter, si ServerInterface)

+ func RegisterHandlersWithOptions(router gin.IRouter, si ServerInterface, options GinServerOptions)

+ type Config struct

+ Heartbeat *HeartbeatConfig

+ Http *HttpConfig

+ Logging *LoggingConfig

+ Nats *NatsConfig

+ func NewConfig() (*Config, error)

+ type ErrorResponse struct

+ Detail string

+ Title string

+ type FmDevice struct

+ Freq string

+ Latitude float32

+ Longitude float32

+ Name string

+ SampleRate string

+ type FmDeviceResponse struct

+ Device FmDevice

+ type FmDevicesResponse struct

+ Devices []FmDevice

+ type GinServerOptions struct

+ BaseURL string

+ ErrorHandler func(*gin.Context, error, int)

+ Middlewares []MiddlewareFunc

+ type HeartbeatConfig struct

+ TimeoutSec int64

+ type HttpConfig struct

+ ServerPort string

+ type IqDevice struct

+ Freq string

+ Latitude float32

+ Longitude float32

+ Name string

+ SampleRate string

+ type IqDeviceResponse struct

+ Device IqDevice

+ type IqDevicesResponse struct

+ Devices []IqDevice

+ type LoggingConfig struct

+ Level string

+ type MiddlewareFunc func(c *gin.Context)

+ type NatsConfig struct

+ Url string

+ type PutFmDevicesDevicenameJSONRequestBody = UpdateFmDeviceRequest

+ type PutIqDevicesDevicenameJSONRequestBody = UpdateIqDeviceRequest

+ type ServerInterface interface

+ GetFmDevices func(c *gin.Context)

+ GetFmDevicesDevicename func(c *gin.Context, devicename string)

+ GetIqDevices func(c *gin.Context)

+ GetIqDevicesDevicename func(c *gin.Context, devicename string)

+ PutFmDevicesDevicename func(c *gin.Context, devicename string)

+ PutIqDevicesDevicename func(c *gin.Context, devicename string)

+ type ServerInterfaceWrapper struct

+ ErrorHandler func(*gin.Context, error, int)

+ Handler ServerInterface

+ HandlerMiddlewares []MiddlewareFunc

+ func (siw *ServerInterfaceWrapper) GetFmDevices(c *gin.Context)

+ func (siw *ServerInterfaceWrapper) GetFmDevicesDevicename(c *gin.Context)

+ func (siw *ServerInterfaceWrapper) GetIqDevices(c *gin.Context)

+ func (siw *ServerInterfaceWrapper) GetIqDevicesDevicename(c *gin.Context)

+ func (siw *ServerInterfaceWrapper) PutFmDevicesDevicename(c *gin.Context)

+ func (siw *ServerInterfaceWrapper) PutIqDevicesDevicename(c *gin.Context)

+ type SpecpipeServer struct

+ func NewSpecpipeServer(store *Store) *SpecpipeServer

+ func (s *SpecpipeServer) GetFmDevices(c *gin.Context)

+ func (s *SpecpipeServer) GetFmDevicesDevicename(c *gin.Context, deviceName string)

+ func (s *SpecpipeServer) GetIqDevices(c *gin.Context)

+ func (s *SpecpipeServer) GetIqDevicesDevicename(c *gin.Context, deviceName string)

+ func (s *SpecpipeServer) PutFmDevicesDevicename(c *gin.Context, deviceName string)

+ func (s *SpecpipeServer) PutIqDevicesDevicename(c *gin.Context, deviceName string)

+ type Store struct

+ func NewStore(conn *nats.Conn, kv jetstream.KeyValue) *Store

+ func (s *Store) DeleteDevice(ctx context.Context, sdrType common.SDRType, deviceName string) error

+ func (s *Store) GetDevice(ctx context.Context, sdrType common.SDRType, deviceName string) (bool, common.Device, error)

+ func (s *Store) GetDevices(ctx context.Context, sdrType common.SDRType) ([]common.Device, error)

+ func (s *Store) UpdateDevice(ctx context.Context, sdrType common.SDRType, deviceName string, ...) error

+ type UpdateFmDeviceRequest struct

+ Freq string

+ SampleRate *string

+ type UpdateIqDeviceRequest struct

+ Freq string

+ SampleRate *string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL