mongo

Documentation

Index

• type Client
  • func NewClient() (*Client, error)
  • func (m *Client) Client() *mongo.Client
  • func (m *Client) Disconnect()
• type ProcessDTO
  • func (p ProcessDTO) ToProcess() (*domain.Process, error)
• type ProcessMongoRepository
  • func NewProcessMongoRepository(client *mongo.Client) *ProcessMongoRepository
  • func (p *ProcessMongoRepository) GetAll(ctx context.Context) (domain.Processes, error)
  • func (p *ProcessMongoRepository) Save(ctx context.Context, process *domain.Process) (err error)

Types

type Client

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

func NewClient

func NewClient() (*Client, error)

func (*Client) Client

func (m *Client) Client() *mongo.Client

func (*Client) Disconnect

func (m *Client) Disconnect()

type ProcessDTO

type ProcessDTO struct {
	ID      string                      `bson:"_id,omitempty"`
	Process *domain.ProcessAsPrimitives `bson:"process"`
}

func (ProcessDTO) ToProcess

func (p ProcessDTO) ToProcess() (*domain.Process, error)

type ProcessMongoRepository

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

func NewProcessMongoRepository

func NewProcessMongoRepository(client *mongo.Client) *ProcessMongoRepository

func (*ProcessMongoRepository) GetAll

func (p *ProcessMongoRepository) GetAll(ctx context.Context) (domain.Processes, error)

func (*ProcessMongoRepository) Save

func (p *ProcessMongoRepository) Save(ctx context.Context, process *domain.Process) (err error)