bizrepos

type Handler func(context.Context, *emptypb.Empty) error

type NodeIdBizRepo interface {
	GetConfig() *bo.NodeIDConfig
	GetNodeId(ctx context.Context, param *bo.GetNodeIdParam) (*po.NodeId, error)
	GenerateNextID(serialModel *po.NodeSerial, param *bo.GetNodeIdParam) (*po.NodeId, error)
	RenewalNodeId(ctx context.Context, param *bo.RenewalNodeIdParam) (*bo.RenewalNodeIDReply, error)
	ReleaseNodeId(ctx context.Context, param *bo.ReleaseNodeIdParam) (*po.NodeId, error)
}

type RenewNodeIDEventRepo interface {
	Publish(ctx context.Context, param *bo.RenewalNodeIdParam) error
	Consume(ctx context.Context, handler RenewNodeIDHandler) error
	Close(ctx context.Context) error
}

type RenewNodeIDHandler func(ctx context.Context, param *bo.RenewalNodeIdParam) (*bo.RenewalNodeIDReply, error)

type TestingEventRepo interface {
	Publish(ctx context.Context, msg *emptypb.Empty) error
	Consume(ctx context.Context, handler Handler) error
	Close() error
}