openclose

package
v0.0.0-...-0f67f6e Latest Latest
Warning

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

 Go to latest Published: Oct 2, 2024 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WithOpenCloseApiClientFactory 

func WithOpenCloseApiClientFactory(f func(name string) (traits.OpenCloseApiClient, error)) router.Option

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

func WithOpenCloseInfoClientFactory 

func WithOpenCloseInfoClientFactory(f func(name string) (traits.OpenCloseInfoClient, error)) router.Option

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

Types

type ApiRouter 

type ApiRouter struct {
	traits.UnimplementedOpenCloseApiServer

	router.Router
}

ApiRouter is a traits.OpenCloseApiServer that allows routing named requests to specific traits.OpenCloseApiClient

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.OpenCloseApiClient.

func (*ApiRouter) AddOpenCloseApiClient 

func (r *ApiRouter) AddOpenCloseApiClient(name string, client traits.OpenCloseApiClient) traits.OpenCloseApiClient

func (*ApiRouter) GetOpenCloseApiClient 

func (r *ApiRouter) GetOpenCloseApiClient(name string) (traits.OpenCloseApiClient, error)

func (*ApiRouter) GetPositions 

func (r *ApiRouter) GetPositions(ctx context.Context, request *traits.GetOpenClosePositionsRequest) (*traits.OpenClosePositions, error)

func (*ApiRouter) HoldsType 

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

func (*ApiRouter) PullPositions 

func (r *ApiRouter) PullPositions(request *traits.PullOpenClosePositionsRequest, server traits.OpenCloseApi_PullPositionsServer) error

func (*ApiRouter) Register 

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

func (*ApiRouter) RemoveOpenCloseApiClient 

func (r *ApiRouter) RemoveOpenCloseApiClient(name string) traits.OpenCloseApiClient

func (*ApiRouter) Stop 

func (r *ApiRouter) Stop(ctx context.Context, request *traits.StopOpenCloseRequest) (*traits.OpenClosePositions, error)

func (*ApiRouter) UpdatePositions 

func (r *ApiRouter) UpdatePositions(ctx context.Context, request *traits.UpdateOpenClosePositionsRequest) (*traits.OpenClosePositions, error)

type ApiWrapper 

type ApiWrapper struct {
	traits.OpenCloseApiClient
	// contains filtered or unexported fields
}

func WrapApi 

func WrapApi(server traits.OpenCloseApiServer) *ApiWrapper

WrapApi adapts a traits.OpenCloseApiServer and presents it as a traits.OpenCloseApiClient

func (*ApiWrapper) Unwrap 

func (w *ApiWrapper) Unwrap() any

Unwrap implements wrap.Unwrapper and returns the underlying server instance as an unknown type.

func (*ApiWrapper) UnwrapServer 

func (w *ApiWrapper) UnwrapServer() traits.OpenCloseApiServer

UnwrapServer returns the underlying server instance.

func (*ApiWrapper) UnwrapService 

func (w *ApiWrapper) UnwrapService() (grpc.ClientConnInterface, grpc.ServiceDesc)

type InfoRouter 

type InfoRouter struct {
	traits.UnimplementedOpenCloseInfoServer

	router.Router
}

InfoRouter is a traits.OpenCloseInfoServer that allows routing named requests to specific traits.OpenCloseInfoClient

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.OpenCloseInfoClient.

func (*InfoRouter) AddOpenCloseInfoClient 

func (r *InfoRouter) AddOpenCloseInfoClient(name string, client traits.OpenCloseInfoClient) traits.OpenCloseInfoClient

func (*InfoRouter) DescribePositions 

func (r *InfoRouter) DescribePositions(ctx context.Context, request *traits.DescribePositionsRequest) (*traits.PositionsSupport, error)

func (*InfoRouter) GetOpenCloseInfoClient 

func (r *InfoRouter) GetOpenCloseInfoClient(name string) (traits.OpenCloseInfoClient, error)

func (*InfoRouter) HoldsType 

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

func (*InfoRouter) Register 

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

func (*InfoRouter) RemoveOpenCloseInfoClient 

func (r *InfoRouter) RemoveOpenCloseInfoClient(name string) traits.OpenCloseInfoClient

type InfoWrapper 

type InfoWrapper struct {
	traits.OpenCloseInfoClient
	// contains filtered or unexported fields
}

func WrapInfo 

func WrapInfo(server traits.OpenCloseInfoServer) *InfoWrapper

WrapInfo adapts a traits.OpenCloseInfoServer and presents it as a traits.OpenCloseInfoClient

func (*InfoWrapper) Unwrap 

func (w *InfoWrapper) Unwrap() any

Unwrap implements wrap.Unwrapper and returns the underlying server instance as an unknown type.

func (*InfoWrapper) UnwrapServer 

func (w *InfoWrapper) UnwrapServer() traits.OpenCloseInfoServer

UnwrapServer returns the underlying server instance.

func (*InfoWrapper) UnwrapService 

func (w *InfoWrapper) UnwrapService() (grpc.ClientConnInterface, grpc.ServiceDesc)

type Model 

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

func NewModel 

func NewModel(opts ...resource.Option) *Model

func (*Model) GetPosition 

func (m *Model) GetPosition(id string, opts ...resource.ReadOption) (*traits.OpenClosePosition, error)

func (*Model) GetPositions 

func (m *Model) GetPositions(opts ...resource.ReadOption) (*traits.OpenClosePositions, error)

func (*Model) PullPositions 

func (m *Model) PullPositions(ctx context.Context, ops ...resource.ReadOption) <-chan PullOpenClosePositionsChange

func (*Model) UpdatePosition 

func (m *Model) UpdatePosition(position *traits.OpenClosePosition, opts ...resource.WriteOption) (*traits.OpenClosePosition, error)

func (*Model) UpdatePositionN 

func (m *Model) UpdatePositionN(id uint, position *traits.OpenClosePosition, opts ...resource.WriteOption) (*traits.OpenClosePosition, error)

func (*Model) UpdatePositions 

func (m *Model) UpdatePositions(positions *traits.OpenClosePositions, opts ...resource.WriteOption) (*traits.OpenClosePositions, error)

type ModelServer 

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

func NewModelServer 

func NewModelServer(model *Model) *ModelServer

func (*ModelServer) GetPositions 

func (s *ModelServer) GetPositions(_ context.Context, request *traits.GetOpenClosePositionsRequest) (*traits.OpenClosePositions, error)

func (*ModelServer) PullPositions 

func (s *ModelServer) PullPositions(request *traits.PullOpenClosePositionsRequest, server traits.OpenCloseApi_PullPositionsServer) error

func (*ModelServer) Register 

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

func (*ModelServer) Unwrap 

func (s *ModelServer) Unwrap() any

func (*ModelServer) UpdatePositions 

func (s *ModelServer) UpdatePositions(_ context.Context, request *traits.UpdateOpenClosePositionsRequest) (*traits.OpenClosePositions, error)

type PullOpenClosePositionsChange 

type PullOpenClosePositionsChange struct {
	Positions  *traits.OpenClosePositions
	ChangeTime time.Time
}

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.