metadata

Documentation

Index

• func WithMetadataApiClientFactory(f func(name string) (traits.MetadataApiClient, error)) router.Option
• func WithMetadataInfoClientFactory(f func(name string) (traits.MetadataInfoClient, error)) router.Option
• func WrapApi(server traits.MetadataApiServer) traits.MetadataApiClient
• func WrapInfo(server traits.MetadataInfoServer) traits.MetadataInfoClient
• type ApiRouter
  • func NewApiRouter(opts ...router.Option) *ApiRouter
  • func (r *ApiRouter) Add(name string, client any) any
  • func (r *ApiRouter) AddMetadataApiClient(name string, client traits.MetadataApiClient) traits.MetadataApiClient
  • func (r *ApiRouter) GetMetadata(ctx context.Context, request *traits.GetMetadataRequest) (*traits.Metadata, error)
  • func (r *ApiRouter) GetMetadataApiClient(name string) (traits.MetadataApiClient, error)
  • func (r *ApiRouter) HoldsType(client any) bool
  • func (r *ApiRouter) PullMetadata(request *traits.PullMetadataRequest, ...) error
  • func (r *ApiRouter) Register(server *grpc.Server)
  • func (r *ApiRouter) RemoveMetadataApiClient(name string) traits.MetadataApiClient
• type InfoRouter
  • func NewInfoRouter(opts ...router.Option) *InfoRouter
  • func (r *InfoRouter) Add(name string, client any) any
  • func (r *InfoRouter) AddMetadataInfoClient(name string, client traits.MetadataInfoClient) traits.MetadataInfoClient
  • func (r *InfoRouter) GetMetadataInfoClient(name string) (traits.MetadataInfoClient, error)
  • func (r *InfoRouter) HoldsType(client any) bool
  • func (r *InfoRouter) Register(server *grpc.Server)
  • func (r *InfoRouter) RemoveMetadataInfoClient(name string) traits.MetadataInfoClient
• type Model
  • func NewModel(opts ...resource.Option) *Model
  • func (m *Model) GetMetadata(opts ...resource.ReadOption) (*traits.Metadata, error)
  • func (m *Model) MergeMetadata(metadata *traits.Metadata, opts ...resource.WriteOption) (*traits.Metadata, error)
  • func (m *Model) PullMetadata(ctx context.Context, opts ...resource.ReadOption) <-chan *traits.PullMetadataResponse_Change
  • func (m *Model) UpdateMetadata(metadata *traits.Metadata, opts ...resource.WriteOption) (*traits.Metadata, error)
  • func (m *Model) UpdateTraitMetadata(traitMetadata *traits.TraitMetadata, opts ...resource.WriteOption) (*traits.Metadata, error)
• type ModelServer
  • func NewModelServer(model *Model) *ModelServer
  • func (s *ModelServer) GetMetadata(_ context.Context, request *traits.GetMetadataRequest) (*traits.Metadata, error)
  • func (s *ModelServer) PullMetadata(request *traits.PullMetadataRequest, ...) error
  • func (s *ModelServer) Register(server *grpc.Server)
  • func (s *ModelServer) Unwrap() any

Functions

func WithMetadataApiClientFactory

func WithMetadataApiClientFactory(f func(name string) (traits.MetadataApiClient, error)) router.Option

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

func WithMetadataInfoClientFactory

func WithMetadataInfoClientFactory(f func(name string) (traits.MetadataInfoClient, error)) router.Option

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

func WrapApi

func WrapApi(server traits.MetadataApiServer) traits.MetadataApiClient

WrapApi adapts a traits.MetadataApiServer and presents it as a traits.MetadataApiClient

func WrapInfo

func WrapInfo(server traits.MetadataInfoServer) traits.MetadataInfoClient

WrapInfo adapts a traits.MetadataInfoServer and presents it as a traits.MetadataInfoClient

Types

type ApiRouter

type ApiRouter struct {
	traits.UnimplementedMetadataApiServer

	router.Router
}

ApiRouter is a traits.MetadataApiServer that allows routing named requests to specific traits.MetadataApiClient

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

func (*ApiRouter) AddMetadataApiClient

func (r *ApiRouter) AddMetadataApiClient(name string, client traits.MetadataApiClient) traits.MetadataApiClient

func (*ApiRouter) GetMetadata

func (r *ApiRouter) GetMetadata(ctx context.Context, request *traits.GetMetadataRequest) (*traits.Metadata, error)

func (*ApiRouter) GetMetadataApiClient

func (r *ApiRouter) GetMetadataApiClient(name string) (traits.MetadataApiClient, error)

func (*ApiRouter) HoldsType

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

func (*ApiRouter) PullMetadata

func (r *ApiRouter) PullMetadata(request *traits.PullMetadataRequest, server traits.MetadataApi_PullMetadataServer) error

func (*ApiRouter) Register

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

func (*ApiRouter) RemoveMetadataApiClient

func (r *ApiRouter) RemoveMetadataApiClient(name string) traits.MetadataApiClient

type InfoRouter

type InfoRouter struct {
	traits.UnimplementedMetadataInfoServer

	router.Router
}

InfoRouter is a traits.MetadataInfoServer that allows routing named requests to specific traits.MetadataInfoClient

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

func (*InfoRouter) AddMetadataInfoClient

func (r *InfoRouter) AddMetadataInfoClient(name string, client traits.MetadataInfoClient) traits.MetadataInfoClient

func (*InfoRouter) GetMetadataInfoClient

func (r *InfoRouter) GetMetadataInfoClient(name string) (traits.MetadataInfoClient, error)

func (*InfoRouter) HoldsType

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

func (*InfoRouter) Register

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

func (*InfoRouter) RemoveMetadataInfoClient

func (r *InfoRouter) RemoveMetadataInfoClient(name string) traits.MetadataInfoClient

type Model

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

func NewModel

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

func (*Model) GetMetadata

func (m *Model) GetMetadata(opts ...resource.ReadOption) (*traits.Metadata, error)

func (*Model) MergeMetadata

func (m *Model) MergeMetadata(metadata *traits.Metadata, opts ...resource.WriteOption) (*traits.Metadata, error)

MergeMetadata writes any present fields in metadata to the existing data. Traits that exist in the given metadata are merged with existing traits using

func (*Model) PullMetadata

func (m *Model) PullMetadata(ctx context.Context, opts ...resource.ReadOption) <-chan *traits.PullMetadataResponse_Change

func (*Model) UpdateMetadata

func (m *Model) UpdateMetadata(metadata *traits.Metadata, opts ...resource.WriteOption) (*traits.Metadata, error)

func (*Model) UpdateTraitMetadata

func (m *Model) UpdateTraitMetadata(traitMetadata *traits.TraitMetadata, opts ...resource.WriteOption) (*traits.Metadata, error)

type ModelServer

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

func NewModelServer

func NewModelServer(model *Model) *ModelServer

func (*ModelServer) GetMetadata

func (s *ModelServer) GetMetadata(_ context.Context, request *traits.GetMetadataRequest) (*traits.Metadata, error)

func (*ModelServer) PullMetadata

func (s *ModelServer) PullMetadata(request *traits.PullMetadataRequest, server traits.MetadataApi_PullMetadataServer) error

func (*ModelServer) Register

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

func (*ModelServer) Unwrap

func (s *ModelServer) Unwrap() any