cockroach

Documentation

Index

• func Close(wg *sync.WaitGroup) error
• func Cluster() string
• func Database() string
• func Host() string
• func MaxConnections() int32
• func MinConnections() int32
• func Password() string
• func Port() string
• func SSLMode() string
• func SSLRootCert() string
• func SetCluster(newCluster string)
• func SetDatabase(newDatabase string)
• func SetHost(newHost string)
• func SetMaxConnections(newMax int32)
• func SetMinConnections(newMin int32)
• func SetPassword(newPassword string)
• func SetPort(newPort string)
• func SetSSLMode(newSSLMode string)
• func SetSSLRootCert(newSSLRootCert string)
• func SetUser(newUser string)
• func User() string
• type Conn
  • func GetConnection(ctx context.Context) (*Conn, error)
  • func (c *Conn) AddPost(request models.SendPostRequest) error
  • func (c *Conn) Close(context.Context) error
  • func (c *Conn) FindUser(filter map[string]string) (models.User, error)
  • func (c *Conn) GetPosts(page, num int) ([]models.PostDisplay, error)
  • func (c *Conn) GetPostsSince(max int, since time.Time) ([]models.PostDisplay, int, error)
  • func (c *Conn) GetPublicKey(email string) (ssh.PublicKey, error)
  • func (c *Conn) RegisterUser(request models.RegisterRequest) error

Functions

func Close

func Close(wg *sync.WaitGroup) error

func Cluster

func Cluster() string

func Database

func Database() string

func Host

func Host() string

func MaxConnections

func MaxConnections() int32

func MinConnections

func MinConnections() int32

func Password

func Password() string

func Port

func Port() string

func SSLMode

func SSLMode() string

func SSLRootCert

func SSLRootCert() string

func SetCluster

func SetCluster(newCluster string)

func SetDatabase

func SetDatabase(newDatabase string)

func SetHost

func SetHost(newHost string)

func SetMaxConnections

func SetMaxConnections(newMax int32)

func SetMinConnections

func SetMinConnections(newMin int32)

func SetPassword

func SetPassword(newPassword string)

func SetPort

func SetPort(newPort string)

func SetSSLMode

func SetSSLMode(newSSLMode string)

func SetSSLRootCert

func SetSSLRootCert(newSSLRootCert string)

func SetUser

func SetUser(newUser string)

func User

func User() string

Types

type Conn

type Conn struct {
	*pgxpool.Conn
}

func GetConnection

func GetConnection(ctx context.Context) (*Conn, error)

func (*Conn) AddPost

func (c *Conn) AddPost(request models.SendPostRequest) error

TODO Use user model

func (*Conn) Close

func (c *Conn) Close(context.Context) error

func (*Conn) FindUser

func (c *Conn) FindUser(filter map[string]string) (models.User, error)

func (*Conn) GetPosts

func (c *Conn) GetPosts(page, num int) ([]models.PostDisplay, error)

func (*Conn) GetPostsSince

func (c *Conn) GetPostsSince(max int, since time.Time) ([]models.PostDisplay, int, error)

func (*Conn) GetPublicKey

func (c *Conn) GetPublicKey(email string) (ssh.PublicKey, error)

func (*Conn) RegisterUser

func (c *Conn) RegisterUser(request models.RegisterRequest) error