update

package

v1.32.0 Latest Latest Go to latest Published: Jul 15, 2026 License: MIT Imports: 22 Imported by: 0

Documentation ¶

Index ¶

type Config
- func (c Config) GRPCAddr() string
- func (c Config) Validate() error
type Update
- func NewUpdateAPI(ctx context.Context, cfg config.RuntimeConfig[Config]) (*Update, error)
type UpdateService
- func NewUpdateService(ctx context.Context) (*UpdateService, error)
- func NewUpdateServiceWithDB(db storage.Database) *UpdateService

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	GRPCAddress string `mapstructure:"grpc_address"`
}

func (Config) GRPCAddr ¶

func (c Config) GRPCAddr() string

func (Config) Validate ¶

func (c Config) Validate() error

type Update ¶

type Update struct {
	*UpdateService
	// contains filtered or unexported fields
}

func NewUpdateAPI ¶

func NewUpdateAPI(ctx context.Context, cfg config.RuntimeConfig[Config]) (*Update, error)

func (*Update) Address ¶

func (u *Update) Address() string

func (*Update) Logger ¶

func (u *Update) Logger() *logrus.Entry

func (*Update) Name ¶

func (u *Update) Name() string

func (*Update) Serve ¶

func (u *Update) Serve() error

func (*Update) Shutdown ¶

func (u *Update) Shutdown(ctx context.Context) error

type UpdateService ¶

type UpdateService struct {
	proto.UnimplementedUpdateServiceServer
	// contains filtered or unexported fields
}

UpdateService is the implementation of the Update service.

func NewUpdateService ¶

func NewUpdateService(ctx context.Context) (*UpdateService, error)

func NewUpdateServiceWithDB ¶ added in v1.26.0

func NewUpdateServiceWithDB(db storage.Database) *UpdateService

NewUpdateServiceWithDB builds an UpdateService from an already-connected db, so tests can exercise the real service with a stub database instead of a live one.

func (*UpdateService) Close ¶

func (s *UpdateService) Close() error

func (*UpdateService) DeleteRelationships ¶ added in v1.31.0

func (s *UpdateService) DeleteRelationships(ctx context.Context, req *proto.DeleteRelationshipsRequest) (*proto.DeleteRelationshipsResponse, error)

DeleteRelationships resolves and authorizes a key-based delete; the actual delete lands in a follow-up MR.

func (*UpdateService) Health ¶

func (s *UpdateService) Health(ctx context.Context, in *proto.HealthRequest) (*proto.HealthResponse, error)

Health checks the health of the Update service.

func (*UpdateService) WriteRelationships ¶ added in v1.11.0

func (s *UpdateService) WriteRelationships(ctx context.Context, req *proto.WriteRelationshipsRequest) (*proto.WriteRelationshipsResponse, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL