machinechannel

Documentation

Index

• type EntRepository
  • func NewEntRepository(client *ent.Client) *EntRepository
  • func (r *EntRepository) GetMachine(ctx context.Context, machineID uuid.UUID) (service.MachineRecord, error)
  • func (r *EntRepository) IssueToken(ctx context.Context, input service.CreateTokenRecord) (service.TokenRecord, error)
  • func (r *EntRepository) RecordConnectedSession(ctx context.Context, input service.ConnectedSessionRecord) (service.MachineRecord, error)
  • func (r *EntRepository) RecordDisconnectedSession(ctx context.Context, input service.DisconnectedSessionRecord) (service.MachineRecord, error)
  • func (r *EntRepository) RecordHeartbeat(ctx context.Context, input service.HeartbeatRecord) (service.MachineRecord, error)
  • func (r *EntRepository) RevokeToken(ctx context.Context, machineID uuid.UUID, tokenID uuid.UUID, ...) error
  • func (r *EntRepository) TokenByHash(ctx context.Context, tokenHash string) (service.TokenRecord, error)
  • func (r *EntRepository) TouchTokenLastUsed(ctx context.Context, tokenID uuid.UUID, usedAt time.Time) error

Types

type EntRepository

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

func NewEntRepository

func NewEntRepository(client *ent.Client) *EntRepository

func (*EntRepository) GetMachine

func (r *EntRepository) GetMachine(ctx context.Context, machineID uuid.UUID) (service.MachineRecord, error)

func (*EntRepository) IssueToken

func (r *EntRepository) IssueToken(ctx context.Context, input service.CreateTokenRecord) (service.TokenRecord, error)

func (*EntRepository) RecordConnectedSession

func (r *EntRepository) RecordConnectedSession(ctx context.Context, input service.ConnectedSessionRecord) (service.MachineRecord, error)

func (*EntRepository) RecordDisconnectedSession

func (r *EntRepository) RecordDisconnectedSession(ctx context.Context, input service.DisconnectedSessionRecord) (service.MachineRecord, error)

func (*EntRepository) RecordHeartbeat

func (r *EntRepository) RecordHeartbeat(ctx context.Context, input service.HeartbeatRecord) (service.MachineRecord, error)

func (*EntRepository) RevokeToken

func (r *EntRepository) RevokeToken(ctx context.Context, machineID uuid.UUID, tokenID uuid.UUID, revokedAt time.Time) error

func (*EntRepository) TokenByHash

func (r *EntRepository) TokenByHash(ctx context.Context, tokenHash string) (service.TokenRecord, error)

func (*EntRepository) TouchTokenLastUsed

func (r *EntRepository) TouchTokenLastUsed(ctx context.Context, tokenID uuid.UUID, usedAt time.Time) error