Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dbn_live

package

Go to main page

Versions in this module

v0

v0.9.3

Apr 20, 2026

Changes in this version

+ const SUBSCRIPTION_LINE_MAX

type LiveConfig

+ HandshakeReadTimeout time.Duration

v0.9.2

Apr 13, 2026

v0.9.1

Apr 10, 2026

Changes in this version

type LiveConfig

+ ReadTimeout time.Duration

v0.9.0

Apr 10, 2026

Changes in this version

type AuthenticationRequestMsg

+ Compression dbn.Compression

+ HeartbeatIntervalS uint32

+ PrettyPx bool

+ PrettyTs bool

+ SlowReaderBehavior dbn.SlowReaderBehavior

type LiveConfig

+ HeartbeatInterval time.Duration

+ SlowReaderBehavior dbn.SlowReaderBehavior

v0.8.11

Mar 20, 2026

v0.8.10

Mar 18, 2026

v0.8.9

Mar 18, 2026

Changes in this version

+ const API_KEY_LENGTH

+ const API_VERSION

+ const API_VERSION_STR

+ const BUCKET_ID_LENGTH

+ const DATABENTO_API_ENV_KEY

+ const DATABENTO_CLIENT_ENV_KEY

+ const DATABENTO_VERSION

+ const ERROR_ERR_SIZE_V1

+ const ERROR_ERR_SIZE_V2

+ const LIVE_API_PORT

+ const LIVE_HOST_SUFFIX

+ const MAX_STR_LENGTH

+ const SYSTEM_MSG_SIZE_V1

+ const SYSTEM_MSG_SIZE_V2

+ type AuthenticationRequestMsg struct

+ Auth string

+ Client string

+ Dataset string

+ Details string

+ Encoding dbn.Encoding

+ TsOut bool

+ func NewAuthenticationRequestMsg() AuthenticationRequestMsg

+ func (m *AuthenticationRequestMsg) Encode() []byte

+ type AuthenticationResponseMsg struct

+ Error string

+ SessionID string

+ Success string

+ func NewAuthenticationResponseMsgFromBytes(b []byte) *AuthenticationResponseMsg

+ type ChallengeRequestMsg struct

+ Cram string

+ func NewChallengeRequestMsgFromBytes(b []byte) *ChallengeRequestMsg

+ type ErrorMsgV1 struct

+ Err [ERROR_ERR_SIZE_V1]byte

+ type ErrorMsgV2 struct

+ Code uint8

+ Err [ERROR_ERR_SIZE_V2]byte

+ IsLast uint8

+ type GreetingMsg struct

+ LsgVersion string

+ func NewGreetingMsgFromBytes(b []byte) *GreetingMsg

+ type LiveClient struct

+ func NewLiveClient(config LiveConfig) (*LiveClient, error)

+ func (c *LiveClient) Authenticate(apiKey string) (string, error)

+ func (c *LiveClient) GetConfig() LiveConfig

+ func (c *LiveClient) GetDbnScanner() *dbn.DbnScanner

+ func (c *LiveClient) GetGateway() string

+ func (c *LiveClient) GetJsonScanner() *dbn.JsonScanner

+ func (c *LiveClient) GetLsgVersion() string

+ func (c *LiveClient) GetPort() uint16

+ func (c *LiveClient) GetSessionID() string

+ func (c *LiveClient) Start() error

+ func (c *LiveClient) Stop() error

+ func (c *LiveClient) Subscribe(sub SubscriptionRequestMsg) error

+ type LiveConfig struct

+ ApiKey string

+ Client string

+ Dataset string

+ Encoding dbn.Encoding

+ Logger *slog.Logger

+ SendTsOut bool

+ Verbose bool

+ VersionUpgradePolicy dbn.VersionUpgradePolicy

+ func (c *LiveConfig) SetFromEnv() error

+ type SessionStartMsg struct

+ StartSession string

+ func (m *SessionStartMsg) Encode() []byte

+ type SubscriptionRequestMsg struct

+ Schema string

+ Snapshot bool

+ Start time.Time

+ StypeIn dbn.SType

+ Symbols []string

+ func (m *SubscriptionRequestMsg) Encode() []byte

+ type SystemMsgV1 struct

+ Msg [SYSTEM_MSG_SIZE_V1]byte

+ type SystemMsgV2 struct

+ Code uint8

+ Msg [SYSTEM_MSG_SIZE_V2]byte