mem

Documentation

Overview

Copyright 2017 Joan Llopis. All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

Copyright 2017 Joan Llopis. All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

Index

• type MemStore
  • func New() (*MemStore, error)
  • func (m *MemStore) AddJob(*services.JobMsg) (*services.IdMessage, error)
  • func (d *MemStore) Close() error
  • func (m *MemStore) DeleteJob(*services.IdMessage) (*services.JobMsg, error)
  • func (d *MemStore) Dial(options store.Options) error
  • func (m *MemStore) FindJob(*services.IdMessage) (*services.JobMsg, error)
  • func (m *MemStore) ListJobs(*services.JobFilterMsg) (*services.JobArrayMsg, error)
  • func (d *MemStore) Status() (int, string)
  • func (m *MemStore) UpdateJob(*services.JobMsg) (*services.JobMsg, error)

Types

type MemStore

type MemStore struct {
	Pool          map[int64]*services.JobDataMsg
	StoreFileName string
	StoreFile     *os.File
	Stat          int
}

MemStore is a Storer implementation over PostgresSQL

func New

func New() (*MemStore, error)

New is a default Storer implementation based upon PostgresSQL

func (*MemStore) AddJob

func (m *MemStore) AddJob(*services.JobMsg) (*services.IdMessage, error)

func (*MemStore) Close

func (d *MemStore) Close() error

Close effectively close de database connection

func (*MemStore) DeleteJob

func (m *MemStore) DeleteJob(*services.IdMessage) (*services.JobMsg, error)

func (*MemStore) Dial

func (d *MemStore) Dial(options store.Options) error

Dial perform the connection to the underlying database server

func (*MemStore) FindJob

func (m *MemStore) FindJob(*services.IdMessage) (*services.JobMsg, error)

func (*MemStore) ListJobs

func (m *MemStore) ListJobs(*services.JobFilterMsg) (*services.JobArrayMsg, error)

func (*MemStore) Status

func (d *MemStore) Status() (int, string)

Status return the current status of the underlying database

func (*MemStore) UpdateJob

func (m *MemStore) UpdateJob(*services.JobMsg) (*services.JobMsg, error)