testutils

Documentation

Index

• Variables
• func NewTestPostgresDB(ctx context.Context, dbName, userName, password string) (testcontainers.Container, string, error)
• func NewTestRedis(ctx context.Context) (*redis.RedisContainer, int, error)
• type FakePublisher
  • func (f FakePublisher[T]) Subscribe() <-chan T
  • func (f FakePublisher[T]) Unsubscribe(_ <-chan T)

Variables

var (
	TestUpdate = publisher.SolarEdgeUpdate{
		{
			ID:   1,
			Name: "foo",
			PowerOverview: solaredge.PowerOverview{
				LastYearData:  solaredge.EnergyOverview{Energy: 1000},
				LastMonthData: solaredge.EnergyOverview{Energy: 100},
				LastDayData:   solaredge.EnergyOverview{Energy: 10},
				CurrentPower:  solaredge.CurrentPower{Power: 3000},
			},
			InverterUpdates: []publisher.InverterUpdate{
				{
					Name:         "inv1",
					SerialNumber: "1234",
					Telemetry: solaredge.InverterTelemetry{
						L1Data: struct {
							AcCurrent     float64 `json:"acCurrent"`
							AcFrequency   float64 `json:"acFrequency"`
							AcVoltage     float64 `json:"acVoltage"`
							ActivePower   float64 `json:"activePower"`
							ApparentPower float64 `json:"apparentPower"`
							CosPhi        float64 `json:"cosPhi"`
							ReactivePower float64 `json:"reactivePower"`
						}(struct {
							AcCurrent     float64
							AcFrequency   float64
							AcVoltage     float64
							ActivePower   float64
							ApparentPower float64
							CosPhi        float64
							ReactivePower float64
						}{
							AcCurrent: 10,
							AcVoltage: 240,
						}),
						DcVoltage:        400,
						PowerLimit:       1,
						Temperature:      40,
						TotalActivePower: 9999,
						TotalEnergy:      8888,
					},
				},
			},
		},
	}

	EmptyUpdate = publisher.SolarEdgeUpdate{
		{
			ID:   1,
			Name: "foo",
			PowerOverview: solaredge.PowerOverview{
				LastYearData:  solaredge.EnergyOverview{Energy: 1000},
				LastMonthData: solaredge.EnergyOverview{Energy: 100},
				LastDayData:   solaredge.EnergyOverview{Energy: 10},
				CurrentPower:  solaredge.CurrentPower{Power: 0},
			},
		},
	}
)

Functions

func NewTestPostgresDB

func NewTestPostgresDB(ctx context.Context, dbName, userName, password string) (testcontainers.Container, string, error)

func NewTestRedis

func NewTestRedis(ctx context.Context) (*redis.RedisContainer, int, error)

Types

type FakePublisher

type FakePublisher[T any] struct {
	Ch chan T
}

func (FakePublisher[T]) Subscribe

func (f FakePublisher[T]) Subscribe() <-chan T

func (FakePublisher[T]) Unsubscribe

func (f FakePublisher[T]) Unsubscribe(_ <-chan T)