gowandb

Documentation

Overview

package gowandb implements the go Weights & Biases SDK

Index

• type Connection
  • func NewConnection(ctx context.Context, addr string) (*Connection, error)
  • func (c *Connection) Close()
  • func (c *Connection) Recv()
  • func (c *Connection) Send(msg proto.Message) error
• type History
• type Mailbox
  • func NewMailbox() *Mailbox
  • func (mb *Mailbox) Deliver(rec *service.Record) *MailboxHandle
  • func (mb *Mailbox) Respond(result *service.Result) bool
• type MailboxHandle
  • func NewMailboxHandle() *MailboxHandle
• type Manager
  • func NewManager(ctx context.Context, baseSettings *settings.SettingsWrap, addr string) *Manager
  • func (m *Manager) Close()
  • func (m *Manager) Connect(ctx context.Context) *Connection
  • func (m *Manager) NewRun(runParams *runopts.RunParams) *Run
• type Run
  • func NewRun(ctx context.Context, settings *service.Settings, conn *Connection, ...) *Run
  • func (r *Run) Finish()
  • func (r *Run) Log(data map[string]interface{})
  • func (r *Run) LogPartial(data map[string]interface{}, commit bool)
  • func (r *Run) LogPartialCommit()
• type Session
  • func NewSession(opts ...sessionopts.SessionOption) (*Session, error)
  • func (s *Session) Close()
  • func (s *Session) NewRun(opts ...runopts.RunOption) (*Run, error)
• type Settings

Types

type Connection

type Connection struct {

	// Conn is the connection to the server
	net.Conn
	Mbox *Mailbox
	// contains filtered or unexported fields
}

Connection is a connection to the server.

func NewConnection

func NewConnection(ctx context.Context, addr string) (*Connection, error)

NewConnection creates a new connection to the server.

func (*Connection) Close

func (c *Connection) Close()

Close closes the connection.

func (*Connection) Recv

func (c *Connection) Recv()

func (*Connection) Send

func (c *Connection) Send(msg proto.Message) error

Send sends a message to the server.

type History

type History map[string]interface{}

type Mailbox

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

func NewMailbox

func NewMailbox() *Mailbox

func (*Mailbox) Deliver

func (mb *Mailbox) Deliver(rec *service.Record) *MailboxHandle

func (*Mailbox) Respond

func (mb *Mailbox) Respond(result *service.Result) bool

type MailboxHandle

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

func NewMailboxHandle

func NewMailboxHandle() *MailboxHandle

type Manager

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

Manager is a collection of components that work together to handle incoming

func NewManager

func NewManager(ctx context.Context, baseSettings *settings.SettingsWrap, addr string) *Manager

NewManager creates a new manager with the given settings and responders.

func (*Manager) Close

func (m *Manager) Close()

func (*Manager) Connect

func (m *Manager) Connect(ctx context.Context) *Connection

func (*Manager) NewRun

func (m *Manager) NewRun(runParams *runopts.RunParams) *Run

type Run

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

func NewRun

func NewRun(ctx context.Context, settings *service.Settings, conn *Connection, runParams *runopts.RunParams) *Run

NewRun creates a new run with the given settings and responders.

func (*Run) Finish

func (r *Run) Finish()

func (*Run) Log

func (r *Run) Log(data map[string]interface{})

func (*Run) LogPartial

func (r *Run) LogPartial(data map[string]interface{}, commit bool)

func (*Run) LogPartialCommit

func (r *Run) LogPartialCommit()

type Session

type Session struct {

	// embed settings parameters which are set by sessionopts options
	sessionopts.SessionParams
	// contains filtered or unexported fields
}

func NewSession

func NewSession(opts ...sessionopts.SessionOption) (*Session, error)

func (*Session) Close

func (s *Session) Close()

func (*Session) NewRun

func (s *Session) NewRun(opts ...runopts.RunOption) (*Run, error)

type Settings

type Settings map[string]interface{}