energystorage

package
v0.0.0-...-8d9afb2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 7, 2022 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WithEnergyStorageApiClientFactory 

func WithEnergyStorageApiClientFactory(f func(name string) (traits.EnergyStorageApiClient, error)) router.Option

WithEnergyStorageApiClientFactory instructs the router to create a new client the first time Get is called for that name.

func WithEnergyStorageInfoClientFactory 

func WithEnergyStorageInfoClientFactory(f func(name string) (traits.EnergyStorageInfoClient, error)) router.Option

WithEnergyStorageInfoClientFactory instructs the router to create a new client the first time Get is called for that name.

func WrapApi 

func WrapApi(server traits.EnergyStorageApiServer) traits.EnergyStorageApiClient

WrapApi adapts a traits.EnergyStorageApiServer and presents it as a traits.EnergyStorageApiClient

func WrapInfo 

func WrapInfo(server traits.EnergyStorageInfoServer) traits.EnergyStorageInfoClient

WrapInfo adapts a traits.EnergyStorageInfoServer and presents it as a traits.EnergyStorageInfoClient

Types

type ApiRouter 

type ApiRouter struct {
	traits.UnimplementedEnergyStorageApiServer

	router.Router
}

ApiRouter is a traits.EnergyStorageApiServer that allows routing named requests to specific traits.EnergyStorageApiClient

func NewApiRouter 

func NewApiRouter(opts ...router.Option) *ApiRouter

func (*ApiRouter) Add 

func (r *ApiRouter) Add(name string, client any) any

Add extends Router.Add to panic if client is not of type traits.EnergyStorageApiClient.

func (*ApiRouter) AddEnergyStorageApiClient 

func (r *ApiRouter) AddEnergyStorageApiClient(name string, client traits.EnergyStorageApiClient) traits.EnergyStorageApiClient

func (*ApiRouter) Charge 

func (r *ApiRouter) Charge(ctx context.Context, request *traits.ChargeRequest) (*traits.ChargeResponse, error)

func (*ApiRouter) GetEnergyLevel 

func (r *ApiRouter) GetEnergyLevel(ctx context.Context, request *traits.GetEnergyLevelRequest) (*traits.EnergyLevel, error)

func (*ApiRouter) GetEnergyStorageApiClient 

func (r *ApiRouter) GetEnergyStorageApiClient(name string) (traits.EnergyStorageApiClient, error)

func (*ApiRouter) HoldsType 

func (r *ApiRouter) HoldsType(client any) bool

func (*ApiRouter) PullEnergyLevel 

func (r *ApiRouter) PullEnergyLevel(request *traits.PullEnergyLevelRequest, server traits.EnergyStorageApi_PullEnergyLevelServer) error

func (*ApiRouter) Register 

func (r *ApiRouter) Register(server *grpc.Server)

func (*ApiRouter) RemoveEnergyStorageApiClient 

func (r *ApiRouter) RemoveEnergyStorageApiClient(name string) traits.EnergyStorageApiClient

type InfoRouter 

type InfoRouter struct {
	traits.UnimplementedEnergyStorageInfoServer

	router.Router
}

InfoRouter is a traits.EnergyStorageInfoServer that allows routing named requests to specific traits.EnergyStorageInfoClient

func NewInfoRouter 

func NewInfoRouter(opts ...router.Option) *InfoRouter

func (*InfoRouter) Add 

func (r *InfoRouter) Add(name string, client any) any

Add extends Router.Add to panic if client is not of type traits.EnergyStorageInfoClient.

func (*InfoRouter) AddEnergyStorageInfoClient 

func (r *InfoRouter) AddEnergyStorageInfoClient(name string, client traits.EnergyStorageInfoClient) traits.EnergyStorageInfoClient

func (*InfoRouter) DescribeEnergyLevel 

func (r *InfoRouter) DescribeEnergyLevel(ctx context.Context, request *traits.DescribeEnergyLevelRequest) (*traits.EnergyLevelSupport, error)

func (*InfoRouter) GetEnergyStorageInfoClient 

func (r *InfoRouter) GetEnergyStorageInfoClient(name string) (traits.EnergyStorageInfoClient, error)

func (*InfoRouter) HoldsType 

func (r *InfoRouter) HoldsType(client any) bool

func (*InfoRouter) Register 

func (r *InfoRouter) Register(server *grpc.Server)

func (*InfoRouter) RemoveEnergyStorageInfoClient 

func (r *InfoRouter) RemoveEnergyStorageInfoClient(name string) traits.EnergyStorageInfoClient

type Model 

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

func NewModel 

func NewModel() *Model

func (*Model) GetEnergyLevel 

func (m *Model) GetEnergyLevel(opts ...resource.ReadOption) (*traits.EnergyLevel, error)

func (*Model) PullEnergyLevel 

func (m *Model) PullEnergyLevel(ctx context.Context, opts ...resource.ReadOption) <-chan PullEnergyLevelChange

func (*Model) UpdateEnergyLevel 

func (m *Model) UpdateEnergyLevel(energyLevel *traits.EnergyLevel, opts ...resource.WriteOption) (*traits.EnergyLevel, error)

type ModelServer 

type ModelServer struct {
	traits.UnimplementedEnergyStorageApiServer
	// contains filtered or unexported fields
}

func NewModelServer 

func NewModelServer(model *Model, opts ...ServerOption) *ModelServer

func (*ModelServer) Charge 

func (s *ModelServer) Charge(_ context.Context, request *traits.ChargeRequest) (*traits.ChargeResponse, error)

func (*ModelServer) GetEnergyLevel 

func (s *ModelServer) GetEnergyLevel(_ context.Context, request *traits.GetEnergyLevelRequest) (*traits.EnergyLevel, error)

func (*ModelServer) PullEnergyLevel 

func (s *ModelServer) PullEnergyLevel(request *traits.PullEnergyLevelRequest, server traits.EnergyStorageApi_PullEnergyLevelServer) error

func (*ModelServer) Register 

func (s *ModelServer) Register(server *grpc.Server)

func (*ModelServer) Unwrap 

func (s *ModelServer) Unwrap() any

type PullEnergyLevelChange 

type PullEnergyLevelChange struct {
	Value      *traits.EnergyLevel
	ChangeTime time.Time
}

type ServerOption 

type ServerOption func(s *ModelServer)

func ReadOnly 

func ReadOnly() ServerOption

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.