update

package

v1.17.0 Latest Latest Go to latest Published: Jun 23, 2026 License: MIT Imports: 20 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

func (c Config) GRPCAddr() string

func (c Config) Validate() error

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

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

func (u *Update) Address() string

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

func (u *Update) Name() string

func (u *Update) Serve() error

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

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

UpdateService is the implementation of the Update service.

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

func (s *UpdateService) Close() error

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

Health checks the health of the Update service.

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