api

Documentation

Index

• Constants
• func New(db Repository, client HealthcareClient) *http.ServeMux
• func NewPubSubMessage(body io.Reader) (*pubSubMessage, error)
• type API
• type DB
  • func NewDB(db *pgxpool.Pool) DB
  • func (d DB) InsertORU(ctx context.Context, oru models.ORU) error
  • func (d DB) UpsertORM(ctx context.Context, orm models.ORM) error
• type HealthcareClient
• type Hl7Client
  • func NewHl7Client(ctx context.Context, opts ...option.ClientOption) (*Hl7Client, error)
  • func (h *Hl7Client) GetHL7V2Message(messagePath string) (hl7.Message, error)
• type Repository

Constants

const SegDelim = '\r'

Functions

func New

func New(db Repository, client HealthcareClient) *http.ServeMux

func NewPubSubMessage

func NewPubSubMessage(body io.Reader) (*pubSubMessage, error)

Types

type API

type API struct {
	DB     Repository
	Client HealthcareClient
}

type DB

type DB struct {
	*database.Queries
}

func NewDB

func NewDB(db *pgxpool.Pool) DB

func (DB) InsertORU

func (d DB) InsertORU(ctx context.Context, oru models.ORU) error

func (DB) UpsertORM

func (d DB) UpsertORM(ctx context.Context, orm models.ORM) error

type HealthcareClient

type HealthcareClient interface {
	GetHL7V2Message(messagePath string) (hl7.Message, error)
}

type Hl7Client

type Hl7Client healthcare.Service

func NewHl7Client

func NewHl7Client(ctx context.Context, opts ...option.ClientOption) (*Hl7Client, error)

func (*Hl7Client) GetHL7V2Message

func (h *Hl7Client) GetHL7V2Message(messagePath string) (hl7.Message, error)

type Repository

type Repository interface {
	UpsertORM(ctx context.Context, orm models.ORM) error
	InsertORU(ctx context.Context, oru models.ORU) error
}